membership

package

v0.0.0-...-435ba0e Latest Latest Go to latest Published: Feb 16, 2023 License: MIT Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/youngbupark/raft-membership

Links

Open Source Insights

Documentation ¶

Index ¶

type PeerInfo
type RaftLayer
- func NewRaftLayer(src, addr net.Addr, tlsWrap tlsutil.Wrapper, ...) *RaftLayer
type Server
- func NewServer(id, raftBind, environment string, peers []PeerInfo, bootstrap bool) *Server

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
fsm

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL