go_raft_grpc

package module

v0.0.0-...-1c1f771 Latest Latest Go to latest Published: Dec 14, 2023 License: MIT Imports: 9 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

go-raft-grpc is based on go-raft[https://github.com/goraft/raft/], using grpc other than http as the transporter, nothing else changed.

This section is empty.

This section is empty.

This section is empty.

type RaftServer struct {
	protobuf.UnimplementedRaftServerServer
	// contains filtered or unexported fields
}

func NewRaftServer(peers []string, httpAddr string, dataDir string, pulseSeconds int) *RaftServer

func StartRaftServer(ip, peerIps, port, dataDir string) *RaftServer

StartRaftServer start a raft server

func (s *RaftServer) DeathNotify()

DeathNotify If a node is about to die, notify other nodes to elect a new leader as soon as possible before the node dies

func (s *RaftServer) IsLeader() bool

IsLeader i am the leader?

func (s *RaftServer) Join(peers []string) error

Join joins an existing cluster.

func (s *RaftServer) Leader() string

Leader cluster leader

func (s *RaftServer) Nodes() (members []string)

Nodes all nodes

func (s *RaftServer) Peers() (members []string)

Peers my partner nodes