cluster

type FilterFunc func(replica Replica) bool

type Manager interface {
	OnChangeMaster() emitter.Emitter[Replica]
	OnMasterCandidateConnect() emitter.Emitter[Peer]
	OnMasterDisconnection() emitter.Emitter[Peer]
	OnAddPeer() emitter.Emitter[Peer]
	OnDeletingPeer() emitter.Emitter[Peer]
	OnClusterReady() emitter.Emitter[set.Set[Replica]]
	OnClusterSick() emitter.Emitter[set.Set[Replica]]

	Me() Me
	Master() Replica
	Slaves() set.Set[Replica]
	AddPeer(Peer) error
	RemovePeer(Peer) error
	AllReplicas() set.Set[Replica]
	AllPeers() set.Set[Peer]
	Filter(FilterFunc) set.Set[Replica]
	GetPeerHosts() set.Set[string]
}

type Me interface {
	Replica

	OnChangeScore() emitter.Emitter[Me]
	GetTimeStart() time.Time
	SetScore(float32)
	GetMeta() *domain.Meta
	GetState() *domain.State
	AddRoles(set.Set[domain.Role])
	AddRole(domain.Role)
	RemoveRoles(set.Set[domain.Role])
	RemoveRole(domain.Role)
}

type Peer interface {
	runner.Process
	Replica

	OnChangeStatus() emitter.Emitter[Peer]
	OnChangeAvailableRoles() emitter.Emitter[Peer]
	GetStatus() domain.Status
	GetGrpcConnection() (grpc.ClientConnInterface, error)
}

type Replica interface {
	OnChangeRole() emitter.Emitter[Replica]
	GetId() uuid.UUID
	GetHost() string
	GetName() string
	GetUptime() time.Duration
	GetScore() float32
	GetResource() *linker.Linker[resource.Type, *resource.Resource]
	GetAvailableRoles() set.Set[domain.Role]
	GetRoles() set.Set[domain.Role]
	IsMe() bool
}