elector

type LeaderCallbacks struct {
	// OnStartedLeading is called when a LeaderElector client starts leading
	OnStartedLeading func(shardId int)
	// OnStoppedLeading is called when a LeaderElector client stops leading
	OnStoppedLeading func(shardId int)
}

type LeaderElector interface {
	Run(ctx context.Context)
	IsLeader(shardId int) bool
	GetLeaders() map[int]proxyv1alpha1.EndpointInfo
	SetCallbacks(LeaderCallbacks)
}