agent

Documentation

Index

• Constants
• Variables
• func AppendLog(logEntry *LogEntry) error
• func BroadcastHeartBeat() error
• func Init(id int32, ge []string, ps PersistentStore)
• func IsLeader() bool
• func LeaderID() int32
• func LockHolderID() int32
• func PendingApplyLogExist() bool
• func StartRPCServer(port int)
• type LogEntry
• type PersistentStore
• type RaftServerImpl
  • func (rsi *RaftServerImpl) AppendEntries(ctx context.Context, req *sfrpc.AppendEntriesRequest) (*sfrpc.AppendEntriesReply, error)
  • func (rsi *RaftServerImpl) RequestVote(ctx context.Context, req *sfrpc.RequestVoteRequest) (*sfrpc.RequestVoteReply, error)
• type Role
• type StateMachine
• type VolatileLeaderState
• type VolatileState

Constants

const (
	Follower Role = iota
	Candidate
	Leader

	InvalidLockHolderID int32 = -1
	InvalidAgentID      int32 = -1
	NoopAgentID         int32 = -2
)

Variables

var (
	DemotedToFollower error
	LogMismatch       error
)

Functions

func AppendLog

func AppendLog(logEntry *LogEntry) error

func BroadcastHeartBeat

func BroadcastHeartBeat() error

func Init

func Init(id int32, ge []string, ps PersistentStore)

func IsLeader

func IsLeader() bool

func LeaderID

func LeaderID() int32

func LockHolderID

func LockHolderID() int32

func PendingApplyLogExist

func PendingApplyLogExist() bool

func StartRPCServer

func StartRPCServer(port int)

Types

type LogEntry

type LogEntry struct {
	Term         int64
	LockHolderID int32
	Reserved     int32
}

type PersistentStore

type PersistentStore interface {
	CurrentTerm() int64
	PutCurrentTerm(int64)
	VotedFor() int32
	PutVotedFor(int32)
	LogEntry(int64) *LogEntry
	LogSize() int64
	AppendLog(*LogEntry)
	CutOffLogTail(int64)
}

type RaftServerImpl

type RaftServerImpl struct {
	sfrpc.UnimplementedRaftServer
}

func (*RaftServerImpl) AppendEntries

func (rsi *RaftServerImpl) AppendEntries(ctx context.Context, req *sfrpc.AppendEntriesRequest) (*sfrpc.AppendEntriesReply, error)

func (*RaftServerImpl) RequestVote

func (rsi *RaftServerImpl) RequestVote(ctx context.Context, req *sfrpc.RequestVoteRequest) (*sfrpc.RequestVoteReply, error)

type Role

type Role int32

type StateMachine

type StateMachine struct {
	LockHolderID int32
}

type VolatileLeaderState

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

type VolatileState

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