IsCompleteFor returns true if the combiner has reached the limit and all traces are after the given time
(ts uint32)
| 188 | |
| 189 | // IsCompleteFor returns true if the combiner has reached the limit and all traces are after the given time |
| 190 | func (c *mostRecentCombiner) IsCompleteFor(ts uint32) bool { |
| 191 | if ts == TimestampNever { |
| 192 | return false |
| 193 | } |
| 194 | |
| 195 | if c.Count() < c.keepMostRecent { |
| 196 | return false |
| 197 | } |
| 198 | |
| 199 | return c.OldestTimestampNanos() > uint64(ts)*uint64(time.Second) |
| 200 | } |
| 201 | |
| 202 | func (c *mostRecentCombiner) Metadata() []*tempopb.TraceSearchMetadata { |
| 203 | return c.trsSorted |
nothing calls this directly
no test coverage detected