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 MockMembershipClient
- func (m *MockMembershipClient) EXPECT() *MockMembershipClientMockRecorder
- func (m *MockMembershipClient) ListNodes(arg0 context.Context, arg1 *proto.ListNodesRequest, arg2 ...grpc.CallOption) (*proto.ListNodesResponse, error)
- func (m *MockMembershipClient) Ping(arg0 context.Context, arg1 *proto.PingRequest, arg2 ...grpc.CallOption) (*proto.PingResponse, error)
- func (m *MockMembershipClient) PingIndirect(arg0 context.Context, arg1 *proto.PingIndirectRequest, arg2 ...grpc.CallOption) (*proto.PingIndirectResponse, error)
- func (m *MockMembershipClient) PullPushState(arg0 context.Context, arg1 *proto.PullPushStateRequest, ...) (*proto.PullPushStateResponse, error)
- type MockMembershipClientMockRecorder
- func (mr *MockMembershipClientMockRecorder) ListNodes(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockMembershipClientMockRecorder) Ping(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockMembershipClientMockRecorder) PingIndirect(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockMembershipClientMockRecorder) PullPushState(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- type MockReplicationClient
- func (m *MockReplicationClient) CounterDecrement(arg0 context.Context, arg1 *proto.CounterDecrementRequest, ...) (*proto.CounterDecrementResponse, error)
- func (m *MockReplicationClient) CounterGet(arg0 context.Context, arg1 *proto.CounterGetRequest, arg2 ...grpc.CallOption) (*proto.CounterGetResponse, error)
- func (m *MockReplicationClient) CounterIncrement(arg0 context.Context, arg1 *proto.CounterIncrementRequest, ...) (*proto.CounterIncrementResponse, error)
- func (m *MockReplicationClient) Delete(arg0 context.Context, arg1 *proto.DeleteRequest, arg2 ...grpc.CallOption) (*proto.DeleteResponse, error)
- func (m *MockReplicationClient) EXPECT() *MockReplicationClientMockRecorder
- func (m *MockReplicationClient) Get(arg0 context.Context, arg1 *proto.GetRequest, arg2 ...grpc.CallOption) (*proto.GetResponse, error)
- func (m *MockReplicationClient) Put(arg0 context.Context, arg1 *proto.PutRequest, arg2 ...grpc.CallOption) (*proto.PutResponse, error)
- func (m *MockReplicationClient) RegisterGet(arg0 context.Context, arg1 *proto.RegisterGetRequest, arg2 ...grpc.CallOption) (*proto.RegisterGetResponse, error)
- func (m *MockReplicationClient) RegisterPut(arg0 context.Context, arg1 *proto.RegisterPutRequest, arg2 ...grpc.CallOption) (*proto.RegisterPutResponse, error)
- func (m *MockReplicationClient) SetAdd(arg0 context.Context, arg1 *proto.SetAddRequest, arg2 ...grpc.CallOption) (*proto.SetAddResponse, error)
- func (m *MockReplicationClient) SetContains(arg0 context.Context, arg1 *proto.SetContainsRequest, arg2 ...grpc.CallOption) (*proto.SetContainsResponse, error)
- func (m *MockReplicationClient) SetGetAll(arg0 context.Context, arg1 *proto.SetGetAllRequest, arg2 ...grpc.CallOption) (*proto.SetGetAllResponse, error)
- func (m *MockReplicationClient) SetIntersect(arg0 context.Context, arg1 *proto.SetIntersectRequest, arg2 ...grpc.CallOption) (*proto.SetIntersectResponse, error)
- func (m *MockReplicationClient) SetRemove(arg0 context.Context, arg1 *proto.SetRemoveRequest, arg2 ...grpc.CallOption) (*proto.SetRemoveResponse, error)
- type MockReplicationClientMockRecorder
- func (mr *MockReplicationClientMockRecorder) CounterDecrement(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockReplicationClientMockRecorder) CounterGet(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockReplicationClientMockRecorder) CounterIncrement(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockReplicationClientMockRecorder) Delete(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockReplicationClientMockRecorder) Get(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockReplicationClientMockRecorder) Put(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockReplicationClientMockRecorder) RegisterGet(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockReplicationClientMockRecorder) RegisterPut(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockReplicationClientMockRecorder) SetAdd(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockReplicationClientMockRecorder) SetContains(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockReplicationClientMockRecorder) SetGetAll(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockReplicationClientMockRecorder) SetIntersect(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockReplicationClientMockRecorder) SetRemove(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- type MockStorageServiceClient
- func (m *MockStorageServiceClient) EXPECT() *MockStorageServiceClientMockRecorder
- func (m *MockStorageServiceClient) Get(arg0 context.Context, arg1 *proto.GetRequest, arg2 ...grpc.CallOption) (*proto.GetResponse, error)
- func (m *MockStorageServiceClient) Put(arg0 context.Context, arg1 *proto.PutRequest, arg2 ...grpc.CallOption) (*proto.PutResponse, error)
- func (m *MockStorageServiceClient) Scan(arg0 context.Context, arg1 *proto.ScanRequest, arg2 ...grpc.CallOption) (proto.StorageService_ScanClient, error)
- type MockStorageServiceClientMockRecorder
- func (mr *MockStorageServiceClientMockRecorder) Get(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockStorageServiceClientMockRecorder) Put(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockStorageServiceClientMockRecorder) Scan(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockMembershipClient ¶
type MockMembershipClient struct {
// contains filtered or unexported fields
}
MockMembershipClient is a mock of MembershipClient interface.
func NewMockMembershipClient ¶
func NewMockMembershipClient(ctrl *gomock.Controller) *MockMembershipClient
NewMockMembershipClient creates a new mock instance.
func (*MockMembershipClient) EXPECT ¶
func (m *MockMembershipClient) EXPECT() *MockMembershipClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockMembershipClient) ListNodes ¶
func (m *MockMembershipClient) ListNodes(arg0 context.Context, arg1 *proto.ListNodesRequest, arg2 ...grpc.CallOption) (*proto.ListNodesResponse, error)
ListNodes mocks base method.
func (*MockMembershipClient) Ping ¶
func (m *MockMembershipClient) Ping(arg0 context.Context, arg1 *proto.PingRequest, arg2 ...grpc.CallOption) (*proto.PingResponse, error)
Ping mocks base method.
func (*MockMembershipClient) PingIndirect ¶
func (m *MockMembershipClient) PingIndirect(arg0 context.Context, arg1 *proto.PingIndirectRequest, arg2 ...grpc.CallOption) (*proto.PingIndirectResponse, error)
PingIndirect mocks base method.
func (*MockMembershipClient) PullPushState ¶
func (m *MockMembershipClient) PullPushState(arg0 context.Context, arg1 *proto.PullPushStateRequest, arg2 ...grpc.CallOption) (*proto.PullPushStateResponse, error)
PullPushState mocks base method.
type MockMembershipClientMockRecorder ¶
type MockMembershipClientMockRecorder struct {
// contains filtered or unexported fields
}
MockMembershipClientMockRecorder is the mock recorder for MockMembershipClient.
func (*MockMembershipClientMockRecorder) ListNodes ¶
func (mr *MockMembershipClientMockRecorder) ListNodes(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListNodes indicates an expected call of ListNodes.
func (*MockMembershipClientMockRecorder) Ping ¶
func (mr *MockMembershipClientMockRecorder) Ping(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Ping indicates an expected call of Ping.
func (*MockMembershipClientMockRecorder) PingIndirect ¶
func (mr *MockMembershipClientMockRecorder) PingIndirect(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
PingIndirect indicates an expected call of PingIndirect.
func (*MockMembershipClientMockRecorder) PullPushState ¶
func (mr *MockMembershipClientMockRecorder) PullPushState(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
PullPushState indicates an expected call of PullPushState.
type MockReplicationClient ¶
type MockReplicationClient struct {
// contains filtered or unexported fields
}
MockReplicationClient is a mock of ReplicationClient interface.
func NewMockReplicationClient ¶
func NewMockReplicationClient(ctrl *gomock.Controller) *MockReplicationClient
NewMockReplicationClient creates a new mock instance.
func (*MockReplicationClient) CounterDecrement ¶
func (m *MockReplicationClient) CounterDecrement(arg0 context.Context, arg1 *proto.CounterDecrementRequest, arg2 ...grpc.CallOption) (*proto.CounterDecrementResponse, error)
CounterDecrement mocks base method.
func (*MockReplicationClient) CounterGet ¶
func (m *MockReplicationClient) CounterGet(arg0 context.Context, arg1 *proto.CounterGetRequest, arg2 ...grpc.CallOption) (*proto.CounterGetResponse, error)
CounterGet mocks base method.
func (*MockReplicationClient) CounterIncrement ¶
func (m *MockReplicationClient) CounterIncrement(arg0 context.Context, arg1 *proto.CounterIncrementRequest, arg2 ...grpc.CallOption) (*proto.CounterIncrementResponse, error)
CounterIncrement mocks base method.
func (*MockReplicationClient) Delete ¶
func (m *MockReplicationClient) Delete(arg0 context.Context, arg1 *proto.DeleteRequest, arg2 ...grpc.CallOption) (*proto.DeleteResponse, error)
Delete mocks base method.
func (*MockReplicationClient) EXPECT ¶
func (m *MockReplicationClient) EXPECT() *MockReplicationClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockReplicationClient) Get ¶
func (m *MockReplicationClient) Get(arg0 context.Context, arg1 *proto.GetRequest, arg2 ...grpc.CallOption) (*proto.GetResponse, error)
Get mocks base method.
func (*MockReplicationClient) Put ¶
func (m *MockReplicationClient) Put(arg0 context.Context, arg1 *proto.PutRequest, arg2 ...grpc.CallOption) (*proto.PutResponse, error)
Put mocks base method.
func (*MockReplicationClient) RegisterGet ¶
func (m *MockReplicationClient) RegisterGet(arg0 context.Context, arg1 *proto.RegisterGetRequest, arg2 ...grpc.CallOption) (*proto.RegisterGetResponse, error)
RegisterGet mocks base method.
func (*MockReplicationClient) RegisterPut ¶
func (m *MockReplicationClient) RegisterPut(arg0 context.Context, arg1 *proto.RegisterPutRequest, arg2 ...grpc.CallOption) (*proto.RegisterPutResponse, error)
RegisterPut mocks base method.
func (*MockReplicationClient) SetAdd ¶
func (m *MockReplicationClient) SetAdd(arg0 context.Context, arg1 *proto.SetAddRequest, arg2 ...grpc.CallOption) (*proto.SetAddResponse, error)
SetAdd mocks base method.
func (*MockReplicationClient) SetContains ¶
func (m *MockReplicationClient) SetContains(arg0 context.Context, arg1 *proto.SetContainsRequest, arg2 ...grpc.CallOption) (*proto.SetContainsResponse, error)
SetContains mocks base method.
func (*MockReplicationClient) SetGetAll ¶
func (m *MockReplicationClient) SetGetAll(arg0 context.Context, arg1 *proto.SetGetAllRequest, arg2 ...grpc.CallOption) (*proto.SetGetAllResponse, error)
SetGetAll mocks base method.
func (*MockReplicationClient) SetIntersect ¶
func (m *MockReplicationClient) SetIntersect(arg0 context.Context, arg1 *proto.SetIntersectRequest, arg2 ...grpc.CallOption) (*proto.SetIntersectResponse, error)
SetIntersect mocks base method.
func (*MockReplicationClient) SetRemove ¶
func (m *MockReplicationClient) SetRemove(arg0 context.Context, arg1 *proto.SetRemoveRequest, arg2 ...grpc.CallOption) (*proto.SetRemoveResponse, error)
SetRemove mocks base method.
type MockReplicationClientMockRecorder ¶
type MockReplicationClientMockRecorder struct {
// contains filtered or unexported fields
}
MockReplicationClientMockRecorder is the mock recorder for MockReplicationClient.
func (*MockReplicationClientMockRecorder) CounterDecrement ¶
func (mr *MockReplicationClientMockRecorder) CounterDecrement(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CounterDecrement indicates an expected call of CounterDecrement.
func (*MockReplicationClientMockRecorder) CounterGet ¶
func (mr *MockReplicationClientMockRecorder) CounterGet(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CounterGet indicates an expected call of CounterGet.
func (*MockReplicationClientMockRecorder) CounterIncrement ¶
func (mr *MockReplicationClientMockRecorder) CounterIncrement(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CounterIncrement indicates an expected call of CounterIncrement.
func (*MockReplicationClientMockRecorder) Delete ¶
func (mr *MockReplicationClientMockRecorder) Delete(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockReplicationClientMockRecorder) Get ¶
func (mr *MockReplicationClientMockRecorder) Get(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockReplicationClientMockRecorder) Put ¶
func (mr *MockReplicationClientMockRecorder) Put(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Put indicates an expected call of Put.
func (*MockReplicationClientMockRecorder) RegisterGet ¶
func (mr *MockReplicationClientMockRecorder) RegisterGet(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RegisterGet indicates an expected call of RegisterGet.
func (*MockReplicationClientMockRecorder) RegisterPut ¶
func (mr *MockReplicationClientMockRecorder) RegisterPut(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RegisterPut indicates an expected call of RegisterPut.
func (*MockReplicationClientMockRecorder) SetAdd ¶
func (mr *MockReplicationClientMockRecorder) SetAdd(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
SetAdd indicates an expected call of SetAdd.
func (*MockReplicationClientMockRecorder) SetContains ¶
func (mr *MockReplicationClientMockRecorder) SetContains(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
SetContains indicates an expected call of SetContains.
func (*MockReplicationClientMockRecorder) SetGetAll ¶
func (mr *MockReplicationClientMockRecorder) SetGetAll(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
SetGetAll indicates an expected call of SetGetAll.
func (*MockReplicationClientMockRecorder) SetIntersect ¶
func (mr *MockReplicationClientMockRecorder) SetIntersect(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
SetIntersect indicates an expected call of SetIntersect.
func (*MockReplicationClientMockRecorder) SetRemove ¶
func (mr *MockReplicationClientMockRecorder) SetRemove(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
SetRemove indicates an expected call of SetRemove.
type MockStorageServiceClient ¶
type MockStorageServiceClient struct {
// contains filtered or unexported fields
}
MockStorageServiceClient is a mock of StorageServiceClient interface.
func NewMockStorageServiceClient ¶
func NewMockStorageServiceClient(ctrl *gomock.Controller) *MockStorageServiceClient
NewMockStorageServiceClient creates a new mock instance.
func (*MockStorageServiceClient) EXPECT ¶
func (m *MockStorageServiceClient) EXPECT() *MockStorageServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockStorageServiceClient) Get ¶
func (m *MockStorageServiceClient) Get(arg0 context.Context, arg1 *proto.GetRequest, arg2 ...grpc.CallOption) (*proto.GetResponse, error)
Get mocks base method.
func (*MockStorageServiceClient) Put ¶
func (m *MockStorageServiceClient) Put(arg0 context.Context, arg1 *proto.PutRequest, arg2 ...grpc.CallOption) (*proto.PutResponse, error)
Put mocks base method.
func (*MockStorageServiceClient) Scan ¶
func (m *MockStorageServiceClient) Scan(arg0 context.Context, arg1 *proto.ScanRequest, arg2 ...grpc.CallOption) (proto.StorageService_ScanClient, error)
Scan mocks base method.
type MockStorageServiceClientMockRecorder ¶
type MockStorageServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockStorageServiceClientMockRecorder is the mock recorder for MockStorageServiceClient.
func (*MockStorageServiceClientMockRecorder) Get ¶
func (mr *MockStorageServiceClientMockRecorder) Get(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockStorageServiceClientMockRecorder) Put ¶
func (mr *MockStorageServiceClientMockRecorder) Put(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Put indicates an expected call of Put.
func (*MockStorageServiceClientMockRecorder) Scan ¶
func (mr *MockStorageServiceClientMockRecorder) Scan(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Scan indicates an expected call of Scan.