Function main

cmd/tempo-vulture/main.go:138–244

()

}

func main() {
	flag.Parse()

	config := zap.NewDevelopmentEncoderConfig()
	logger = zap.New(zapcore.NewCore(
		zaplogfmt.NewEncoder(config),
		os.Stdout,
		zapcore.DebugLevel,
	))

	vultureConfig := vultureConfiguration{
		tempoQueryURL:                   tempoQueryURL,
		tempoPushURL:                    tempoPushURL,
		tempoOrgID:                      tempoOrgID,
		tempoWriteBackoffDuration:       tempoWriteBackoffDuration,
		tempoLongWriteBackoffDuration:   tempoLongWriteBackoffDuration,
		tempoReadBackoffDuration:        tempoReadBackoffDuration,
		tempoSearchBackoffDuration:      tempoSearchBackoffDuration,
		tempoMetricsBackoffDuration:     tempoMetricsBackoffDuration,
		tempoRetentionDuration:          tempoRetentionDuration,
		tempoRecentTracesCutoffDuration: tempoRecentTracesCutoffDuration,
		tempoPushTLS:                    tempoPushTLS,
		tempoQueryLiveStores:            tempoQueryLiveStores,
	}
	pushEndpoint, err := getGRPCEndpoint(vultureConfig.tempoPushURL)
	if err != nil {
		panic(err)
	}

	logger.Info("Tempo Vulture starting", zap.String("tempoQueryURL", vultureConfig.tempoQueryURL), zap.String("tempoPushURL", pushEndpoint))
	jaegerClient, err := utilpkg.NewJaegerToOTLPExporterWithAuth(pushEndpoint, "", "", vultureConfig.tempoPushTLS)
	httpClient := createHTTPClient(vultureConfig.tempoQueryURL, vultureConfig.tempoOrgID, vultureConfig.tempoQueryLiveStores)
	if err != nil {
		panic(err)
	}

	tickerWrite, tickerRead, tickerSearch, tickerMetrics, err := initTickers(
		vultureConfig.tempoWriteBackoffDuration,
		vultureConfig.tempoReadBackoffDuration,
		vultureConfig.tempoSearchBackoffDuration,
		vultureConfig.tempoMetricsBackoffDuration,
	)
	if err != nil {
		panic(err)
	}
	startTime := time.Now()
	r := rand.New(rand.NewSource(startTime.Unix()))
	interval := vultureConfig.tempoWriteBackoffDuration

	selectRecentTimestamp := func(now time.Time) (newStart, ts time.Time, skip bool) {
		oldest := now.Add(-vultureConfig.tempoRecentTracesCutoffDuration)
		if oldest.Before(startTime) { // if vulture's just started
			oldest = startTime
		}
		newStart, ts = selectPastTimestamp(oldest, now, interval, vultureConfig.tempoRetentionDuration, r)
		return newStart, ts, skip
	}