recordWrite stamps the time of a successful trace write. Callers should invoke this after every method that emits traces to the distributor so that WaitTracesQueryable can wait for the query_end_cutoff window to elapse before tests assert queryability.
()
| 130 | // after every method that emits traces to the distributor so that WaitTracesQueryable |
| 131 | // can wait for the query_end_cutoff window to elapse before tests assert queryability. |
| 132 | func (h *TempoHarness) recordWrite() { |
| 133 | h.lastWriteUnixNano.Store(time.Now().UnixNano()) |
| 134 | } |
| 135 | |
| 136 | // TestHarnessConfig provides configuration options for the test harness |
| 137 | type TestHarnessConfig struct { |
no test coverage detected