rpc

type AppendEntiresReq struct {
	LeaderTerm   uint64
	LeaderId     string
	PrevLogIndex uint64
	PrevLogTerm  uint64
	Entries      []string
	LeaderCommit uint64
}

type AppendEntiresResp struct {
	Term    uint64
	Success bool
}

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

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

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

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

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

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

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

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

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

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

type RPCClientProvider interface {
	GetRPCClient(remoteNodeIP string, remoteNodePort string) RPClient
}

type RPCServer interface {
	Start() error
	Stop() error
	RegisterRaftHandle(pRaftHandler RaftServiceHandler) error
}

type RPCServerProvider interface {
	GetRPCServer(localNodePort string) RPCServer
}

type RPClient interface {
	Start() error
	Stop() error
	AppendEntires(ctx context.Context, req *AppendEntiresReq) (*AppendEntiresResp, error)
	RequestVote(ctx context.Context, req *RequestVoteReq) (*RequestVoteResp, error)
}

type RaftServiceHandler interface {
	AppendEntires(ctx context.Context, req *AppendEntiresReq) (*AppendEntiresResp, error)
	RequestVote(ctx context.Context, req *RequestVoteReq) (*RequestVoteResp, error)
}

type RequestVoteReq struct {
	Term         uint64
	CandidateId  string
	LastLogIndex uint64
	LastLogTerm  uint64
}

type RequestVoteResp struct {
	Term        uint64
	VoteGranted bool
}