Function SimpleRingLifecycler

ring/example/local/local.go:212–232

SimpleRingLifecycler returns an instance lifecycler for the given `kv.Client`. Usually lifecycler will be part of the server side that act as a single peer.

(store kv.Client, bindaddr string, bindport int)

// SimpleRingLifecycler returns an instance lifecycler for the given `kv.Client`.
// Usually lifecycler will be part of the server side that act as a single peer.
func SimpleRingLifecycler(store kv.Client, bindaddr string, bindport int) (*ring.BasicLifecycler, error) {
	var config ring.BasicLifecyclerConfig
	config.ID = bindaddr
	config.Addr = net.JoinHostPort(bindaddr, strconv.Itoa(bindport))

	var delegate ring.BasicLifecyclerDelegate

	delegate = ring.NewInstanceRegisterDelegate(ring.ACTIVE, 128)
	delegate = ring.NewLeaveOnStoppingDelegate(delegate, logger)
	delegate = ring.NewAutoForgetDelegate(1*time.Minute, delegate, logger)

	return ring.NewBasicLifecycler(
		config,
		"local",
		"collectors/ring",
		store,
		delegate,
		log.With(logger, "component", "lifecycler"),
		prometheus.NewPedanticRegistry(),
	)
}