raft

type AppendEntriesReply struct {
	Term      int32     `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
	Success   bool      `protobuf:"varint,2,opt,name=Success,proto3" json:"Success,omitempty"`
	NextIndex int32     `protobuf:"varint,3,opt,name=NextIndex,proto3" json:"NextIndex,omitempty"`
	Base      *RaftBase `protobuf:"bytes,4,opt,name=Base,proto3" json:"Base,omitempty"`
	// contains filtered or unexported fields
}

type AppendEntriesRequest struct {
	Term         int32       `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
	LeaderName   string      `protobuf:"bytes,2,opt,name=LeaderName,proto3" json:"LeaderName,omitempty"`
	PrevLogIndex int32       `protobuf:"varint,3,opt,name=PrevLogIndex,proto3" json:"PrevLogIndex,omitempty"`
	PrevLogTerm  int32       `protobuf:"varint,4,opt,name=PrevLogTerm,proto3" json:"PrevLogTerm,omitempty"`
	Entries      []*LogEntry `protobuf:"bytes,5,rep,name=Entries,proto3" json:"Entries,omitempty"`
	LeaderCommit int32       `protobuf:"varint,6,opt,name=LeaderCommit,proto3" json:"LeaderCommit,omitempty"`
	Base         *RaftBase   `protobuf:"bytes,7,opt,name=Base,proto3" json:"Base,omitempty"`
	// contains filtered or unexported fields
}

type ApplyMsg struct {
	CommandValid bool
	CommandIndex int32
	Command      []byte
}

type InstallSnapshotReply struct {
	Term int32     `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
	Base *RaftBase `protobuf:"bytes,2,opt,name=Base,proto3" json:"Base,omitempty"`
	// contains filtered or unexported fields
}

type InstallSnapshotRequest struct {
	Term              int32     `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
	LeaderName        string    `protobuf:"bytes,2,opt,name=LeaderName,proto3" json:"LeaderName,omitempty"`
	LastIncludedIndex int32     `protobuf:"varint,3,opt,name=LastIncludedIndex,proto3" json:"LastIncludedIndex,omitempty"`
	LastIncludedTerm  int32     `protobuf:"varint,4,opt,name=LastIncludedTerm,proto3" json:"LastIncludedTerm,omitempty"`
	Data              [][]byte  `protobuf:"bytes,5,rep,name=Data,proto3" json:"Data,omitempty"`
	Base              *RaftBase `protobuf:"bytes,6,opt,name=Base,proto3" json:"Base,omitempty"`
	// contains filtered or unexported fields
}

type LogEntry struct {
	Term    int32  `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
	Index   int32  `protobuf:"varint,2,opt,name=Index,proto3" json:"Index,omitempty"`
	Command []byte `protobuf:"bytes,3,opt,name=Command,proto3" json:"Command,omitempty"`
	// contains filtered or unexported fields
}

type Option func(*Options)

type Options struct {
	NativeName        string
	Address           string        `yaml:"address"`
	CodecType         string        `yaml:"codec_type"`
	ApplyMsgLength    int           `yaml:"apply_msg_length"`
	SnapshotPath      string        `yaml:"snapshot_path"`
	MaxLogEntryLength int           `yaml:"max_log_entry_length"`
	ElectionTimeout   time.Duration `yaml:"election_timeout"`
	HeartBeatTimeout  time.Duration `yaml:"heartbeat_timeout"`
	ApplyInterval     time.Duration `yaml:"apply_interval"`
	RPCTimeout        time.Duration `yaml:"rpc_timeout"`
	RaftPeers         map[string]string
	InfoCh            chan *RaftInfo
}

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

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

type RaftBase struct {
	To   string `protobuf:"bytes,1,opt,name=To,proto3" json:"To,omitempty"`
	From string `protobuf:"bytes,2,opt,name=From,proto3" json:"From,omitempty"`
	// contains filtered or unexported fields
}

type RaftClient interface {
	InstallSnapshot(ctx context.Context, in *InstallSnapshotRequest, opts ...grpc.CallOption) (*InstallSnapshotReply, error)
	AppendEntries(ctx context.Context, in *AppendEntriesRequest, opts ...grpc.CallOption) (*AppendEntriesReply, error)
	Vote(ctx context.Context, in *VoteRequest, opts ...grpc.CallOption) (*VoteReply, error)
}

type RaftInfo struct {
	Name   string
	Leader string
	Role   Role
	Term   int32
}

type RaftServer interface {
	InstallSnapshot(context.Context, *InstallSnapshotRequest) (*InstallSnapshotReply, error)
	AppendEntries(context.Context, *AppendEntriesRequest) (*AppendEntriesReply, error)
	Vote(context.Context, *VoteRequest) (*VoteReply, error)
}

type RaftState struct {
	Term              int32
	VoteFor           string
	CommitIndex       int32
	LastSnapshotIndex int32
	LastSnapshotTerm  int32
	LogEntries        []*LogEntry
}

type Role string

type Server interface {
	Put([]byte) bool
	CommitChannel() <-chan []byte
	Run()
	Kill()
}

type UnimplementedRaftServer struct {
}

type VoteReply struct {
	Term        int32     `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
	VoteGranted bool      `protobuf:"varint,2,opt,name=VoteGranted,proto3" json:"VoteGranted,omitempty"`
	Base        *RaftBase `protobuf:"bytes,3,opt,name=Base,proto3" json:"Base,omitempty"`
	// contains filtered or unexported fields
}

type VoteRequest struct {
	Term          int32     `protobuf:"varint,1,opt,name=Term,proto3" json:"Term,omitempty"`
	CandidateName string    `protobuf:"bytes,2,opt,name=CandidateName,proto3" json:"CandidateName,omitempty"`
	LastLogIndex  int32     `protobuf:"varint,3,opt,name=LastLogIndex,proto3" json:"LastLogIndex,omitempty"`
	LastLogTerm   int32     `protobuf:"varint,4,opt,name=LastLogTerm,proto3" json:"LastLogTerm,omitempty"`
	Base          *RaftBase `protobuf:"bytes,5,opt,name=Base,proto3" json:"Base,omitempty"`
	// contains filtered or unexported fields
}