raft

package

v0.2.0 Latest Latest Go to latest Published: Feb 21, 2020 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ChangeLeaderNotification struct {
	CurrentLeaderAddress string
	IsLeader             bool
	LeaderElected        bool
}

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

func NewRaft(tcpListener net.Listener, configuration config.ClusterConfiguration, state raft.FSM, logger hclog.Logger) (*Raft, error)

func (r *Raft) BootstrapCluster() error

func (r *Raft) GracefulShutdown() error

func (r *Raft) Leader() raft.ServerAddress

func (r *Raft) LeaderNotificationsCh() <-chan ChangeLeaderNotification

func (r *Raft) LocalID() string

func (r *Raft) Servers() ([]raft.Server, error)

func (r *Raft) SyncApply(command []byte) (interface{}, error)

type StreamLayer struct {
	net.Listener
}

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