membership

Documentation

Index

• type PeerInfo
• type RaftLayer
  • func NewRaftLayer(src, addr net.Addr, tlsWrap tlsutil.Wrapper, ...) *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)
  • func (l *RaftLayer) Handoff(c net.Conn) error
• type Server
  • func NewServer(id, raftBind, environment string, peers []PeerInfo, bootstrap bool) *Server
  • func (s *Server) FSM() *fsm.FSM
  • func (s *Server) InitRaft() error
  • func (s *Server) IsLeader() bool
  • func (s *Server) Watch(stream pb.RaftMemberShip_WatchServer) error

Types

type PeerInfo

type PeerInfo struct {
	Name    string
	Address string
}

type RaftLayer

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

RaftLayer implements the raft.StreamLayer interface, so that we can use a single RPC layer for Raft and Consul

func NewRaftLayer

func NewRaftLayer(src, addr net.Addr, tlsWrap tlsutil.Wrapper, tlsFunc func(raft.ServerAddress) bool) *RaftLayer

NewRaftLayer is used to initialize a new RaftLayer which can be used as a StreamLayer for Raft. If a tlsConfig is provided, then the connection will use TLS.

func (*RaftLayer) Accept

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

Accept is used to return connection which are dialed to be used with the Raft layer

func (*RaftLayer) Addr

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

Addr is used to return the address of the listener

func (*RaftLayer) Close

func (l *RaftLayer) Close() error

Close is used to stop listening for Raft connections

func (*RaftLayer) Dial

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

Dial is used to create a new outgoing connection

func (*RaftLayer) Handoff

func (l *RaftLayer) Handoff(c net.Conn) error

Handoff is used to hand off a connection to the RaftLayer. This allows it to be Accept()'ed

type Server

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

func NewServer

func NewServer(id, raftBind, environment string, peers []PeerInfo, bootstrap bool) *Server

func (*Server) FSM

func (s *Server) FSM() *fsm.FSM

func (*Server) InitRaft

func (s *Server) InitRaft() error

func (*Server) IsLeader

func (s *Server) IsLeader() bool

func (*Server) Watch

func (s *Server) Watch(stream pb.RaftMemberShip_WatchServer) error