Versions in this module Expand all Collapse all v0 v0.0.2 May 26, 2026 v0.0.1 May 25, 2026 Changes in this version + type FilterFunc func(replica Replica) bool + func AvailableRoleFilter(role domain.Role) FilterFunc + func HostFilter(host string) FilterFunc + func IdFilter(id uuid.UUID) FilterFunc + func NameFilter(name string) FilterFunc + func NotRoleFilter(role domain.Role) FilterFunc + func RoleFilter(role domain.Role) FilterFunc + func StatusFilter(status domain.Status) FilterFunc + type Manager interface + AddPeer func(Peer) error + AllPeers func() set.Set[Peer] + AllReplicas func() set.Set[Replica] + Filter func(FilterFunc) set.Set[Replica] + GetPeerHosts func() set.Set[string] + Master func() Replica + Me func() Me + OnAddPeer func() emitter.Emitter[Peer] + OnChangeMaster func() emitter.Emitter[Replica] + OnClusterReady func() emitter.Emitter[set.Set[Replica]] + OnClusterSick func() emitter.Emitter[set.Set[Replica]] + OnDeletingPeer func() emitter.Emitter[Peer] + OnMasterCandidateConnect func() emitter.Emitter[Peer] + OnMasterDisconnection func() emitter.Emitter[Peer] + RemovePeer func(Peer) error + Slaves func() set.Set[Replica] + type Me interface + AddRole func(domain.Role) + AddRoles func(set.Set[domain.Role]) + GetMeta func() *domain.Meta + GetState func() *domain.State + GetTimeStart func() time.Time + OnChangeScore func() emitter.Emitter[Me] + RemoveRole func(domain.Role) + RemoveRoles func(set.Set[domain.Role]) + SetScore func(float32) + type Peer interface + GetGrpcConnection func() (grpc.ClientConnInterface, error) + GetStatus func() domain.Status + OnChangeAvailableRoles func() emitter.Emitter[Peer] + OnChangeStatus func() emitter.Emitter[Peer] + type Replica interface + GetAvailableRoles func() set.Set[domain.Role] + GetHost func() string + GetId func() uuid.UUID + GetName func() string + GetResource func() *linker.Linker[resource.Type, *resource.Resource] + GetRoles func() set.Set[domain.Role] + GetScore func() float32 + GetUptime func() time.Duration + IsMe func() bool + OnChangeRole func() emitter.Emitter[Replica]
Go to main page