Method EnablePolling

tempodb/tempodb.go:716–765

EnablePolling activates the polling loop. Pass nil if this component should never be a tenant index builder.

(ctx context.Context, sharder blocklist.JobSharder, skipNoCompactBlocks bool)

//
//	should never be a tenant index builder.
func (rw *readerWriter) EnablePolling(ctx context.Context, sharder blocklist.JobSharder, skipNoCompactBlocks bool) {
	if sharder == nil {
		sharder = blocklist.OwnsNothingSharder
	}

	if rw.cfg.BlocklistPoll == 0 {
		rw.cfg.BlocklistPoll = DefaultBlocklistPoll
	}

	if rw.cfg.BlocklistPollConcurrency == 0 {
		rw.cfg.BlocklistPollConcurrency = DefaultBlocklistPollConcurrency
	}

	if rw.cfg.BlocklistPollTenantConcurrency == 0 {
		rw.cfg.BlocklistPollTenantConcurrency = DefaultBlocklistPollTenantConcurrency
	}

	if rw.cfg.BlocklistPollTenantIndexBuilders <= 0 {
		rw.cfg.BlocklistPollTenantIndexBuilders = DefaultTenantIndexBuilders
	}

	if rw.cfg.EmptyTenantDeletionAge <= 0 {
		rw.cfg.EmptyTenantDeletionAge = DefaultEmptyTenantDeletionAge
	}

	level.Info(rw.logger).Log("msg", "polling enabled", "interval", rw.cfg.BlocklistPoll, "blocklist_concurrency", rw.cfg.BlocklistPollConcurrency)

	blocklistPoller := blocklist.NewPoller(&blocklist.PollerConfig{
		PollConcurrency:            rw.cfg.BlocklistPollConcurrency,
		PollFallback:               rw.cfg.BlocklistPollFallback,
		TenantIndexBuilders:        rw.cfg.BlocklistPollTenantIndexBuilders,
		StaleTenantIndex:           rw.cfg.BlocklistPollStaleTenantIndex,
		PollJitterMs:               rw.cfg.BlocklistPollJitterMs,
		TolerateConsecutiveErrors:  rw.cfg.BlocklistPollTolerateConsecutiveErrors,
		TolerateTenantFailures:     rw.cfg.BlocklistPollTolerateTenantFailures,
		TenantPollConcurrency:      rw.cfg.BlocklistPollTenantConcurrency,
		EmptyTenantDeletionAge:     rw.cfg.EmptyTenantDeletionAge,
		EmptyTenantDeletionEnabled: rw.cfg.EmptyTenantDeletionEnabled,
		SkipNoCompactBlocks:        skipNoCompactBlocks,
	}, sharder, rw.r, rw.c, rw.w, rw.logger)

	rw.blocklistPoller = blocklistPoller
	rw.pollerShutdownCh = make(chan struct{})

	// do the first poll cycle synchronously. this will allow the caller to know
	// that when this method returns the block list is updated
	rw.pollBlocklist(ctx)

	go rw.pollingLoop(ctx)
}

func (rw *readerWriter) PollNow(ctx context.Context) {
	rw.pollBlocklist(ctx)