servicediscovery

type Client interface {
	Close() error
	Ping() error
	Register() error
	IsConnected() bool
	Reconnect() error
	Rebalance(memberNumber int, totalMembers int) error
}

type Handler struct {
	// contains filtered or unexported fields
}

type Ping struct {
	From *models.Identity
}

type Pong struct {
	From *models.Identity
}

type Rebalance struct {
	From         *models.Identity
	MemberNumber int
	TotalMembers int
}

type Register struct {
	From     *models.Identity
	Identity *models.Identity
}

type Server interface {
	Listen()
	Shutdown()
}

type Service struct {
	Client          Client
	Name            string
	ClusterJoinTime int64
}

type ServiceBy func(s1, s2 *Service) bool

type ServiceDiscovery interface {
	Add(service *Service)
	Remove(name string)
	RemoveAll()
	AssignLeader(leaderService *Service)
	RemoveLeader()
	ReassignLeader() error
	StartHeartbeat()
	StopHeartbeat()
	StartMonitor()
	StopMonitor()
	GetAll() []string
	SetInfo(memberNumber int, totalMembers int)
	BeLeader()
	DontBeLeader()
}