Function New

pkg/ring/ring.go:22–33

New creates a new distributed consistent hash ring. It shadows the cortex ring.New method so we can use our own replication strategy for repl factor = 2

(cfg ring.Config, name, key string, reg prometheus.Registerer)

// New creates a new distributed consistent hash ring.  It shadows the cortex
// ring.New method so we can use our own replication strategy for repl factor = 2
func New(cfg ring.Config, name, key string, reg prometheus.Registerer) (*ring.Ring, error) {
	reg = prometheus.WrapRegistererWithPrefix("tempo_", reg)

	statReplicationFactor.Set(int64(cfg.ReplicationFactor))
	statKvStore.Set(cfg.KVStore.Store)

	if cfg.ReplicationFactor == 2 {
		return newEventuallyConsistentRing(cfg, name, key, reg)
	}

	return ring.New(cfg, name, key, log.Logger, reg)
}

func newEventuallyConsistentRing(cfg ring.Config, name, key string, reg prometheus.Registerer) (*ring.Ring, error) {
	codec := ring.GetCodec()