Function runChecker

cmd/tempo-vulture/main.go:366–399

(
	ticker *time.Ticker,
	config vultureConfiguration,
	selectPastTimestamp func(now time.Time) (newStart, ts time.Time, skip bool),
	checker func(*util.TraceInfo, *zap.Logger),
	l *zap.Logger,
)

}

func runChecker(
	ticker *time.Ticker,
	config vultureConfiguration,
	selectPastTimestamp func(now time.Time) (newStart, ts time.Time, skip bool),
	checker func(*util.TraceInfo, *zap.Logger),
	l *zap.Logger,
) {
	if ticker == nil {
		return
	}
	go func() {
		for now := range ticker.C {
			startTime, seed, skip := selectPastTimestamp(now)
			if skip {
				continue
			}

			logger := l.With(
				zap.String("org_id", config.tempoOrgID),
				zap.Int64("seed", seed.Unix()),
			)

			info := util.NewTraceInfo(seed, config.tempoOrgID)

			// Don't query for a trace we don't expect to be complete
			if !traceIsReady(info, now, startTime,
				config.tempoWriteBackoffDuration, config.tempoLongWriteBackoffDuration) {
				continue
			}

			checker(info, logger)
		}
	}()
}

func doRead(httpClient httpclient.TempoHTTPClient, _ vultureConfiguration, info *util.TraceInfo, l *zap.Logger) {
	// query the trace