graft

README

graft

A RAFT election implementation in Go and grpc.

Documentation

Index

• Constants
• type Logger
  • func (*Logger) Fatal(args ...interface{})
  • func (*Logger) Fatalf(format string, args ...interface{})
  • func (*Logger) Fatalln(args ...interface{})
  • func (*Logger) Print(args ...interface{})
  • func (*Logger) Printf(format string, args ...interface{})
  • func (*Logger) Println(args ...interface{})
• type Raft
  • func New(peers []string, me string, port int, chanState chan bool) (*Raft, error)
  • func (rf *Raft) GetState() (uint64, bool, int)
  • func (rf *Raft) IsLeader() bool
  • func (rf *Raft) SendHeartbeat(context context.Context, hreqt *protocol.HeartbeatRequest) (repe *protocol.Response, err error)
  • func (rf *Raft) SendVoteRequest(context context.Context, vreqt *protocol.VoteRequest) (vrepe *protocol.VoteResponse, err error)
  • func (rf *Raft) Stop()

Constants

const (
	// LEADER raft
	LEADER = iota
	// CANDIDATE raft
	CANDIDATE
	// FLLOWER raft
	FLLOWER
	//CLOSED  closed
	CLOSED
	//HBINTERVAL 50 ms
	HBINTERVAL = 50 * time.Millisecond
)

Types

type Logger

type Logger struct {
}

Logger mock grpc logger

func (*Logger) Fatal

func (*Logger) Fatal(args ...interface{})

Fatal mock grpc

func (*Logger) Fatalf

func (*Logger) Fatalf(format string, args ...interface{})

Fatalf mock grpc

func (*Logger) Fatalln

func (*Logger) Fatalln(args ...interface{})

Fatalln mock grpc

func (*Logger) Print

func (*Logger) Print(args ...interface{})

Print mock grpc

func (*Logger) Printf

func (*Logger) Printf(format string, args ...interface{})

Printf mock grpc

func (*Logger) Println

func (*Logger) Println(args ...interface{})

Println mock grpc

type Raft

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

Raft raft peer

func New

func New(peers []string, me string, port int, chanState chan bool) (*Raft, error)

New return *Raft

func (*Raft) GetState

func (rf *Raft) GetState() (uint64, bool, int)

GetState return currentTerm and whether this peer is leader

func (*Raft) IsLeader

func (rf *Raft) IsLeader() bool

IsLeader is leader

func (*Raft) SendHeartbeat

func (rf *Raft) SendHeartbeat(context context.Context, hreqt *protocol.HeartbeatRequest) (repe *protocol.Response, err error)

SendHeartbeat rpc handler

func (*Raft) SendVoteRequest

func (rf *Raft) SendVoteRequest(context context.Context, vreqt *protocol.VoteRequest) (vrepe *protocol.VoteResponse, err error)

SendVoteRequest rpc handler

func (*Raft) Stop

func (rf *Raft) Stop()

Stop ...