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 ElectionClient struct + func NewElectionClient(grpcConn grpc.ClientConnInterface) *ElectionClient + func (e *ElectionClient) Election(ctx context.Context, term uint64) error + func (e *ElectionClient) Vote(ctx context.Context, bulletin *domain.Bulletin) (err error) + type ReplicaClient struct + func NewClient(grpcConn grpc.ClientConnInterface, closer closer.Closer) *ReplicaClient + func (c *ReplicaClient) OnRecvMeta() emitter.Emitter[*domain.Meta] + func (c *ReplicaClient) OnRecvState() emitter.Emitter[*domain.State] + func (c *ReplicaClient) Subscribe(ctx context.Context, myMeta *domain.Meta) (err error) + type SyncClient struct + func NewSyncClient(grpcConn grpc.ClientConnInterface) *SyncClient + func (s *SyncClient) Hosts(ctx context.Context, hosts set.Set[string]) (set.Set[string], error)
Go to main page