Method loop

ring/partition_ring_watcher.go:92–107

(ctx context.Context)

}

func (w *PartitionRingWatcher) loop(ctx context.Context) error {
	var watchErr error
	w.kv.WatchKey(ctx, w.key, func(value interface{}) bool {
		if value == nil {
			level.Info(w.logger).Log("msg", "partition ring doesn't exist in KV store yet")
			return true
		}

		if err := w.updatePartitionRing(value.(*PartitionRingDesc)); err != nil {
			watchErr = err
			return false
		}
		return true
	})
	return watchErr
}

func (w *PartitionRingWatcher) updatePartitionRing(desc *PartitionRingDesc) error {
	newRing, err := NewPartitionRingWithOptions(*desc, w.opts)