pb

type AppendEntriesReq struct {
	Term         int32        `protobuf:"varint,1,opt,name=term" json:"term,omitempty"`
	LeaderId     int32        `protobuf:"varint,2,opt,name=leader_id,json=leaderId" json:"leader_id,omitempty"`
	PrevLogIndex int32        `protobuf:"varint,3,opt,name=prev_log_index,json=prevLogIndex" json:"prev_log_index,omitempty"`
	PrevLogTerm  int32        `protobuf:"varint,4,opt,name=prev_log_term,json=prevLogTerm" json:"prev_log_term,omitempty"`
	LogEntries   []*KVCommand `protobuf:"bytes,5,rep,name=log_entries,json=logEntries" json:"log_entries,omitempty"`
	LeaderCommit int32        `protobuf:"varint,6,opt,name=leader_commit,json=leaderCommit" json:"leader_commit,omitempty"`
}

type AppendEntriesRes struct {
	Term    int32 `protobuf:"varint,1,opt,name=term" json:"term,omitempty"`
	Success bool  `protobuf:"varint,2,opt,name=success" json:"success,omitempty"`
}

type CommandType int32

type GetReq struct {
	Session *Session `protobuf:"bytes,1,opt,name=session" json:"session,omitempty"`
	Key     string   `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"`
}

type GetRes struct {
	Status Status `protobuf:"varint,1,opt,name=status,enum=pb.Status" json:"status,omitempty"`
	Value  string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
}

type KVCommand struct {
	CmdType CommandType `protobuf:"varint,1,opt,name=cmd_type,json=cmdType,enum=pb.CommandType" json:"cmd_type,omitempty"`
	// Types that are valid to be assigned to Command:
	//	*KVCommand_GetCommand
	//	*KVCommand_PutCommand
	//	*KVCommand_Noop
	Command   isKVCommand_Command `protobuf_oneof:"command"`
	Term      int32               `protobuf:"varint,5,opt,name=term" json:"term,omitempty"`
	Index     int32               `protobuf:"varint,6,opt,name=index" json:"index,omitempty"`
	Timestamp int64               `protobuf:"varint,7,opt,name=timestamp" json:"timestamp,omitempty"`
}

type KVCommand_GetCommand struct {
	GetCommand *GetReq `protobuf:"bytes,2,opt,name=get_command,json=getCommand,oneof"`
}

type KVCommand_Noop struct {
	Noop []byte `protobuf:"bytes,4,opt,name=noop,proto3,oneof"`
}

type KVCommand_PutCommand struct {
	PutCommand *PutReq `protobuf:"bytes,3,opt,name=put_command,json=putCommand,oneof"`
}

type OpenSessionReq struct {
	Session *Session `protobuf:"bytes,1,opt,name=session" json:"session,omitempty"`
}

type OpenSessionRes struct {
	ClientId int64 `protobuf:"varint,1,opt,name=client_id,json=clientId" json:"client_id,omitempty"`
}

type PutReq struct {
	Session *Session `protobuf:"bytes,1,opt,name=session" json:"session,omitempty"`
	Key     string   `protobuf:"bytes,2,opt,name=key" json:"key,omitempty"`
	Value   string   `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"`
}

type PutRes struct {
	Status Status `protobuf:"varint,1,opt,name=status,enum=pb.Status" json:"status,omitempty"`
}

type RaftClient interface {
	RequestVote(ctx context.Context, in *RequestVoteReq, opts ...grpc.CallOption) (*RequestVoteRes, error)
	AppendEntries(ctx context.Context, in *AppendEntriesReq, opts ...grpc.CallOption) (*AppendEntriesRes, error)
}

type RaftKVClient interface {
	OpenSession(ctx context.Context, in *OpenSessionReq, opts ...grpc.CallOption) (*OpenSessionRes, error)
	Put(ctx context.Context, in *PutReq, opts ...grpc.CallOption) (*PutRes, error)
	Get(ctx context.Context, in *GetReq, opts ...grpc.CallOption) (*GetRes, error)
}

type RaftKVServer interface {
	OpenSession(context.Context, *OpenSessionReq) (*OpenSessionRes, error)
	Put(context.Context, *PutReq) (*PutRes, error)
	Get(context.Context, *GetReq) (*GetRes, error)
}

type RaftRole int32

type RaftServer interface {
	RequestVote(context.Context, *RequestVoteReq) (*RequestVoteRes, error)
	AppendEntries(context.Context, *AppendEntriesReq) (*AppendEntriesRes, error)
}

type RequestVoteReq struct {
	Term         int32 `protobuf:"varint,1,opt,name=term" json:"term,omitempty"`
	CandidateId  int32 `protobuf:"varint,2,opt,name=candidate_id,json=candidateId" json:"candidate_id,omitempty"`
	LastLogIndex int32 `protobuf:"varint,3,opt,name=last_log_index,json=lastLogIndex" json:"last_log_index,omitempty"`
	LastLogTerm  int32 `protobuf:"varint,4,opt,name=last_log_term,json=lastLogTerm" json:"last_log_term,omitempty"`
}

type RequestVoteRes struct {
	Term        int32 `protobuf:"varint,1,opt,name=term" json:"term,omitempty"`
	VoteGranted bool  `protobuf:"varint,2,opt,name=vote_granted,json=voteGranted" json:"vote_granted,omitempty"`
}

type Session struct {
	ClientId int64  `protobuf:"varint,1,opt,name=client_id,json=clientId" json:"client_id,omitempty"`
	Sn       int64  `protobuf:"varint,2,opt,name=sn" json:"sn,omitempty"`
	LogId    string `protobuf:"bytes,3,opt,name=log_id,json=logId" json:"log_id,omitempty"`
}

type Status int32