Function NewInstanceRegisterDelegate

ring/basic_lifecycler_delegates.go:161–166

(state InstanceState, tokenCount int)

}

func NewInstanceRegisterDelegate(state InstanceState, tokenCount int) InstanceRegisterDelegate {
	return InstanceRegisterDelegate{
		registerState: state,
		tokenCount:    tokenCount,
	}
}

func (d InstanceRegisterDelegate) OnRingInstanceRegister(l *BasicLifecycler, ringDesc Desc, instanceExists bool, _ string, instanceDesc InstanceDesc) (InstanceState, Tokens) {
	// Keep the existing tokens if any, otherwise start with a clean situation.