Function NewPartitionRingWatcher

ring/partition_ring_watcher.go:41–43

(name, key string, kv kv.Client, logger log.Logger, reg prometheus.Registerer)

}

func NewPartitionRingWatcher(name, key string, kv kv.Client, logger log.Logger, reg prometheus.Registerer) *PartitionRingWatcher {
	return NewPartitionRingWatcherWithOptions(name, key, kv, DefaultPartitionRingOptions(), logger, reg)
}

func NewPartitionRingWatcherWithOptions(name, key string, kv kv.Client, opts PartitionRingOptions, logger log.Logger, reg prometheus.Registerer) *PartitionRingWatcher {
	emptyRing, err := NewPartitionRingWithOptions(*NewPartitionRingDesc(), opts)