cluster

Documentation

Index

• type Service
  • func New(cfg store.Config) *Service
  • func (c *Service) Close(ctx context.Context) error
  • func (c *Service) LeaderWithID() (string, string)
  • func (c *Service) Open(ctx context.Context, db store.Indexer) error
  • func (c *Service) Ready() bool

Types

type Service

type Service struct {
	*store.Service
	// contains filtered or unexported fields
}

Service class serves as the primary entry point for the Raft layer, managing and coordinating the key functionalities of the distributed consensus protocol.

func New

func New(cfg store.Config) *Service

func (*Service) Close

func (c *Service) Close(ctx context.Context) error

func (*Service) LeaderWithID

func (c *Service) LeaderWithID() (string, string)

LeaderWithID is used to return the current leader address and ID of the cluster. It may return empty strings if there is no current leader or the leader is unknown.

func (*Service) Open

func (c *Service) Open(ctx context.Context, db store.Indexer) error

Open internal RPC service to handle node communication, bootstrap the Raft node, and restore the database state

func (*Service) Ready

func (c *Service) Ready() bool