Function NewKV

kv/memberlist/memberlist_client.go:458–490

NewKV creates new gossip-based KV service. Note that service needs to be started, until then it doesn't initialize gossiping part. Only after service is in Running state, it is really gossiping. Starting the service will also trigger connecting to the existing memberlist cluster. If that fails and A

(cfg KVConfig, logger log.Logger, dnsProvider DNSProvider, registerer prometheus.Registerer)

// trigger connecting to the existing memberlist cluster. If that fails and AbortIfJoinFails is true, error is returned
// and service enters Failed state.
func NewKV(cfg KVConfig, logger log.Logger, dnsProvider DNSProvider, registerer prometheus.Registerer) *KV {
	cfg.TCPTransport.MetricsNamespace = cfg.MetricsNamespace

	mlkv := &KV{
		cfg:              cfg,
		logger:           logger,
		registerer:       registerer,
		provider:         dnsProvider,
		store:            make(map[string]ValueDesc),
		codecs:           make(map[string]codec.Codec),
		watchers:         make(map[string][]chan string),
		keyNotifications: make(map[string]struct{}),
		prefixWatchers:   make(map[string][]chan string),
		workersChannels:  make(map[string]chan valueUpdate),
		shutdown:         make(chan struct{}),
		maxCasRetries:    maxCasRetries,
	}

	mlkv.createAndRegisterMetrics()

	for _, c := range cfg.Codecs {
		mlkv.codecs[c.CodecID()] = c
	}

	// Register propagation delay tracker codec if enabled.
	if cfg.PropagationDelayTracker.Enabled {
		mlkv.codecs[PropagationDelayTrackerCodecID] = GetPropagationDelayTrackerCodec()
	}

	mlkv.NamedService = services.NewBasicService(mlkv.starting, mlkv.running, mlkv.stopping).WithName("memberlist_kv")

	return mlkv
}

func defaultMemberlistConfig() *memberlist.Config {
	return memberlist.DefaultLANConfig()