cluster

Documentation

Index

• type Config
  • func DefaultConfig() *Config
• type RaftLayer
  • func NewRaftLayer(addr net.Addr) *RaftLayer
  • func (l *RaftLayer) Accept() (net.Conn, error)
  • func (l *RaftLayer) Addr() net.Addr
  • func (l *RaftLayer) Close() error
  • func (l *RaftLayer) Dial(address raft.ServerAddress, timeout time.Duration) (net.Conn, error)
• type Server
  • func NewServer(config *Config, logger *log.Logger) *Server
  • func (s *Server) Apply(cmd []byte, timeout time.Duration) raft.ApplyFuture
  • func (s *Server) GRPCServer() *grpc.Server
  • func (s *Server) IsLeader() bool
  • func (s *Server) SetupGRPC() error
  • func (s *Server) SetupRaft(fsm raft.FSM) error
  • func (s *Server) SetupSerf() error

Types

type Config

type Config struct {
	NodeName          string
	ServiceName       string
	Tags              map[string]string
	BootstrapExpected int64
	LogOutput         io.Writer
	GRPCAddr          *net.TCPAddr
}

func DefaultConfig

func DefaultConfig() *Config

type RaftLayer

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

func NewRaftLayer

func NewRaftLayer(addr net.Addr) *RaftLayer

func (*RaftLayer) Accept

func (l *RaftLayer) Accept() (net.Conn, error)

func (*RaftLayer) Addr

func (l *RaftLayer) Addr() net.Addr

func (*RaftLayer) Close

func (l *RaftLayer) Close() error

func (*RaftLayer) Dial

func (l *RaftLayer) Dial(address raft.ServerAddress, timeout time.Duration) (net.Conn, error)

type Server

type Server struct {
	Config *Config

	// serf
	Serf *serf.Serf

	EventCh chan serf.Event

	// raft
	Raft     *raft.Raft
	LeaderCh chan bool
	// contains filtered or unexported fields
}

func NewServer

func NewServer(config *Config, logger *log.Logger) *Server

func (*Server) Apply

func (s *Server) Apply(cmd []byte, timeout time.Duration) raft.ApplyFuture

func (*Server) GRPCServer

func (s *Server) GRPCServer() *grpc.Server

func (*Server) IsLeader

func (s *Server) IsLeader() bool

func (*Server) SetupGRPC

func (s *Server) SetupGRPC() error

func (*Server) SetupRaft

func (s *Server) SetupRaft(fsm raft.FSM) error

func (*Server) SetupSerf

func (s *Server) SetupSerf() error