Function SimpleMemberlistKV

ring/example/local/local.go:156–192

SimpleMemberlistKV returns a memberlist KV as a service. Starting and stopping the service is up to the caller. Caller can create an instance `kv.Client` from returned service by explicity calling `.GetMemberlistKV()` which can be used as dependency to create a ring or ring lifecycler.

(bindaddr string, bindport int, joinmembers []string)

// Caller can create an instance `kv.Client` from returned service by explicity calling `.GetMemberlistKV()`
// which can be used as dependency to create a ring or ring lifecycler.
func SimpleMemberlistKV(bindaddr string, bindport int, joinmembers []string) *memberlist.KVInitService {
	var config memberlist.KVConfig
	flagext.DefaultValues(&config)

	// Codecs is used to tell memberlist library how to serialize/de-serialize the messages between peers.
	// `ring.GetCodec()` uses default, which is protobuf.
	config.Codecs = []codec.Codec{ring.GetCodec()}

	// TCPTransport defines what addr and port this particular peer should listen on.
	config.TCPTransport = memberlist.TCPTransportConfig{
		BindPort:  bindport,
		BindAddrs: []string{bindaddr},
	}

	// joinmembers are the addresses of peers who are already in the memberlist group.
	// Usually provided if this peer is trying to join an existing cluster.
	// Generally you start the very first peer without `joinmembers`, but start all
	// other peers with at least one `joinmembers`.
	if len(joinmembers) > 0 {
		config.JoinMembers = joinmembers
	}

	// resolver defines how each peers IP address should be resolved.
	// We use default resolver comes with Go.
	resolver := dns.NewProvider(dns.GolangResolverType, 0, log.With(logger, "component", "dns"), prometheus.NewPedanticRegistry())

	config.NodeName = bindaddr
	config.StreamTimeout = 5 * time.Second

	return memberlist.NewKVInitService(
		&config,
		log.With(logger, "component", "memberlist"),
		resolver,
		prometheus.NewPedanticRegistry(),
	)

}

// SimpleRing returns an instance of `ring.Ring` as a service. Starting and stopping the service is up to the caller.
func SimpleRing(store kv.Client) (*ring.Ring, error) {