server

Documentation

Index

• type Option
  • func WithElectionTime(duration time.Duration) Option
  • func WithLogger(log logger.Logger) Option
• type Server
  • func New(ctx context.Context, serverRPC *rpc.Server, peers []string, options ...Option) (*Server, error)
  • func (s *Server) GetStatus() v1.RaftStatus

Types

type Option

type Option func(*Server)

func WithElectionTime

func WithElectionTime(duration time.Duration) Option

WithElectionTime sets the election time for the server

func WithLogger

func WithLogger(log logger.Logger) Option

WithLogger sets the logger for the server

type Server

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

func New

func New(ctx context.Context, serverRPC *rpc.Server, peers []string, options ...Option) (*Server, error)

func (*Server) GetStatus

func (s *Server) GetStatus() v1.RaftStatus

GetStatus returns the status of the raft node.