sdk

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 26, 2026 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ElectionClient 

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

func NewElectionClient 

func NewElectionClient(grpcConn grpc.ClientConnInterface) *ElectionClient

func (*ElectionClient) Election 

func (e *ElectionClient) Election(ctx context.Context, term uint64) error

func (*ElectionClient) Vote 

func (e *ElectionClient) Vote(ctx context.Context, bulletin *domain.Bulletin) (err error)

type ReplicaClient 

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

func NewClient 

func NewClient(grpcConn grpc.ClientConnInterface, closer closer.Closer) *ReplicaClient

func (*ReplicaClient) OnRecvMeta 

func (c *ReplicaClient) OnRecvMeta() emitter.Emitter[*domain.Meta]

func (*ReplicaClient) OnRecvState 

func (c *ReplicaClient) OnRecvState() emitter.Emitter[*domain.State]

func (*ReplicaClient) Subscribe 

func (c *ReplicaClient) Subscribe(ctx context.Context, myMeta *domain.Meta) (err error)

type SyncClient 

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

func NewSyncClient 

func NewSyncClient(grpcConn grpc.ClientConnInterface) *SyncClient

func (*SyncClient) Hosts 

func (s *SyncClient) Hosts(ctx context.Context, hosts set.Set[string]) (set.Set[string], error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.