func()

in plugins/storage/memory/memory.go [122:143]


func (m *Memory) GetTestEvents(_ xcontext.Context, eventQuery *testevent.Query) ([]testevent.Event, error) {
	m.lock.Lock()
	defer m.lock.Unlock()

	var matchingTestEvents []testevent.Event

	if emptyTestEventQuery(eventQuery) {
		return matchingTestEvents, nil
	}

	for _, event := range m.testEvents {
		if eventJobMatch(eventQuery.JobID, event.Header.JobID) &&
			eventRunMatch(eventQuery.RunID, event.Header.RunID) &&
			eventNameMatch(eventQuery.EventNames, event.Data.EventName) &&
			eventTimeMatch(eventQuery.EmittedStartTime, eventQuery.EmittedEndTime, event.EmitTime) &&
			eventTestMatch(eventQuery.TestName, event.Header.TestName) &&
			eventTestStepMatch(eventQuery.TestStepLabel, event.Header.TestStepLabel) {
			matchingTestEvents = append(matchingTestEvents, event)
		}
	}
	return matchingTestEvents, nil
}