Method running

ring/partition_instance_lifecycler.go:181–205

(ctx context.Context)

}

func (l *PartitionInstanceLifecycler) running(ctx context.Context) error {
	reconcile := func() {
		l.reconcileOwnedPartition(ctx, time.Now())
		l.reconcileOtherPartitions(ctx, time.Now())
	}

	// Run a reconciliation as soon as the lifecycler, in order to not having to wait for the 1st timer tick.
	reconcile()

	reconcileTicker := time.NewTicker(l.cfg.PollingInterval)
	defer reconcileTicker.Stop()

	for {
		select {
		case <-reconcileTicker.C:
			reconcile()

		case f := <-l.actorChan:
			f()

		case <-ctx.Done():
			return nil
		}
	}
}

func (l *PartitionInstanceLifecycler) stopping(_ error) error {
	level.Info(l.logger).Log("msg", "partition ring lifecycler is shutting down", "ring", l.ringName)