Versions in this module Expand all Collapse all v0 v0.1.0 Jan 7, 2022 Changes in this version + var File_raft_rpc_proto protoreflect.FileDescriptor + var RaftRpc_ServiceDesc = grpc.ServiceDesc + func MapToAppendEntriesReq(from *AppendEntriesArguments) (to *core.AppendEntriesReq) + func MapToAppendEntriesResp(from *AppendEntriesResults) (to *core.AppendEntriesResp) + func MapToCmdReq(from *CmdRequest) (to *core.CmdReq) + func MapToCmdResp(from *CmdResponse) (to *core.CmdResp) + func MapToRequestVoteReq(from *RequestVoteArguments) (to *core.RequestVoteReq) + func MapToRequestVoteResp(from *RequestVoteResults) (to *core.RequestVoteResp) + func RegisterRaftRpcServer(s grpc.ServiceRegistrar, srv RaftRpcServer) + type AppendEntriesArguments struct + Entries []*Entry + LeaderCommit int64 + LeaderId string + PrevLogIndex int64 + PrevLogTerm int64 + Term int64 + func MapToAppendEntriesArguments(from *core.AppendEntriesReq) (to *AppendEntriesArguments) + func (*AppendEntriesArguments) Descriptor() ([]byte, []int) + func (*AppendEntriesArguments) ProtoMessage() + func (x *AppendEntriesArguments) GetEntries() []*Entry + func (x *AppendEntriesArguments) GetLeaderCommit() int64 + func (x *AppendEntriesArguments) GetLeaderId() string + func (x *AppendEntriesArguments) GetPrevLogIndex() int64 + func (x *AppendEntriesArguments) GetPrevLogTerm() int64 + func (x *AppendEntriesArguments) GetTerm() int64 + func (x *AppendEntriesArguments) ProtoReflect() protoreflect.Message + func (x *AppendEntriesArguments) Reset() + func (x *AppendEntriesArguments) String() string + type AppendEntriesResults struct + Success bool + Term int64 + func MapToAppendEntriesResults(from *core.AppendEntriesResp) (to *AppendEntriesResults) + func (*AppendEntriesResults) Descriptor() ([]byte, []int) + func (*AppendEntriesResults) ProtoMessage() + func (x *AppendEntriesResults) GetSuccess() bool + func (x *AppendEntriesResults) GetTerm() int64 + func (x *AppendEntriesResults) ProtoReflect() protoreflect.Message + func (x *AppendEntriesResults) Reset() + func (x *AppendEntriesResults) String() string + type Caller struct + func NewCaller(recv chan *mgr.Rpc, send chan *mgr.Rpc, mgr *mgr.RaftManager) (caller *Caller, done chan struct{}) + func (c *Caller) Run() + type CmdRequest struct + Cmd string + func MapToCmdRequest(from *core.CmdReq) (to *CmdRequest) + func (*CmdRequest) Descriptor() ([]byte, []int) + func (*CmdRequest) ProtoMessage() + func (x *CmdRequest) GetCmd() string + func (x *CmdRequest) ProtoReflect() protoreflect.Message + func (x *CmdRequest) Reset() + func (x *CmdRequest) String() string + type CmdResponse struct + Result string + Success bool + func MapToCmdResponse(from *core.CmdResp) (to *CmdResponse) + func (*CmdResponse) Descriptor() ([]byte, []int) + func (*CmdResponse) ProtoMessage() + func (x *CmdResponse) GetResult() string + func (x *CmdResponse) GetSuccess() bool + func (x *CmdResponse) ProtoReflect() protoreflect.Message + func (x *CmdResponse) Reset() + func (x *CmdResponse) String() string + type Entry struct + Cmd string + Idx int64 + Term int64 + func (*Entry) Descriptor() ([]byte, []int) + func (*Entry) ProtoMessage() + func (x *Entry) GetCmd() string + func (x *Entry) GetIdx() int64 + func (x *Entry) GetTerm() int64 + func (x *Entry) ProtoReflect() protoreflect.Message + func (x *Entry) Reset() + func (x *Entry) String() string + type RaftRpcClient interface + AppendEntries func(ctx context.Context, in *AppendEntriesArguments, opts ...grpc.CallOption) (*AppendEntriesResults, error) + ExecCmd func(ctx context.Context, in *CmdRequest, opts ...grpc.CallOption) (*CmdResponse, error) + RequestVote func(ctx context.Context, in *RequestVoteArguments, opts ...grpc.CallOption) (*RequestVoteResults, error) + func NewRaftRpcClient(cc grpc.ClientConnInterface) RaftRpcClient + type RaftRpcServer interface + AppendEntries func(context.Context, *AppendEntriesArguments) (*AppendEntriesResults, error) + ExecCmd func(context.Context, *CmdRequest) (*CmdResponse, error) + RequestVote func(context.Context, *RequestVoteArguments) (*RequestVoteResults, error) + type RaftServer struct + func NewServer(inputCh chan *mgr.Rpc, mgr *mgr.RaftManager) *RaftServer + func (s *RaftServer) AppendEntries(ctx context.Context, in *AppendEntriesArguments) (*AppendEntriesResults, error) + func (s *RaftServer) ExecCmd(ctx context.Context, in *CmdRequest) (*CmdResponse, error) + func (s *RaftServer) RequestVote(ctx context.Context, in *RequestVoteArguments) (*RequestVoteResults, error) + type RequestVoteArguments struct + CandidateId string + LastLogIndex int64 + LastLogTerm int64 + Term int64 + func MapToRequestVoteArguments(from *core.RequestVoteReq) (to *RequestVoteArguments) + func (*RequestVoteArguments) Descriptor() ([]byte, []int) + func (*RequestVoteArguments) ProtoMessage() + func (x *RequestVoteArguments) GetCandidateId() string + func (x *RequestVoteArguments) GetLastLogIndex() int64 + func (x *RequestVoteArguments) GetLastLogTerm() int64 + func (x *RequestVoteArguments) GetTerm() int64 + func (x *RequestVoteArguments) ProtoReflect() protoreflect.Message + func (x *RequestVoteArguments) Reset() + func (x *RequestVoteArguments) String() string + type RequestVoteResults struct + Term int64 + VoteGranted bool + func MapToRequestVoteResults(from *core.RequestVoteResp) (to *RequestVoteResults) + func (*RequestVoteResults) Descriptor() ([]byte, []int) + func (*RequestVoteResults) ProtoMessage() + func (x *RequestVoteResults) GetTerm() int64 + func (x *RequestVoteResults) GetVoteGranted() bool + func (x *RequestVoteResults) ProtoReflect() protoreflect.Message + func (x *RequestVoteResults) Reset() + func (x *RequestVoteResults) String() string + type UnimplementedRaftRpcServer struct + func (UnimplementedRaftRpcServer) AppendEntries(context.Context, *AppendEntriesArguments) (*AppendEntriesResults, error) + func (UnimplementedRaftRpcServer) ExecCmd(context.Context, *CmdRequest) (*CmdResponse, error) + func (UnimplementedRaftRpcServer) RequestVote(context.Context, *RequestVoteArguments) (*RequestVoteResults, error) + type UnsafeRaftRpcServer interface