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
}