Documentation ¶
Overview ¶
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Index ¶
- type MockClient
- func (m *MockClient) Append(ctx context.Context, request *protocol.AppendRequest, member protocol.MemberID) (*protocol.AppendResponse, error)
- func (m *MockClient) Command(ctx context.Context, request *protocol.CommandRequest, ...) (<-chan *protocol.CommandStreamResponse, error)
- func (m *MockClient) Configure(ctx context.Context, request *protocol.ConfigureRequest, ...) (*protocol.ConfigureResponse, error)
- func (m *MockClient) EXPECT() *MockClientMockRecorder
- func (m *MockClient) Install(ctx context.Context, member protocol.MemberID) (chan<- *protocol.InstallRequest, <-chan *protocol.InstallStreamResponse, error)
- func (m *MockClient) Join(ctx context.Context, request *protocol.JoinRequest, member protocol.MemberID) (*protocol.JoinResponse, error)
- func (m *MockClient) Leave(ctx context.Context, request *protocol.LeaveRequest, member protocol.MemberID) (*protocol.LeaveResponse, error)
- func (m *MockClient) Poll(ctx context.Context, request *protocol.PollRequest, member protocol.MemberID) (*protocol.PollResponse, error)
- func (m *MockClient) Query(ctx context.Context, request *protocol.QueryRequest, member protocol.MemberID) (<-chan *protocol.QueryStreamResponse, error)
- func (m *MockClient) Reconfigure(ctx context.Context, request *protocol.ReconfigureRequest, ...) (*protocol.ReconfigureResponse, error)
- func (m *MockClient) Transfer(ctx context.Context, request *protocol.TransferRequest, ...) (*protocol.TransferResponse, error)
- func (m *MockClient) Vote(ctx context.Context, request *protocol.VoteRequest, member protocol.MemberID) (*protocol.VoteResponse, error)
- type MockClientMockRecorder
- func (mr *MockClientMockRecorder) Append(ctx, request, member interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Command(ctx, request, member interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Configure(ctx, request, member interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Install(ctx, member interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Join(ctx, request, member interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Leave(ctx, request, member interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Poll(ctx, request, member interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Query(ctx, request, member interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Reconfigure(ctx, request, member interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Transfer(ctx, request, member interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) Vote(ctx, request, member interface{}) *gomock.Call
- type MockCluster
- func (m *MockCluster) EXPECT() *MockClusterMockRecorder
- func (m *MockCluster) GetClient(memberID protocol.MemberID) (protocol.RaftServiceClient, error)
- func (m *MockCluster) GetMember(memberID protocol.MemberID) *protocol.Member
- func (m *MockCluster) Member() protocol.MemberID
- func (m *MockCluster) Members() []protocol.MemberID
- type MockClusterMockRecorder
- type MockRaft
- func (m *MockRaft) Append(ctx context.Context, request *protocol.AppendRequest) (*protocol.AppendResponse, error)
- func (m *MockRaft) Close() error
- func (m *MockRaft) Command(request *protocol.CommandRequest, ch chan<- *protocol.CommandStreamResponse) error
- func (m *MockRaft) Commit(index protocol.Index) protocol.Index
- func (m *MockRaft) CommitIndex() protocol.Index
- func (m *MockRaft) Config() *config.ProtocolConfig
- func (m *MockRaft) Configure(ctx context.Context, request *protocol.ConfigureRequest) (*protocol.ConfigureResponse, error)
- func (m *MockRaft) EXPECT() *MockRaftMockRecorder
- func (m *MockRaft) GetMember(memberID protocol.MemberID) *protocol.Member
- func (m *MockRaft) Init()
- func (m *MockRaft) Install(ch <-chan *protocol.InstallStreamRequest) (*protocol.InstallResponse, error)
- func (m *MockRaft) Join(ctx context.Context, request *protocol.JoinRequest) (*protocol.JoinResponse, error)
- func (m *MockRaft) LastVotedFor() *protocol.MemberID
- func (m *MockRaft) Leader() *protocol.MemberID
- func (m *MockRaft) Leave(ctx context.Context, request *protocol.LeaveRequest) (*protocol.LeaveResponse, error)
- func (m *MockRaft) Member() protocol.MemberID
- func (m *MockRaft) Members() []protocol.MemberID
- func (m *MockRaft) Poll(ctx context.Context, request *protocol.PollRequest) (*protocol.PollResponse, error)
- func (m *MockRaft) Protocol() protocol.Client
- func (m *MockRaft) Query(request *protocol.QueryRequest, ch chan<- *protocol.QueryStreamResponse) error
- func (m *MockRaft) ReadLock()
- func (m *MockRaft) ReadUnlock()
- func (m *MockRaft) Reconfigure(ctx context.Context, request *protocol.ReconfigureRequest) (*protocol.ReconfigureResponse, error)
- func (m *MockRaft) Role() protocol.RoleType
- func (m *MockRaft) SetCommitIndex(index protocol.Index)
- func (m *MockRaft) SetLastVotedFor(memberID protocol.MemberID) error
- func (m *MockRaft) SetLeader(leader *protocol.MemberID) error
- func (m *MockRaft) SetRole(role protocol.Role)
- func (m *MockRaft) SetTerm(term protocol.Term) error
- func (m *MockRaft) Status() protocol.Status
- func (m *MockRaft) Term() protocol.Term
- func (m *MockRaft) Transfer(ctx context.Context, request *protocol.TransferRequest) (*protocol.TransferResponse, error)
- func (m *MockRaft) Vote(ctx context.Context, request *protocol.VoteRequest) (*protocol.VoteResponse, error)
- func (m *MockRaft) WatchRole(arg0 func(protocol.RoleType))
- func (m *MockRaft) WatchStatus(arg0 func(protocol.Status))
- func (m *MockRaft) WriteLock()
- func (m *MockRaft) WriteUnlock()
- type MockRaftMockRecorder
- func (mr *MockRaftMockRecorder) Append(ctx, request interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) Close() *gomock.Call
- func (mr *MockRaftMockRecorder) Command(request, ch interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) Commit(index interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) CommitIndex() *gomock.Call
- func (mr *MockRaftMockRecorder) Config() *gomock.Call
- func (mr *MockRaftMockRecorder) Configure(ctx, request interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) GetMember(memberID interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) Init() *gomock.Call
- func (mr *MockRaftMockRecorder) Install(ch interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) Join(ctx, request interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) LastVotedFor() *gomock.Call
- func (mr *MockRaftMockRecorder) Leader() *gomock.Call
- func (mr *MockRaftMockRecorder) Leave(ctx, request interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) Member() *gomock.Call
- func (mr *MockRaftMockRecorder) Members() *gomock.Call
- func (mr *MockRaftMockRecorder) Poll(ctx, request interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) Protocol() *gomock.Call
- func (mr *MockRaftMockRecorder) Query(request, ch interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) ReadLock() *gomock.Call
- func (mr *MockRaftMockRecorder) ReadUnlock() *gomock.Call
- func (mr *MockRaftMockRecorder) Reconfigure(ctx, request interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) Role() *gomock.Call
- func (mr *MockRaftMockRecorder) SetCommitIndex(index interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) SetLastVotedFor(memberID interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) SetLeader(leader interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) SetRole(role interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) SetTerm(term interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) Status() *gomock.Call
- func (mr *MockRaftMockRecorder) Term() *gomock.Call
- func (mr *MockRaftMockRecorder) Transfer(ctx, request interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) Vote(ctx, request interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) WatchRole(arg0 interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) WatchStatus(arg0 interface{}) *gomock.Call
- func (mr *MockRaftMockRecorder) WriteLock() *gomock.Call
- func (mr *MockRaftMockRecorder) WriteUnlock() *gomock.Call
- type MockRole
- func (m *MockRole) Append(ctx context.Context, request *protocol.AppendRequest) (*protocol.AppendResponse, error)
- func (m *MockRole) Command(request *protocol.CommandRequest, ch chan<- *protocol.CommandStreamResponse) error
- func (m *MockRole) Configure(ctx context.Context, request *protocol.ConfigureRequest) (*protocol.ConfigureResponse, error)
- func (m *MockRole) EXPECT() *MockRoleMockRecorder
- func (m *MockRole) Install(ch <-chan *protocol.InstallStreamRequest) (*protocol.InstallResponse, error)
- func (m *MockRole) Join(ctx context.Context, request *protocol.JoinRequest) (*protocol.JoinResponse, error)
- func (m *MockRole) Leave(ctx context.Context, request *protocol.LeaveRequest) (*protocol.LeaveResponse, error)
- func (m *MockRole) Poll(ctx context.Context, request *protocol.PollRequest) (*protocol.PollResponse, error)
- func (m *MockRole) Query(request *protocol.QueryRequest, ch chan<- *protocol.QueryStreamResponse) error
- func (m *MockRole) Reconfigure(ctx context.Context, request *protocol.ReconfigureRequest) (*protocol.ReconfigureResponse, error)
- func (m *MockRole) Start() error
- func (m *MockRole) Stop() error
- func (m *MockRole) Transfer(ctx context.Context, request *protocol.TransferRequest) (*protocol.TransferResponse, error)
- func (m *MockRole) Type() protocol.RoleType
- func (m *MockRole) Vote(ctx context.Context, request *protocol.VoteRequest) (*protocol.VoteResponse, error)
- type MockRoleMockRecorder
- func (mr *MockRoleMockRecorder) Append(ctx, request interface{}) *gomock.Call
- func (mr *MockRoleMockRecorder) Command(request, ch interface{}) *gomock.Call
- func (mr *MockRoleMockRecorder) Configure(ctx, request interface{}) *gomock.Call
- func (mr *MockRoleMockRecorder) Install(ch interface{}) *gomock.Call
- func (mr *MockRoleMockRecorder) Join(ctx, request interface{}) *gomock.Call
- func (mr *MockRoleMockRecorder) Leave(ctx, request interface{}) *gomock.Call
- func (mr *MockRoleMockRecorder) Poll(ctx, request interface{}) *gomock.Call
- func (mr *MockRoleMockRecorder) Query(request, ch interface{}) *gomock.Call
- func (mr *MockRoleMockRecorder) Reconfigure(ctx, request interface{}) *gomock.Call
- func (mr *MockRoleMockRecorder) Start() *gomock.Call
- func (mr *MockRoleMockRecorder) Stop() *gomock.Call
- func (mr *MockRoleMockRecorder) Transfer(ctx, request interface{}) *gomock.Call
- func (mr *MockRoleMockRecorder) Type() *gomock.Call
- func (mr *MockRoleMockRecorder) Vote(ctx, request interface{}) *gomock.Call
- type MockServer
- func (m *MockServer) Append(ctx context.Context, request *protocol.AppendRequest) (*protocol.AppendResponse, error)
- func (m *MockServer) Command(request *protocol.CommandRequest, ch chan<- *protocol.CommandStreamResponse) error
- func (m *MockServer) Configure(ctx context.Context, request *protocol.ConfigureRequest) (*protocol.ConfigureResponse, error)
- func (m *MockServer) EXPECT() *MockServerMockRecorder
- func (m *MockServer) Install(ch <-chan *protocol.InstallStreamRequest) (*protocol.InstallResponse, error)
- func (m *MockServer) Join(ctx context.Context, request *protocol.JoinRequest) (*protocol.JoinResponse, error)
- func (m *MockServer) Leave(ctx context.Context, request *protocol.LeaveRequest) (*protocol.LeaveResponse, error)
- func (m *MockServer) Poll(ctx context.Context, request *protocol.PollRequest) (*protocol.PollResponse, error)
- func (m *MockServer) Query(request *protocol.QueryRequest, ch chan<- *protocol.QueryStreamResponse) error
- func (m *MockServer) Reconfigure(ctx context.Context, request *protocol.ReconfigureRequest) (*protocol.ReconfigureResponse, error)
- func (m *MockServer) Transfer(ctx context.Context, request *protocol.TransferRequest) (*protocol.TransferResponse, error)
- func (m *MockServer) Vote(ctx context.Context, request *protocol.VoteRequest) (*protocol.VoteResponse, error)
- type MockServerMockRecorder
- func (mr *MockServerMockRecorder) Append(ctx, request interface{}) *gomock.Call
- func (mr *MockServerMockRecorder) Command(request, ch interface{}) *gomock.Call
- func (mr *MockServerMockRecorder) Configure(ctx, request interface{}) *gomock.Call
- func (mr *MockServerMockRecorder) Install(ch interface{}) *gomock.Call
- func (mr *MockServerMockRecorder) Join(ctx, request interface{}) *gomock.Call
- func (mr *MockServerMockRecorder) Leave(ctx, request interface{}) *gomock.Call
- func (mr *MockServerMockRecorder) Poll(ctx, request interface{}) *gomock.Call
- func (mr *MockServerMockRecorder) Query(request, ch interface{}) *gomock.Call
- func (mr *MockServerMockRecorder) Reconfigure(ctx, request interface{}) *gomock.Call
- func (mr *MockServerMockRecorder) Transfer(ctx, request interface{}) *gomock.Call
- func (mr *MockServerMockRecorder) Vote(ctx, request interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockClient ¶
type MockClient struct {
// contains filtered or unexported fields
}
MockClient is a mock of Client interface
func NewMockClient ¶
func NewMockClient(ctrl *gomock.Controller) *MockClient
NewMockClient creates a new mock instance
func (*MockClient) Append ¶
func (m *MockClient) Append(ctx context.Context, request *protocol.AppendRequest, member protocol.MemberID) (*protocol.AppendResponse, error)
Append mocks base method
func (*MockClient) Command ¶
func (m *MockClient) Command(ctx context.Context, request *protocol.CommandRequest, member protocol.MemberID) (<-chan *protocol.CommandStreamResponse, error)
Command mocks base method
func (*MockClient) Configure ¶
func (m *MockClient) Configure(ctx context.Context, request *protocol.ConfigureRequest, member protocol.MemberID) (*protocol.ConfigureResponse, error)
Configure mocks base method
func (*MockClient) EXPECT ¶
func (m *MockClient) EXPECT() *MockClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockClient) Install ¶
func (m *MockClient) Install(ctx context.Context, member protocol.MemberID) (chan<- *protocol.InstallRequest, <-chan *protocol.InstallStreamResponse, error)
Install mocks base method
func (*MockClient) Join ¶
func (m *MockClient) Join(ctx context.Context, request *protocol.JoinRequest, member protocol.MemberID) (*protocol.JoinResponse, error)
Join mocks base method
func (*MockClient) Leave ¶
func (m *MockClient) Leave(ctx context.Context, request *protocol.LeaveRequest, member protocol.MemberID) (*protocol.LeaveResponse, error)
Leave mocks base method
func (*MockClient) Poll ¶
func (m *MockClient) Poll(ctx context.Context, request *protocol.PollRequest, member protocol.MemberID) (*protocol.PollResponse, error)
Poll mocks base method
func (*MockClient) Query ¶
func (m *MockClient) Query(ctx context.Context, request *protocol.QueryRequest, member protocol.MemberID) (<-chan *protocol.QueryStreamResponse, error)
Query mocks base method
func (*MockClient) Reconfigure ¶
func (m *MockClient) Reconfigure(ctx context.Context, request *protocol.ReconfigureRequest, member protocol.MemberID) (*protocol.ReconfigureResponse, error)
Reconfigure mocks base method
func (*MockClient) Transfer ¶
func (m *MockClient) Transfer(ctx context.Context, request *protocol.TransferRequest, member protocol.MemberID) (*protocol.TransferResponse, error)
Transfer mocks base method
func (*MockClient) Vote ¶
func (m *MockClient) Vote(ctx context.Context, request *protocol.VoteRequest, member protocol.MemberID) (*protocol.VoteResponse, error)
Vote mocks base method
type MockClientMockRecorder ¶
type MockClientMockRecorder struct {
// contains filtered or unexported fields
}
MockClientMockRecorder is the mock recorder for MockClient
func (*MockClientMockRecorder) Append ¶
func (mr *MockClientMockRecorder) Append(ctx, request, member interface{}) *gomock.Call
Append indicates an expected call of Append
func (*MockClientMockRecorder) Command ¶
func (mr *MockClientMockRecorder) Command(ctx, request, member interface{}) *gomock.Call
Command indicates an expected call of Command
func (*MockClientMockRecorder) Configure ¶
func (mr *MockClientMockRecorder) Configure(ctx, request, member interface{}) *gomock.Call
Configure indicates an expected call of Configure
func (*MockClientMockRecorder) Install ¶
func (mr *MockClientMockRecorder) Install(ctx, member interface{}) *gomock.Call
Install indicates an expected call of Install
func (*MockClientMockRecorder) Join ¶
func (mr *MockClientMockRecorder) Join(ctx, request, member interface{}) *gomock.Call
Join indicates an expected call of Join
func (*MockClientMockRecorder) Leave ¶
func (mr *MockClientMockRecorder) Leave(ctx, request, member interface{}) *gomock.Call
Leave indicates an expected call of Leave
func (*MockClientMockRecorder) Poll ¶
func (mr *MockClientMockRecorder) Poll(ctx, request, member interface{}) *gomock.Call
Poll indicates an expected call of Poll
func (*MockClientMockRecorder) Query ¶
func (mr *MockClientMockRecorder) Query(ctx, request, member interface{}) *gomock.Call
Query indicates an expected call of Query
func (*MockClientMockRecorder) Reconfigure ¶
func (mr *MockClientMockRecorder) Reconfigure(ctx, request, member interface{}) *gomock.Call
Reconfigure indicates an expected call of Reconfigure
func (*MockClientMockRecorder) Transfer ¶
func (mr *MockClientMockRecorder) Transfer(ctx, request, member interface{}) *gomock.Call
Transfer indicates an expected call of Transfer
func (*MockClientMockRecorder) Vote ¶
func (mr *MockClientMockRecorder) Vote(ctx, request, member interface{}) *gomock.Call
Vote indicates an expected call of Vote
type MockCluster ¶
type MockCluster struct {
// contains filtered or unexported fields
}
MockCluster is a mock of Cluster interface
func NewMockCluster ¶
func NewMockCluster(ctrl *gomock.Controller) *MockCluster
NewMockCluster creates a new mock instance
func (*MockCluster) EXPECT ¶
func (m *MockCluster) EXPECT() *MockClusterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockCluster) GetClient ¶
func (m *MockCluster) GetClient(memberID protocol.MemberID) (protocol.RaftServiceClient, error)
GetClient mocks base method
func (*MockCluster) GetMember ¶
func (m *MockCluster) GetMember(memberID protocol.MemberID) *protocol.Member
GetMember mocks base method
func (*MockCluster) Member ¶
func (m *MockCluster) Member() protocol.MemberID
Member mocks base method
func (*MockCluster) Members ¶
func (m *MockCluster) Members() []protocol.MemberID
Members mocks base method
type MockClusterMockRecorder ¶
type MockClusterMockRecorder struct {
// contains filtered or unexported fields
}
MockClusterMockRecorder is the mock recorder for MockCluster
func (*MockClusterMockRecorder) GetClient ¶
func (mr *MockClusterMockRecorder) GetClient(memberID interface{}) *gomock.Call
GetClient indicates an expected call of GetClient
func (*MockClusterMockRecorder) GetMember ¶
func (mr *MockClusterMockRecorder) GetMember(memberID interface{}) *gomock.Call
GetMember indicates an expected call of GetMember
func (*MockClusterMockRecorder) Member ¶
func (mr *MockClusterMockRecorder) Member() *gomock.Call
Member indicates an expected call of Member
func (*MockClusterMockRecorder) Members ¶
func (mr *MockClusterMockRecorder) Members() *gomock.Call
Members indicates an expected call of Members
type MockRaft ¶
type MockRaft struct {
// contains filtered or unexported fields
}
MockRaft is a mock of Raft interface
func NewMockRaft ¶
func NewMockRaft(ctrl *gomock.Controller) *MockRaft
NewMockRaft creates a new mock instance
func (*MockRaft) Append ¶
func (m *MockRaft) Append(ctx context.Context, request *protocol.AppendRequest) (*protocol.AppendResponse, error)
Append mocks base method
func (*MockRaft) Command ¶
func (m *MockRaft) Command(request *protocol.CommandRequest, ch chan<- *protocol.CommandStreamResponse) error
Command mocks base method
func (*MockRaft) CommitIndex ¶
CommitIndex mocks base method
func (*MockRaft) Config ¶
func (m *MockRaft) Config() *config.ProtocolConfig
Config mocks base method
func (*MockRaft) Configure ¶
func (m *MockRaft) Configure(ctx context.Context, request *protocol.ConfigureRequest) (*protocol.ConfigureResponse, error)
Configure mocks base method
func (*MockRaft) EXPECT ¶
func (m *MockRaft) EXPECT() *MockRaftMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockRaft) Install ¶
func (m *MockRaft) Install(ch <-chan *protocol.InstallStreamRequest) (*protocol.InstallResponse, error)
Install mocks base method
func (*MockRaft) Join ¶
func (m *MockRaft) Join(ctx context.Context, request *protocol.JoinRequest) (*protocol.JoinResponse, error)
Join mocks base method
func (*MockRaft) LastVotedFor ¶
LastVotedFor mocks base method
func (*MockRaft) Leave ¶
func (m *MockRaft) Leave(ctx context.Context, request *protocol.LeaveRequest) (*protocol.LeaveResponse, error)
Leave mocks base method
func (*MockRaft) Poll ¶
func (m *MockRaft) Poll(ctx context.Context, request *protocol.PollRequest) (*protocol.PollResponse, error)
Poll mocks base method
func (*MockRaft) Query ¶
func (m *MockRaft) Query(request *protocol.QueryRequest, ch chan<- *protocol.QueryStreamResponse) error
Query mocks base method
func (*MockRaft) Reconfigure ¶
func (m *MockRaft) Reconfigure(ctx context.Context, request *protocol.ReconfigureRequest) (*protocol.ReconfigureResponse, error)
Reconfigure mocks base method
func (*MockRaft) SetCommitIndex ¶
SetCommitIndex mocks base method
func (*MockRaft) SetLastVotedFor ¶
SetLastVotedFor mocks base method
func (*MockRaft) Transfer ¶
func (m *MockRaft) Transfer(ctx context.Context, request *protocol.TransferRequest) (*protocol.TransferResponse, error)
Transfer mocks base method
func (*MockRaft) Vote ¶
func (m *MockRaft) Vote(ctx context.Context, request *protocol.VoteRequest) (*protocol.VoteResponse, error)
Vote mocks base method
func (*MockRaft) WatchStatus ¶
WatchStatus mocks base method
type MockRaftMockRecorder ¶
type MockRaftMockRecorder struct {
// contains filtered or unexported fields
}
MockRaftMockRecorder is the mock recorder for MockRaft
func (*MockRaftMockRecorder) Append ¶
func (mr *MockRaftMockRecorder) Append(ctx, request interface{}) *gomock.Call
Append indicates an expected call of Append
func (*MockRaftMockRecorder) Close ¶
func (mr *MockRaftMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockRaftMockRecorder) Command ¶
func (mr *MockRaftMockRecorder) Command(request, ch interface{}) *gomock.Call
Command indicates an expected call of Command
func (*MockRaftMockRecorder) Commit ¶
func (mr *MockRaftMockRecorder) Commit(index interface{}) *gomock.Call
Commit indicates an expected call of Commit
func (*MockRaftMockRecorder) CommitIndex ¶
func (mr *MockRaftMockRecorder) CommitIndex() *gomock.Call
CommitIndex indicates an expected call of CommitIndex
func (*MockRaftMockRecorder) Config ¶
func (mr *MockRaftMockRecorder) Config() *gomock.Call
Config indicates an expected call of Config
func (*MockRaftMockRecorder) Configure ¶
func (mr *MockRaftMockRecorder) Configure(ctx, request interface{}) *gomock.Call
Configure indicates an expected call of Configure
func (*MockRaftMockRecorder) GetMember ¶
func (mr *MockRaftMockRecorder) GetMember(memberID interface{}) *gomock.Call
GetMember indicates an expected call of GetMember
func (*MockRaftMockRecorder) Init ¶
func (mr *MockRaftMockRecorder) Init() *gomock.Call
Init indicates an expected call of Init
func (*MockRaftMockRecorder) Install ¶
func (mr *MockRaftMockRecorder) Install(ch interface{}) *gomock.Call
Install indicates an expected call of Install
func (*MockRaftMockRecorder) Join ¶
func (mr *MockRaftMockRecorder) Join(ctx, request interface{}) *gomock.Call
Join indicates an expected call of Join
func (*MockRaftMockRecorder) LastVotedFor ¶
func (mr *MockRaftMockRecorder) LastVotedFor() *gomock.Call
LastVotedFor indicates an expected call of LastVotedFor
func (*MockRaftMockRecorder) Leader ¶
func (mr *MockRaftMockRecorder) Leader() *gomock.Call
Leader indicates an expected call of Leader
func (*MockRaftMockRecorder) Leave ¶
func (mr *MockRaftMockRecorder) Leave(ctx, request interface{}) *gomock.Call
Leave indicates an expected call of Leave
func (*MockRaftMockRecorder) Member ¶
func (mr *MockRaftMockRecorder) Member() *gomock.Call
Member indicates an expected call of Member
func (*MockRaftMockRecorder) Members ¶
func (mr *MockRaftMockRecorder) Members() *gomock.Call
Members indicates an expected call of Members
func (*MockRaftMockRecorder) Poll ¶
func (mr *MockRaftMockRecorder) Poll(ctx, request interface{}) *gomock.Call
Poll indicates an expected call of Poll
func (*MockRaftMockRecorder) Protocol ¶
func (mr *MockRaftMockRecorder) Protocol() *gomock.Call
Protocol indicates an expected call of Protocol
func (*MockRaftMockRecorder) Query ¶
func (mr *MockRaftMockRecorder) Query(request, ch interface{}) *gomock.Call
Query indicates an expected call of Query
func (*MockRaftMockRecorder) ReadLock ¶
func (mr *MockRaftMockRecorder) ReadLock() *gomock.Call
ReadLock indicates an expected call of ReadLock
func (*MockRaftMockRecorder) ReadUnlock ¶
func (mr *MockRaftMockRecorder) ReadUnlock() *gomock.Call
ReadUnlock indicates an expected call of ReadUnlock
func (*MockRaftMockRecorder) Reconfigure ¶
func (mr *MockRaftMockRecorder) Reconfigure(ctx, request interface{}) *gomock.Call
Reconfigure indicates an expected call of Reconfigure
func (*MockRaftMockRecorder) Role ¶
func (mr *MockRaftMockRecorder) Role() *gomock.Call
Role indicates an expected call of Role
func (*MockRaftMockRecorder) SetCommitIndex ¶
func (mr *MockRaftMockRecorder) SetCommitIndex(index interface{}) *gomock.Call
SetCommitIndex indicates an expected call of SetCommitIndex
func (*MockRaftMockRecorder) SetLastVotedFor ¶
func (mr *MockRaftMockRecorder) SetLastVotedFor(memberID interface{}) *gomock.Call
SetLastVotedFor indicates an expected call of SetLastVotedFor
func (*MockRaftMockRecorder) SetLeader ¶
func (mr *MockRaftMockRecorder) SetLeader(leader interface{}) *gomock.Call
SetLeader indicates an expected call of SetLeader
func (*MockRaftMockRecorder) SetRole ¶
func (mr *MockRaftMockRecorder) SetRole(role interface{}) *gomock.Call
SetRole indicates an expected call of SetRole
func (*MockRaftMockRecorder) SetTerm ¶
func (mr *MockRaftMockRecorder) SetTerm(term interface{}) *gomock.Call
SetTerm indicates an expected call of SetTerm
func (*MockRaftMockRecorder) Status ¶
func (mr *MockRaftMockRecorder) Status() *gomock.Call
Status indicates an expected call of Status
func (*MockRaftMockRecorder) Term ¶
func (mr *MockRaftMockRecorder) Term() *gomock.Call
Term indicates an expected call of Term
func (*MockRaftMockRecorder) Transfer ¶
func (mr *MockRaftMockRecorder) Transfer(ctx, request interface{}) *gomock.Call
Transfer indicates an expected call of Transfer
func (*MockRaftMockRecorder) Vote ¶
func (mr *MockRaftMockRecorder) Vote(ctx, request interface{}) *gomock.Call
Vote indicates an expected call of Vote
func (*MockRaftMockRecorder) WatchRole ¶
func (mr *MockRaftMockRecorder) WatchRole(arg0 interface{}) *gomock.Call
WatchRole indicates an expected call of WatchRole
func (*MockRaftMockRecorder) WatchStatus ¶
func (mr *MockRaftMockRecorder) WatchStatus(arg0 interface{}) *gomock.Call
WatchStatus indicates an expected call of WatchStatus
func (*MockRaftMockRecorder) WriteLock ¶
func (mr *MockRaftMockRecorder) WriteLock() *gomock.Call
WriteLock indicates an expected call of WriteLock
func (*MockRaftMockRecorder) WriteUnlock ¶
func (mr *MockRaftMockRecorder) WriteUnlock() *gomock.Call
WriteUnlock indicates an expected call of WriteUnlock
type MockRole ¶
type MockRole struct {
// contains filtered or unexported fields
}
MockRole is a mock of Role interface
func NewMockRole ¶
func NewMockRole(ctrl *gomock.Controller) *MockRole
NewMockRole creates a new mock instance
func (*MockRole) Append ¶
func (m *MockRole) Append(ctx context.Context, request *protocol.AppendRequest) (*protocol.AppendResponse, error)
Append mocks base method
func (*MockRole) Command ¶
func (m *MockRole) Command(request *protocol.CommandRequest, ch chan<- *protocol.CommandStreamResponse) error
Command mocks base method
func (*MockRole) Configure ¶
func (m *MockRole) Configure(ctx context.Context, request *protocol.ConfigureRequest) (*protocol.ConfigureResponse, error)
Configure mocks base method
func (*MockRole) EXPECT ¶
func (m *MockRole) EXPECT() *MockRoleMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockRole) Install ¶
func (m *MockRole) Install(ch <-chan *protocol.InstallStreamRequest) (*protocol.InstallResponse, error)
Install mocks base method
func (*MockRole) Join ¶
func (m *MockRole) Join(ctx context.Context, request *protocol.JoinRequest) (*protocol.JoinResponse, error)
Join mocks base method
func (*MockRole) Leave ¶
func (m *MockRole) Leave(ctx context.Context, request *protocol.LeaveRequest) (*protocol.LeaveResponse, error)
Leave mocks base method
func (*MockRole) Poll ¶
func (m *MockRole) Poll(ctx context.Context, request *protocol.PollRequest) (*protocol.PollResponse, error)
Poll mocks base method
func (*MockRole) Query ¶
func (m *MockRole) Query(request *protocol.QueryRequest, ch chan<- *protocol.QueryStreamResponse) error
Query mocks base method
func (*MockRole) Reconfigure ¶
func (m *MockRole) Reconfigure(ctx context.Context, request *protocol.ReconfigureRequest) (*protocol.ReconfigureResponse, error)
Reconfigure mocks base method
func (*MockRole) Transfer ¶
func (m *MockRole) Transfer(ctx context.Context, request *protocol.TransferRequest) (*protocol.TransferResponse, error)
Transfer mocks base method
func (*MockRole) Vote ¶
func (m *MockRole) Vote(ctx context.Context, request *protocol.VoteRequest) (*protocol.VoteResponse, error)
Vote mocks base method
type MockRoleMockRecorder ¶
type MockRoleMockRecorder struct {
// contains filtered or unexported fields
}
MockRoleMockRecorder is the mock recorder for MockRole
func (*MockRoleMockRecorder) Append ¶
func (mr *MockRoleMockRecorder) Append(ctx, request interface{}) *gomock.Call
Append indicates an expected call of Append
func (*MockRoleMockRecorder) Command ¶
func (mr *MockRoleMockRecorder) Command(request, ch interface{}) *gomock.Call
Command indicates an expected call of Command
func (*MockRoleMockRecorder) Configure ¶
func (mr *MockRoleMockRecorder) Configure(ctx, request interface{}) *gomock.Call
Configure indicates an expected call of Configure
func (*MockRoleMockRecorder) Install ¶
func (mr *MockRoleMockRecorder) Install(ch interface{}) *gomock.Call
Install indicates an expected call of Install
func (*MockRoleMockRecorder) Join ¶
func (mr *MockRoleMockRecorder) Join(ctx, request interface{}) *gomock.Call
Join indicates an expected call of Join
func (*MockRoleMockRecorder) Leave ¶
func (mr *MockRoleMockRecorder) Leave(ctx, request interface{}) *gomock.Call
Leave indicates an expected call of Leave
func (*MockRoleMockRecorder) Poll ¶
func (mr *MockRoleMockRecorder) Poll(ctx, request interface{}) *gomock.Call
Poll indicates an expected call of Poll
func (*MockRoleMockRecorder) Query ¶
func (mr *MockRoleMockRecorder) Query(request, ch interface{}) *gomock.Call
Query indicates an expected call of Query
func (*MockRoleMockRecorder) Reconfigure ¶
func (mr *MockRoleMockRecorder) Reconfigure(ctx, request interface{}) *gomock.Call
Reconfigure indicates an expected call of Reconfigure
func (*MockRoleMockRecorder) Start ¶
func (mr *MockRoleMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start
func (*MockRoleMockRecorder) Stop ¶
func (mr *MockRoleMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop
func (*MockRoleMockRecorder) Transfer ¶
func (mr *MockRoleMockRecorder) Transfer(ctx, request interface{}) *gomock.Call
Transfer indicates an expected call of Transfer
func (*MockRoleMockRecorder) Type ¶
func (mr *MockRoleMockRecorder) Type() *gomock.Call
Type indicates an expected call of Type
func (*MockRoleMockRecorder) Vote ¶
func (mr *MockRoleMockRecorder) Vote(ctx, request interface{}) *gomock.Call
Vote indicates an expected call of Vote
type MockServer ¶
type MockServer struct {
// contains filtered or unexported fields
}
MockServer is a mock of Server interface
func NewMockServer ¶
func NewMockServer(ctrl *gomock.Controller) *MockServer
NewMockServer creates a new mock instance
func (*MockServer) Append ¶
func (m *MockServer) Append(ctx context.Context, request *protocol.AppendRequest) (*protocol.AppendResponse, error)
Append mocks base method
func (*MockServer) Command ¶
func (m *MockServer) Command(request *protocol.CommandRequest, ch chan<- *protocol.CommandStreamResponse) error
Command mocks base method
func (*MockServer) Configure ¶
func (m *MockServer) Configure(ctx context.Context, request *protocol.ConfigureRequest) (*protocol.ConfigureResponse, error)
Configure mocks base method
func (*MockServer) EXPECT ¶
func (m *MockServer) EXPECT() *MockServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockServer) Install ¶
func (m *MockServer) Install(ch <-chan *protocol.InstallStreamRequest) (*protocol.InstallResponse, error)
Install mocks base method
func (*MockServer) Join ¶
func (m *MockServer) Join(ctx context.Context, request *protocol.JoinRequest) (*protocol.JoinResponse, error)
Join mocks base method
func (*MockServer) Leave ¶
func (m *MockServer) Leave(ctx context.Context, request *protocol.LeaveRequest) (*protocol.LeaveResponse, error)
Leave mocks base method
func (*MockServer) Poll ¶
func (m *MockServer) Poll(ctx context.Context, request *protocol.PollRequest) (*protocol.PollResponse, error)
Poll mocks base method
func (*MockServer) Query ¶
func (m *MockServer) Query(request *protocol.QueryRequest, ch chan<- *protocol.QueryStreamResponse) error
Query mocks base method
func (*MockServer) Reconfigure ¶
func (m *MockServer) Reconfigure(ctx context.Context, request *protocol.ReconfigureRequest) (*protocol.ReconfigureResponse, error)
Reconfigure mocks base method
func (*MockServer) Transfer ¶
func (m *MockServer) Transfer(ctx context.Context, request *protocol.TransferRequest) (*protocol.TransferResponse, error)
Transfer mocks base method
func (*MockServer) Vote ¶
func (m *MockServer) Vote(ctx context.Context, request *protocol.VoteRequest) (*protocol.VoteResponse, error)
Vote mocks base method
type MockServerMockRecorder ¶
type MockServerMockRecorder struct {
// contains filtered or unexported fields
}
MockServerMockRecorder is the mock recorder for MockServer
func (*MockServerMockRecorder) Append ¶
func (mr *MockServerMockRecorder) Append(ctx, request interface{}) *gomock.Call
Append indicates an expected call of Append
func (*MockServerMockRecorder) Command ¶
func (mr *MockServerMockRecorder) Command(request, ch interface{}) *gomock.Call
Command indicates an expected call of Command
func (*MockServerMockRecorder) Configure ¶
func (mr *MockServerMockRecorder) Configure(ctx, request interface{}) *gomock.Call
Configure indicates an expected call of Configure
func (*MockServerMockRecorder) Install ¶
func (mr *MockServerMockRecorder) Install(ch interface{}) *gomock.Call
Install indicates an expected call of Install
func (*MockServerMockRecorder) Join ¶
func (mr *MockServerMockRecorder) Join(ctx, request interface{}) *gomock.Call
Join indicates an expected call of Join
func (*MockServerMockRecorder) Leave ¶
func (mr *MockServerMockRecorder) Leave(ctx, request interface{}) *gomock.Call
Leave indicates an expected call of Leave
func (*MockServerMockRecorder) Poll ¶
func (mr *MockServerMockRecorder) Poll(ctx, request interface{}) *gomock.Call
Poll indicates an expected call of Poll
func (*MockServerMockRecorder) Query ¶
func (mr *MockServerMockRecorder) Query(request, ch interface{}) *gomock.Call
Query indicates an expected call of Query
func (*MockServerMockRecorder) Reconfigure ¶
func (mr *MockServerMockRecorder) Reconfigure(ctx, request interface{}) *gomock.Call
Reconfigure indicates an expected call of Reconfigure
func (*MockServerMockRecorder) Transfer ¶
func (mr *MockServerMockRecorder) Transfer(ctx, request interface{}) *gomock.Call
Transfer indicates an expected call of Transfer
func (*MockServerMockRecorder) Vote ¶
func (mr *MockServerMockRecorder) Vote(ctx, request interface{}) *gomock.Call
Vote indicates an expected call of Vote