naive_raft

README

Naive_Raft

"Too simple! Sometimes naive!"

"Re-election will still have to follow the (Hong Kong) Basic Law! Of course, our decision is very important too."

-- the elder □-□

naive go implementation of raft consensus algorithm raft

LICENSE

Copyright © 2018 by Aljun

Under Apache license : http://www.apache.org/licenses/

Documentation

Index

• Constants
• Variables
• type Log
• type Node
  • func NewNode(name string, id int, host string, port int, conf string) *Node
  • func (node *Node) AppendEntriesRPC(ctx context.Context, in *pb.AppendEntriesReq) (*pb.AppendEntriesResp, error)
  • func (node *Node) AppendEntry() error
  • func (node *Node) Canvass() error
  • func (node *Node) CanvassRPC(ctx context.Context, in *pb.CanvassReq) (*pb.CanvassResp, error)
  • func (node *Node) Run()
  • func (node *Node) SetLogRPC(ctx context.Context, in *pb.LogReq) (*pb.LogResp, error)
• type NodeConf

Constants

const (
	FOLLOWER = iota
	CANDIDATE
	LEADER
)

const (
	INTERVAL = 5 //heartbeat INTERVAL
)

const ZERO_REPLACE_NUM = 10000000

fix golang pointer convert 0 error

Variables

var (
	StateErr       = errors.New("wrone state")
	NotCandiateErr = errors.New("not candidate")
	NotLeaderErr   = errors.New("not leader")
	SetLogErr      = errors.New("can't set log")
	NoLogErr       = errors.New("node don't have logs")
)

Types

type Log

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

type Node

type Node struct {
	Host string
	Port int
	// contains filtered or unexported fields
}

func NewNode

func NewNode(name string, id int, host string, port int, conf string) *Node

func (*Node) AppendEntriesRPC

func (node *Node) AppendEntriesRPC(ctx context.Context, in *pb.AppendEntriesReq) (*pb.AppendEntriesResp, error)

func (*Node) AppendEntry

func (node *Node) AppendEntry() error

func (*Node) Canvass

func (node *Node) Canvass() error

func (*Node) CanvassRPC

func (node *Node) CanvassRPC(ctx context.Context, in *pb.CanvassReq) (*pb.CanvassResp, error)

func (*Node) Run

func (node *Node) Run()

func (*Node) SetLogRPC

func (node *Node) SetLogRPC(ctx context.Context, in *pb.LogReq) (*pb.LogResp, error)

type NodeConf

type NodeConf struct {
	Name string `json:"name"`
	ID   int    `json:"id"`
	Host string `json:"host"`
	Port int    `json:"port"`
}