Method shouldForceFromLookback

modules/livestore/live_store.go:377–392

shouldForceFromLookback decides whether to re-read the Kafka lookback to rebuild query state. Skipped when local data exists, or when the partition is Inactive (prior pod already drained).

(ctx context.Context)

// shouldForceFromLookback decides whether to re-read the Kafka lookback to rebuild query state.
// Skipped when local data exists, or when the partition is Inactive (prior pod already drained).
func (s *LiveStore) shouldForceFromLookback(ctx context.Context) bool {
	if len(s.getInstances()) > 0 {
		return false
	}
	state, _, err := s.ingestPartitionLifecycler.GetPartitionState(ctx)
	if err != nil {
		level.Warn(s.logger).Log("msg", "failed to read partition state, defaulting to lookback replay", "err", err)
		return true
	}
	if state == ring.PartitionInactive {
		level.Info(s.logger).Log("msg", "skipping lookback replay because partition is Inactive")
		return false
	}
	level.Info(s.logger).Log("msg", "no local data found after reload, will force reading from lookback period")
	return true
}

func (s *LiveStore) startKafkaIngestPath(ctx context.Context) error {
	forceFromLookback := s.shouldForceFromLookback(ctx)