Documentation
¶
Overview ¶
Package mock_v1 is a generated GoMock package.
Package mock_v1 is a generated GoMock package.
Package mock_v1 is a generated GoMock package.
Index ¶
- type MockClientConnInterface
- func (m *MockClientConnInterface) EXPECT() *MockClientConnInterfaceMockRecorder
- func (m *MockClientConnInterface) Invoke(arg0 context.Context, arg1 string, arg2, arg3 interface{}, ...) error
- func (m *MockClientConnInterface) NewStream(arg0 context.Context, arg1 *grpc.StreamDesc, arg2 string, ...) (grpc.ClientStream, error)
- type MockClientConnInterfaceMockRecorder
- type MockDocumentServiceClient
- func (m *MockDocumentServiceClient) Delete(arg0 context.Context, arg1 *v1.DocumentDeleteRequest, arg2 ...grpc.CallOption) (*v1.DocumentDeleteResponse, error)
- func (m *MockDocumentServiceClient) EXPECT() *MockDocumentServiceClientMockRecorder
- func (m *MockDocumentServiceClient) Get(arg0 context.Context, arg1 *v1.DocumentGetRequest, arg2 ...grpc.CallOption) (*v1.DocumentGetResponse, error)
- func (m *MockDocumentServiceClient) Query(arg0 context.Context, arg1 *v1.DocumentQueryRequest, arg2 ...grpc.CallOption) (*v1.DocumentQueryResponse, error)
- func (m *MockDocumentServiceClient) QueryStream(arg0 context.Context, arg1 *v1.DocumentQueryStreamRequest, ...) (v1.DocumentService_QueryStreamClient, error)
- func (m *MockDocumentServiceClient) Set(arg0 context.Context, arg1 *v1.DocumentSetRequest, arg2 ...grpc.CallOption) (*v1.DocumentSetResponse, error)
- type MockDocumentServiceClientMockRecorder
- func (mr *MockDocumentServiceClientMockRecorder) Delete(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDocumentServiceClientMockRecorder) Get(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDocumentServiceClientMockRecorder) Query(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDocumentServiceClientMockRecorder) QueryStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockDocumentServiceClientMockRecorder) Set(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- type MockDocumentServiceServer
- func (m *MockDocumentServiceServer) Delete(arg0 context.Context, arg1 *v1.DocumentDeleteRequest) (*v1.DocumentDeleteResponse, error)
- func (m *MockDocumentServiceServer) EXPECT() *MockDocumentServiceServerMockRecorder
- func (m *MockDocumentServiceServer) Get(arg0 context.Context, arg1 *v1.DocumentGetRequest) (*v1.DocumentGetResponse, error)
- func (m *MockDocumentServiceServer) Query(arg0 context.Context, arg1 *v1.DocumentQueryRequest) (*v1.DocumentQueryResponse, error)
- func (m *MockDocumentServiceServer) QueryStream(arg0 *v1.DocumentQueryStreamRequest, arg1 v1.DocumentService_QueryStreamServer) error
- func (m *MockDocumentServiceServer) Set(arg0 context.Context, arg1 *v1.DocumentSetRequest) (*v1.DocumentSetResponse, error)
- type MockDocumentServiceServerMockRecorder
- func (mr *MockDocumentServiceServerMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockDocumentServiceServerMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockDocumentServiceServerMockRecorder) Query(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockDocumentServiceServerMockRecorder) QueryStream(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockDocumentServiceServerMockRecorder) Set(arg0, arg1 interface{}) *gomock.Call
- type MockDocumentService_QueryStreamClient
- func (m *MockDocumentService_QueryStreamClient) CloseSend() error
- func (m *MockDocumentService_QueryStreamClient) Context() context.Context
- func (m *MockDocumentService_QueryStreamClient) EXPECT() *MockDocumentService_QueryStreamClientMockRecorder
- func (m *MockDocumentService_QueryStreamClient) Header() (metadata.MD, error)
- func (m *MockDocumentService_QueryStreamClient) Recv() (*v1.DocumentQueryStreamResponse, error)
- func (m *MockDocumentService_QueryStreamClient) RecvMsg(arg0 interface{}) error
- func (m *MockDocumentService_QueryStreamClient) SendMsg(arg0 interface{}) error
- func (m *MockDocumentService_QueryStreamClient) Trailer() metadata.MD
- type MockDocumentService_QueryStreamClientMockRecorder
- func (mr *MockDocumentService_QueryStreamClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockDocumentService_QueryStreamClientMockRecorder) Context() *gomock.Call
- func (mr *MockDocumentService_QueryStreamClientMockRecorder) Header() *gomock.Call
- func (mr *MockDocumentService_QueryStreamClientMockRecorder) Recv() *gomock.Call
- func (mr *MockDocumentService_QueryStreamClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockDocumentService_QueryStreamClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockDocumentService_QueryStreamClientMockRecorder) Trailer() *gomock.Call
- type MockDocumentService_QueryStreamServer
- func (m *MockDocumentService_QueryStreamServer) Context() context.Context
- func (m *MockDocumentService_QueryStreamServer) EXPECT() *MockDocumentService_QueryStreamServerMockRecorder
- func (m *MockDocumentService_QueryStreamServer) RecvMsg(arg0 interface{}) error
- func (m *MockDocumentService_QueryStreamServer) Send(arg0 *v1.DocumentQueryStreamResponse) error
- func (m *MockDocumentService_QueryStreamServer) SendHeader(arg0 metadata.MD) error
- func (m *MockDocumentService_QueryStreamServer) SendMsg(arg0 interface{}) error
- func (m *MockDocumentService_QueryStreamServer) SetHeader(arg0 metadata.MD) error
- func (m *MockDocumentService_QueryStreamServer) SetTrailer(arg0 metadata.MD)
- type MockDocumentService_QueryStreamServerMockRecorder
- func (mr *MockDocumentService_QueryStreamServerMockRecorder) Context() *gomock.Call
- func (mr *MockDocumentService_QueryStreamServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockDocumentService_QueryStreamServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockDocumentService_QueryStreamServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockDocumentService_QueryStreamServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockDocumentService_QueryStreamServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockDocumentService_QueryStreamServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockEventServiceClient
- type MockEventServiceClientMockRecorder
- type MockEventServiceServer
- type MockEventServiceServerMockRecorder
- type MockFaasServiceClient
- type MockFaasServiceClientMockRecorder
- type MockFaasServiceServer
- type MockFaasServiceServerMockRecorder
- type MockFaasService_TriggerStreamClient
- func (m *MockFaasService_TriggerStreamClient) CloseSend() error
- func (m *MockFaasService_TriggerStreamClient) Context() context.Context
- func (m *MockFaasService_TriggerStreamClient) EXPECT() *MockFaasService_TriggerStreamClientMockRecorder
- func (m *MockFaasService_TriggerStreamClient) Header() (metadata.MD, error)
- func (m *MockFaasService_TriggerStreamClient) Recv() (*v1.ServerMessage, error)
- func (m *MockFaasService_TriggerStreamClient) RecvMsg(arg0 interface{}) error
- func (m *MockFaasService_TriggerStreamClient) Send(arg0 *v1.ClientMessage) error
- func (m *MockFaasService_TriggerStreamClient) SendMsg(arg0 interface{}) error
- func (m *MockFaasService_TriggerStreamClient) Trailer() metadata.MD
- type MockFaasService_TriggerStreamClientMockRecorder
- func (mr *MockFaasService_TriggerStreamClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockFaasService_TriggerStreamClientMockRecorder) Context() *gomock.Call
- func (mr *MockFaasService_TriggerStreamClientMockRecorder) Header() *gomock.Call
- func (mr *MockFaasService_TriggerStreamClientMockRecorder) Recv() *gomock.Call
- func (mr *MockFaasService_TriggerStreamClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockFaasService_TriggerStreamClientMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockFaasService_TriggerStreamClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockFaasService_TriggerStreamClientMockRecorder) Trailer() *gomock.Call
- type MockFaasService_TriggerStreamServer
- func (m *MockFaasService_TriggerStreamServer) Context() context.Context
- func (m *MockFaasService_TriggerStreamServer) EXPECT() *MockFaasService_TriggerStreamServerMockRecorder
- func (m *MockFaasService_TriggerStreamServer) Recv() (*v1.ClientMessage, error)
- func (m *MockFaasService_TriggerStreamServer) RecvMsg(arg0 interface{}) error
- func (m *MockFaasService_TriggerStreamServer) Send(arg0 *v1.ServerMessage) error
- func (m *MockFaasService_TriggerStreamServer) SendHeader(arg0 metadata.MD) error
- func (m *MockFaasService_TriggerStreamServer) SendMsg(arg0 interface{}) error
- func (m *MockFaasService_TriggerStreamServer) SetHeader(arg0 metadata.MD) error
- func (m *MockFaasService_TriggerStreamServer) SetTrailer(arg0 metadata.MD)
- type MockFaasService_TriggerStreamServerMockRecorder
- func (mr *MockFaasService_TriggerStreamServerMockRecorder) Context() *gomock.Call
- func (mr *MockFaasService_TriggerStreamServerMockRecorder) Recv() *gomock.Call
- func (mr *MockFaasService_TriggerStreamServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockFaasService_TriggerStreamServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockFaasService_TriggerStreamServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockFaasService_TriggerStreamServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockFaasService_TriggerStreamServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockFaasService_TriggerStreamServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockQueueServiceClient
- func (m *MockQueueServiceClient) Complete(arg0 context.Context, arg1 *v1.QueueCompleteRequest, arg2 ...grpc.CallOption) (*v1.QueueCompleteResponse, error)
- func (m *MockQueueServiceClient) EXPECT() *MockQueueServiceClientMockRecorder
- func (m *MockQueueServiceClient) Receive(arg0 context.Context, arg1 *v1.QueueReceiveRequest, arg2 ...grpc.CallOption) (*v1.QueueReceiveResponse, error)
- func (m *MockQueueServiceClient) Send(arg0 context.Context, arg1 *v1.QueueSendRequest, arg2 ...grpc.CallOption) (*v1.QueueSendResponse, error)
- func (m *MockQueueServiceClient) SendBatch(arg0 context.Context, arg1 *v1.QueueSendBatchRequest, arg2 ...grpc.CallOption) (*v1.QueueSendBatchResponse, error)
- type MockQueueServiceClientMockRecorder
- func (mr *MockQueueServiceClientMockRecorder) Complete(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockQueueServiceClientMockRecorder) Receive(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockQueueServiceClientMockRecorder) Send(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockQueueServiceClientMockRecorder) SendBatch(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- type MockQueueServiceServer
- func (m *MockQueueServiceServer) Complete(arg0 context.Context, arg1 *v1.QueueCompleteRequest) (*v1.QueueCompleteResponse, error)
- func (m *MockQueueServiceServer) EXPECT() *MockQueueServiceServerMockRecorder
- func (m *MockQueueServiceServer) Receive(arg0 context.Context, arg1 *v1.QueueReceiveRequest) (*v1.QueueReceiveResponse, error)
- func (m *MockQueueServiceServer) Send(arg0 context.Context, arg1 *v1.QueueSendRequest) (*v1.QueueSendResponse, error)
- func (m *MockQueueServiceServer) SendBatch(arg0 context.Context, arg1 *v1.QueueSendBatchRequest) (*v1.QueueSendBatchResponse, error)
- type MockQueueServiceServerMockRecorder
- func (mr *MockQueueServiceServerMockRecorder) Complete(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockQueueServiceServerMockRecorder) Receive(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockQueueServiceServerMockRecorder) Send(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockQueueServiceServerMockRecorder) SendBatch(arg0, arg1 interface{}) *gomock.Call
- type MockResourceServiceClient
- type MockResourceServiceClientMockRecorder
- type MockSecretServiceClient
- func (m *MockSecretServiceClient) Access(arg0 context.Context, arg1 *v1.SecretAccessRequest, arg2 ...grpc.CallOption) (*v1.SecretAccessResponse, error)
- func (m *MockSecretServiceClient) EXPECT() *MockSecretServiceClientMockRecorder
- func (m *MockSecretServiceClient) Put(arg0 context.Context, arg1 *v1.SecretPutRequest, arg2 ...grpc.CallOption) (*v1.SecretPutResponse, error)
- type MockSecretServiceClientMockRecorder
- type MockSecretServiceServer
- func (m *MockSecretServiceServer) Access(arg0 context.Context, arg1 *v1.SecretAccessRequest) (*v1.SecretAccessResponse, error)
- func (m *MockSecretServiceServer) EXPECT() *MockSecretServiceServerMockRecorder
- func (m *MockSecretServiceServer) Put(arg0 context.Context, arg1 *v1.SecretPutRequest) (*v1.SecretPutResponse, error)
- type MockSecretServiceServerMockRecorder
- type MockStorageServiceClient
- func (m *MockStorageServiceClient) Delete(arg0 context.Context, arg1 *v1.StorageDeleteRequest, arg2 ...grpc.CallOption) (*v1.StorageDeleteResponse, error)
- func (m *MockStorageServiceClient) EXPECT() *MockStorageServiceClientMockRecorder
- func (m *MockStorageServiceClient) PreSignUrl(arg0 context.Context, arg1 *v1.StoragePreSignUrlRequest, ...) (*v1.StoragePreSignUrlResponse, error)
- func (m *MockStorageServiceClient) Read(arg0 context.Context, arg1 *v1.StorageReadRequest, arg2 ...grpc.CallOption) (*v1.StorageReadResponse, error)
- func (m *MockStorageServiceClient) Write(arg0 context.Context, arg1 *v1.StorageWriteRequest, arg2 ...grpc.CallOption) (*v1.StorageWriteResponse, error)
- type MockStorageServiceClientMockRecorder
- func (mr *MockStorageServiceClientMockRecorder) Delete(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockStorageServiceClientMockRecorder) PreSignUrl(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockStorageServiceClientMockRecorder) Read(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockStorageServiceClientMockRecorder) Write(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- type MockStorageServiceServer
- func (m *MockStorageServiceServer) Delete(arg0 context.Context, arg1 *v1.StorageDeleteRequest) (*v1.StorageDeleteResponse, error)
- func (m *MockStorageServiceServer) EXPECT() *MockStorageServiceServerMockRecorder
- func (m *MockStorageServiceServer) PreSignUrl(arg0 context.Context, arg1 *v1.StoragePreSignUrlRequest) (*v1.StoragePreSignUrlResponse, error)
- func (m *MockStorageServiceServer) Read(arg0 context.Context, arg1 *v1.StorageReadRequest) (*v1.StorageReadResponse, error)
- func (m *MockStorageServiceServer) Write(arg0 context.Context, arg1 *v1.StorageWriteRequest) (*v1.StorageWriteResponse, error)
- type MockStorageServiceServerMockRecorder
- func (mr *MockStorageServiceServerMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockStorageServiceServerMockRecorder) PreSignUrl(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockStorageServiceServerMockRecorder) Read(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockStorageServiceServerMockRecorder) Write(arg0, arg1 interface{}) *gomock.Call
- type MockTopicServiceClient
- type MockTopicServiceClientMockRecorder
- type MockTopicServiceServer
- type MockTopicServiceServerMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockClientConnInterface ¶
type MockClientConnInterface struct {
// contains filtered or unexported fields
}
MockClientConnInterface is a mock of ClientConnInterface interface.
func NewMockClientConnInterface ¶
func NewMockClientConnInterface(ctrl *gomock.Controller) *MockClientConnInterface
NewMockClientConnInterface creates a new mock instance.
func (*MockClientConnInterface) EXPECT ¶
func (m *MockClientConnInterface) EXPECT() *MockClientConnInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClientConnInterface) Invoke ¶
func (m *MockClientConnInterface) Invoke(arg0 context.Context, arg1 string, arg2, arg3 interface{}, arg4 ...grpc.CallOption) error
Invoke mocks base method.
func (*MockClientConnInterface) NewStream ¶
func (m *MockClientConnInterface) NewStream(arg0 context.Context, arg1 *grpc.StreamDesc, arg2 string, arg3 ...grpc.CallOption) (grpc.ClientStream, error)
NewStream mocks base method.
type MockClientConnInterfaceMockRecorder ¶
type MockClientConnInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockClientConnInterfaceMockRecorder is the mock recorder for MockClientConnInterface.
func (*MockClientConnInterfaceMockRecorder) Invoke ¶
func (mr *MockClientConnInterfaceMockRecorder) Invoke(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call
Invoke indicates an expected call of Invoke.
func (*MockClientConnInterfaceMockRecorder) NewStream ¶
func (mr *MockClientConnInterfaceMockRecorder) NewStream(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
NewStream indicates an expected call of NewStream.
type MockDocumentServiceClient ¶
type MockDocumentServiceClient struct {
// contains filtered or unexported fields
}
MockDocumentServiceClient is a mock of DocumentServiceClient interface.
func NewMockDocumentServiceClient ¶
func NewMockDocumentServiceClient(ctrl *gomock.Controller) *MockDocumentServiceClient
NewMockDocumentServiceClient creates a new mock instance.
func (*MockDocumentServiceClient) Delete ¶
func (m *MockDocumentServiceClient) Delete(arg0 context.Context, arg1 *v1.DocumentDeleteRequest, arg2 ...grpc.CallOption) (*v1.DocumentDeleteResponse, error)
Delete mocks base method.
func (*MockDocumentServiceClient) EXPECT ¶
func (m *MockDocumentServiceClient) EXPECT() *MockDocumentServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDocumentServiceClient) Get ¶
func (m *MockDocumentServiceClient) Get(arg0 context.Context, arg1 *v1.DocumentGetRequest, arg2 ...grpc.CallOption) (*v1.DocumentGetResponse, error)
Get mocks base method.
func (*MockDocumentServiceClient) Query ¶
func (m *MockDocumentServiceClient) Query(arg0 context.Context, arg1 *v1.DocumentQueryRequest, arg2 ...grpc.CallOption) (*v1.DocumentQueryResponse, error)
Query mocks base method.
func (*MockDocumentServiceClient) QueryStream ¶
func (m *MockDocumentServiceClient) QueryStream(arg0 context.Context, arg1 *v1.DocumentQueryStreamRequest, arg2 ...grpc.CallOption) (v1.DocumentService_QueryStreamClient, error)
QueryStream mocks base method.
func (*MockDocumentServiceClient) Set ¶
func (m *MockDocumentServiceClient) Set(arg0 context.Context, arg1 *v1.DocumentSetRequest, arg2 ...grpc.CallOption) (*v1.DocumentSetResponse, error)
Set mocks base method.
type MockDocumentServiceClientMockRecorder ¶
type MockDocumentServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDocumentServiceClientMockRecorder is the mock recorder for MockDocumentServiceClient.
func (*MockDocumentServiceClientMockRecorder) Delete ¶
func (mr *MockDocumentServiceClientMockRecorder) Delete(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockDocumentServiceClientMockRecorder) Get ¶
func (mr *MockDocumentServiceClientMockRecorder) Get(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockDocumentServiceClientMockRecorder) Query ¶
func (mr *MockDocumentServiceClientMockRecorder) Query(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Query indicates an expected call of Query.
func (*MockDocumentServiceClientMockRecorder) QueryStream ¶
func (mr *MockDocumentServiceClientMockRecorder) QueryStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
QueryStream indicates an expected call of QueryStream.
func (*MockDocumentServiceClientMockRecorder) Set ¶
func (mr *MockDocumentServiceClientMockRecorder) Set(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Set indicates an expected call of Set.
type MockDocumentServiceServer ¶
type MockDocumentServiceServer struct {
// contains filtered or unexported fields
}
MockDocumentServiceServer is a mock of DocumentServiceServer interface.
func NewMockDocumentServiceServer ¶
func NewMockDocumentServiceServer(ctrl *gomock.Controller) *MockDocumentServiceServer
NewMockDocumentServiceServer creates a new mock instance.
func (*MockDocumentServiceServer) Delete ¶
func (m *MockDocumentServiceServer) Delete(arg0 context.Context, arg1 *v1.DocumentDeleteRequest) (*v1.DocumentDeleteResponse, error)
Delete mocks base method.
func (*MockDocumentServiceServer) EXPECT ¶
func (m *MockDocumentServiceServer) EXPECT() *MockDocumentServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDocumentServiceServer) Get ¶
func (m *MockDocumentServiceServer) Get(arg0 context.Context, arg1 *v1.DocumentGetRequest) (*v1.DocumentGetResponse, error)
Get mocks base method.
func (*MockDocumentServiceServer) Query ¶
func (m *MockDocumentServiceServer) Query(arg0 context.Context, arg1 *v1.DocumentQueryRequest) (*v1.DocumentQueryResponse, error)
Query mocks base method.
func (*MockDocumentServiceServer) QueryStream ¶
func (m *MockDocumentServiceServer) QueryStream(arg0 *v1.DocumentQueryStreamRequest, arg1 v1.DocumentService_QueryStreamServer) error
QueryStream mocks base method.
func (*MockDocumentServiceServer) Set ¶
func (m *MockDocumentServiceServer) Set(arg0 context.Context, arg1 *v1.DocumentSetRequest) (*v1.DocumentSetResponse, error)
Set mocks base method.
type MockDocumentServiceServerMockRecorder ¶
type MockDocumentServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockDocumentServiceServerMockRecorder is the mock recorder for MockDocumentServiceServer.
func (*MockDocumentServiceServerMockRecorder) Delete ¶
func (mr *MockDocumentServiceServerMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockDocumentServiceServerMockRecorder) Get ¶
func (mr *MockDocumentServiceServerMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockDocumentServiceServerMockRecorder) Query ¶
func (mr *MockDocumentServiceServerMockRecorder) Query(arg0, arg1 interface{}) *gomock.Call
Query indicates an expected call of Query.
func (*MockDocumentServiceServerMockRecorder) QueryStream ¶
func (mr *MockDocumentServiceServerMockRecorder) QueryStream(arg0, arg1 interface{}) *gomock.Call
QueryStream indicates an expected call of QueryStream.
func (*MockDocumentServiceServerMockRecorder) Set ¶
func (mr *MockDocumentServiceServerMockRecorder) Set(arg0, arg1 interface{}) *gomock.Call
Set indicates an expected call of Set.
type MockDocumentService_QueryStreamClient ¶
type MockDocumentService_QueryStreamClient struct {
// contains filtered or unexported fields
}
MockDocumentService_QueryStreamClient is a mock of DocumentService_QueryStreamClient interface.
func NewMockDocumentService_QueryStreamClient ¶
func NewMockDocumentService_QueryStreamClient(ctrl *gomock.Controller) *MockDocumentService_QueryStreamClient
NewMockDocumentService_QueryStreamClient creates a new mock instance.
func (*MockDocumentService_QueryStreamClient) CloseSend ¶
func (m *MockDocumentService_QueryStreamClient) CloseSend() error
CloseSend mocks base method.
func (*MockDocumentService_QueryStreamClient) Context ¶
func (m *MockDocumentService_QueryStreamClient) Context() context.Context
Context mocks base method.
func (*MockDocumentService_QueryStreamClient) EXPECT ¶
func (m *MockDocumentService_QueryStreamClient) EXPECT() *MockDocumentService_QueryStreamClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDocumentService_QueryStreamClient) Header ¶
func (m *MockDocumentService_QueryStreamClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockDocumentService_QueryStreamClient) Recv ¶
func (m *MockDocumentService_QueryStreamClient) Recv() (*v1.DocumentQueryStreamResponse, error)
Recv mocks base method.
func (*MockDocumentService_QueryStreamClient) RecvMsg ¶
func (m *MockDocumentService_QueryStreamClient) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockDocumentService_QueryStreamClient) SendMsg ¶
func (m *MockDocumentService_QueryStreamClient) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockDocumentService_QueryStreamClient) Trailer ¶
func (m *MockDocumentService_QueryStreamClient) Trailer() metadata.MD
Trailer mocks base method.
type MockDocumentService_QueryStreamClientMockRecorder ¶
type MockDocumentService_QueryStreamClientMockRecorder struct {
// contains filtered or unexported fields
}
MockDocumentService_QueryStreamClientMockRecorder is the mock recorder for MockDocumentService_QueryStreamClient.
func (*MockDocumentService_QueryStreamClientMockRecorder) CloseSend ¶
func (mr *MockDocumentService_QueryStreamClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockDocumentService_QueryStreamClientMockRecorder) Context ¶
func (mr *MockDocumentService_QueryStreamClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDocumentService_QueryStreamClientMockRecorder) Header ¶
func (mr *MockDocumentService_QueryStreamClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockDocumentService_QueryStreamClientMockRecorder) Recv ¶
func (mr *MockDocumentService_QueryStreamClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockDocumentService_QueryStreamClientMockRecorder) RecvMsg ¶
func (mr *MockDocumentService_QueryStreamClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDocumentService_QueryStreamClientMockRecorder) SendMsg ¶
func (mr *MockDocumentService_QueryStreamClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDocumentService_QueryStreamClientMockRecorder) Trailer ¶
func (mr *MockDocumentService_QueryStreamClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockDocumentService_QueryStreamServer ¶
type MockDocumentService_QueryStreamServer struct {
// contains filtered or unexported fields
}
MockDocumentService_QueryStreamServer is a mock of DocumentService_QueryStreamServer interface.
func NewMockDocumentService_QueryStreamServer ¶
func NewMockDocumentService_QueryStreamServer(ctrl *gomock.Controller) *MockDocumentService_QueryStreamServer
NewMockDocumentService_QueryStreamServer creates a new mock instance.
func (*MockDocumentService_QueryStreamServer) Context ¶
func (m *MockDocumentService_QueryStreamServer) Context() context.Context
Context mocks base method.
func (*MockDocumentService_QueryStreamServer) EXPECT ¶
func (m *MockDocumentService_QueryStreamServer) EXPECT() *MockDocumentService_QueryStreamServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDocumentService_QueryStreamServer) RecvMsg ¶
func (m *MockDocumentService_QueryStreamServer) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockDocumentService_QueryStreamServer) Send ¶
func (m *MockDocumentService_QueryStreamServer) Send(arg0 *v1.DocumentQueryStreamResponse) error
Send mocks base method.
func (*MockDocumentService_QueryStreamServer) SendHeader ¶
func (m *MockDocumentService_QueryStreamServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockDocumentService_QueryStreamServer) SendMsg ¶
func (m *MockDocumentService_QueryStreamServer) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockDocumentService_QueryStreamServer) SetHeader ¶
func (m *MockDocumentService_QueryStreamServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockDocumentService_QueryStreamServer) SetTrailer ¶
func (m *MockDocumentService_QueryStreamServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockDocumentService_QueryStreamServerMockRecorder ¶
type MockDocumentService_QueryStreamServerMockRecorder struct {
// contains filtered or unexported fields
}
MockDocumentService_QueryStreamServerMockRecorder is the mock recorder for MockDocumentService_QueryStreamServer.
func (*MockDocumentService_QueryStreamServerMockRecorder) Context ¶
func (mr *MockDocumentService_QueryStreamServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockDocumentService_QueryStreamServerMockRecorder) RecvMsg ¶
func (mr *MockDocumentService_QueryStreamServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockDocumentService_QueryStreamServerMockRecorder) Send ¶
func (mr *MockDocumentService_QueryStreamServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockDocumentService_QueryStreamServerMockRecorder) SendHeader ¶
func (mr *MockDocumentService_QueryStreamServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockDocumentService_QueryStreamServerMockRecorder) SendMsg ¶
func (mr *MockDocumentService_QueryStreamServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockDocumentService_QueryStreamServerMockRecorder) SetHeader ¶
func (mr *MockDocumentService_QueryStreamServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockDocumentService_QueryStreamServerMockRecorder) SetTrailer ¶
func (mr *MockDocumentService_QueryStreamServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockEventServiceClient ¶
type MockEventServiceClient struct {
// contains filtered or unexported fields
}
MockEventServiceClient is a mock of EventServiceClient interface.
func NewMockEventServiceClient ¶
func NewMockEventServiceClient(ctrl *gomock.Controller) *MockEventServiceClient
NewMockEventServiceClient creates a new mock instance.
func (*MockEventServiceClient) EXPECT ¶
func (m *MockEventServiceClient) EXPECT() *MockEventServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockEventServiceClient) Publish ¶
func (m *MockEventServiceClient) Publish(arg0 context.Context, arg1 *v1.EventPublishRequest, arg2 ...grpc.CallOption) (*v1.EventPublishResponse, error)
Publish mocks base method.
type MockEventServiceClientMockRecorder ¶
type MockEventServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockEventServiceClientMockRecorder is the mock recorder for MockEventServiceClient.
func (*MockEventServiceClientMockRecorder) Publish ¶
func (mr *MockEventServiceClientMockRecorder) Publish(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Publish indicates an expected call of Publish.
type MockEventServiceServer ¶
type MockEventServiceServer struct {
// contains filtered or unexported fields
}
MockEventServiceServer is a mock of EventServiceServer interface.
func NewMockEventServiceServer ¶
func NewMockEventServiceServer(ctrl *gomock.Controller) *MockEventServiceServer
NewMockEventServiceServer creates a new mock instance.
func (*MockEventServiceServer) EXPECT ¶
func (m *MockEventServiceServer) EXPECT() *MockEventServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockEventServiceServer) Publish ¶
func (m *MockEventServiceServer) Publish(arg0 context.Context, arg1 *v1.EventPublishRequest) (*v1.EventPublishResponse, error)
Publish mocks base method.
type MockEventServiceServerMockRecorder ¶
type MockEventServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockEventServiceServerMockRecorder is the mock recorder for MockEventServiceServer.
func (*MockEventServiceServerMockRecorder) Publish ¶
func (mr *MockEventServiceServerMockRecorder) Publish(arg0, arg1 interface{}) *gomock.Call
Publish indicates an expected call of Publish.
type MockFaasServiceClient ¶
type MockFaasServiceClient struct {
// contains filtered or unexported fields
}
MockFaasServiceClient is a mock of FaasServiceClient interface.
func NewMockFaasServiceClient ¶
func NewMockFaasServiceClient(ctrl *gomock.Controller) *MockFaasServiceClient
NewMockFaasServiceClient creates a new mock instance.
func (*MockFaasServiceClient) EXPECT ¶
func (m *MockFaasServiceClient) EXPECT() *MockFaasServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockFaasServiceClient) TriggerStream ¶
func (m *MockFaasServiceClient) TriggerStream(arg0 context.Context, arg1 ...grpc.CallOption) (v1.FaasService_TriggerStreamClient, error)
TriggerStream mocks base method.
type MockFaasServiceClientMockRecorder ¶
type MockFaasServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockFaasServiceClientMockRecorder is the mock recorder for MockFaasServiceClient.
func (*MockFaasServiceClientMockRecorder) TriggerStream ¶
func (mr *MockFaasServiceClientMockRecorder) TriggerStream(arg0 interface{}, arg1 ...interface{}) *gomock.Call
TriggerStream indicates an expected call of TriggerStream.
type MockFaasServiceServer ¶
type MockFaasServiceServer struct {
// contains filtered or unexported fields
}
MockFaasServiceServer is a mock of FaasServiceServer interface.
func NewMockFaasServiceServer ¶
func NewMockFaasServiceServer(ctrl *gomock.Controller) *MockFaasServiceServer
NewMockFaasServiceServer creates a new mock instance.
func (*MockFaasServiceServer) EXPECT ¶
func (m *MockFaasServiceServer) EXPECT() *MockFaasServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockFaasServiceServer) TriggerStream ¶
func (m *MockFaasServiceServer) TriggerStream(arg0 v1.FaasService_TriggerStreamServer) error
TriggerStream mocks base method.
type MockFaasServiceServerMockRecorder ¶
type MockFaasServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockFaasServiceServerMockRecorder is the mock recorder for MockFaasServiceServer.
func (*MockFaasServiceServerMockRecorder) TriggerStream ¶
func (mr *MockFaasServiceServerMockRecorder) TriggerStream(arg0 interface{}) *gomock.Call
TriggerStream indicates an expected call of TriggerStream.
type MockFaasService_TriggerStreamClient ¶
type MockFaasService_TriggerStreamClient struct {
// contains filtered or unexported fields
}
MockFaasService_TriggerStreamClient is a mock of FaasService_TriggerStreamClient interface.
func NewMockFaasService_TriggerStreamClient ¶
func NewMockFaasService_TriggerStreamClient(ctrl *gomock.Controller) *MockFaasService_TriggerStreamClient
NewMockFaasService_TriggerStreamClient creates a new mock instance.
func (*MockFaasService_TriggerStreamClient) CloseSend ¶
func (m *MockFaasService_TriggerStreamClient) CloseSend() error
CloseSend mocks base method.
func (*MockFaasService_TriggerStreamClient) Context ¶
func (m *MockFaasService_TriggerStreamClient) Context() context.Context
Context mocks base method.
func (*MockFaasService_TriggerStreamClient) EXPECT ¶
func (m *MockFaasService_TriggerStreamClient) EXPECT() *MockFaasService_TriggerStreamClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockFaasService_TriggerStreamClient) Header ¶
func (m *MockFaasService_TriggerStreamClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockFaasService_TriggerStreamClient) Recv ¶
func (m *MockFaasService_TriggerStreamClient) Recv() (*v1.ServerMessage, error)
Recv mocks base method.
func (*MockFaasService_TriggerStreamClient) RecvMsg ¶
func (m *MockFaasService_TriggerStreamClient) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockFaasService_TriggerStreamClient) Send ¶
func (m *MockFaasService_TriggerStreamClient) Send(arg0 *v1.ClientMessage) error
Send mocks base method.
func (*MockFaasService_TriggerStreamClient) SendMsg ¶
func (m *MockFaasService_TriggerStreamClient) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockFaasService_TriggerStreamClient) Trailer ¶
func (m *MockFaasService_TriggerStreamClient) Trailer() metadata.MD
Trailer mocks base method.
type MockFaasService_TriggerStreamClientMockRecorder ¶
type MockFaasService_TriggerStreamClientMockRecorder struct {
// contains filtered or unexported fields
}
MockFaasService_TriggerStreamClientMockRecorder is the mock recorder for MockFaasService_TriggerStreamClient.
func (*MockFaasService_TriggerStreamClientMockRecorder) CloseSend ¶
func (mr *MockFaasService_TriggerStreamClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockFaasService_TriggerStreamClientMockRecorder) Context ¶
func (mr *MockFaasService_TriggerStreamClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockFaasService_TriggerStreamClientMockRecorder) Header ¶
func (mr *MockFaasService_TriggerStreamClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockFaasService_TriggerStreamClientMockRecorder) Recv ¶
func (mr *MockFaasService_TriggerStreamClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockFaasService_TriggerStreamClientMockRecorder) RecvMsg ¶
func (mr *MockFaasService_TriggerStreamClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockFaasService_TriggerStreamClientMockRecorder) Send ¶
func (mr *MockFaasService_TriggerStreamClientMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockFaasService_TriggerStreamClientMockRecorder) SendMsg ¶
func (mr *MockFaasService_TriggerStreamClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockFaasService_TriggerStreamClientMockRecorder) Trailer ¶
func (mr *MockFaasService_TriggerStreamClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockFaasService_TriggerStreamServer ¶
type MockFaasService_TriggerStreamServer struct {
// contains filtered or unexported fields
}
MockFaasService_TriggerStreamServer is a mock of FaasService_TriggerStreamServer interface.
func NewMockFaasService_TriggerStreamServer ¶
func NewMockFaasService_TriggerStreamServer(ctrl *gomock.Controller) *MockFaasService_TriggerStreamServer
NewMockFaasService_TriggerStreamServer creates a new mock instance.
func (*MockFaasService_TriggerStreamServer) Context ¶
func (m *MockFaasService_TriggerStreamServer) Context() context.Context
Context mocks base method.
func (*MockFaasService_TriggerStreamServer) EXPECT ¶
func (m *MockFaasService_TriggerStreamServer) EXPECT() *MockFaasService_TriggerStreamServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockFaasService_TriggerStreamServer) Recv ¶
func (m *MockFaasService_TriggerStreamServer) Recv() (*v1.ClientMessage, error)
Recv mocks base method.
func (*MockFaasService_TriggerStreamServer) RecvMsg ¶
func (m *MockFaasService_TriggerStreamServer) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockFaasService_TriggerStreamServer) Send ¶
func (m *MockFaasService_TriggerStreamServer) Send(arg0 *v1.ServerMessage) error
Send mocks base method.
func (*MockFaasService_TriggerStreamServer) SendHeader ¶
func (m *MockFaasService_TriggerStreamServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockFaasService_TriggerStreamServer) SendMsg ¶
func (m *MockFaasService_TriggerStreamServer) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockFaasService_TriggerStreamServer) SetHeader ¶
func (m *MockFaasService_TriggerStreamServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockFaasService_TriggerStreamServer) SetTrailer ¶
func (m *MockFaasService_TriggerStreamServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockFaasService_TriggerStreamServerMockRecorder ¶
type MockFaasService_TriggerStreamServerMockRecorder struct {
// contains filtered or unexported fields
}
MockFaasService_TriggerStreamServerMockRecorder is the mock recorder for MockFaasService_TriggerStreamServer.
func (*MockFaasService_TriggerStreamServerMockRecorder) Context ¶
func (mr *MockFaasService_TriggerStreamServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockFaasService_TriggerStreamServerMockRecorder) Recv ¶
func (mr *MockFaasService_TriggerStreamServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockFaasService_TriggerStreamServerMockRecorder) RecvMsg ¶
func (mr *MockFaasService_TriggerStreamServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockFaasService_TriggerStreamServerMockRecorder) Send ¶
func (mr *MockFaasService_TriggerStreamServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockFaasService_TriggerStreamServerMockRecorder) SendHeader ¶
func (mr *MockFaasService_TriggerStreamServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockFaasService_TriggerStreamServerMockRecorder) SendMsg ¶
func (mr *MockFaasService_TriggerStreamServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockFaasService_TriggerStreamServerMockRecorder) SetHeader ¶
func (mr *MockFaasService_TriggerStreamServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockFaasService_TriggerStreamServerMockRecorder) SetTrailer ¶
func (mr *MockFaasService_TriggerStreamServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockQueueServiceClient ¶
type MockQueueServiceClient struct {
// contains filtered or unexported fields
}
MockQueueServiceClient is a mock of QueueServiceClient interface.
func NewMockQueueServiceClient ¶
func NewMockQueueServiceClient(ctrl *gomock.Controller) *MockQueueServiceClient
NewMockQueueServiceClient creates a new mock instance.
func (*MockQueueServiceClient) Complete ¶
func (m *MockQueueServiceClient) Complete(arg0 context.Context, arg1 *v1.QueueCompleteRequest, arg2 ...grpc.CallOption) (*v1.QueueCompleteResponse, error)
Complete mocks base method.
func (*MockQueueServiceClient) EXPECT ¶
func (m *MockQueueServiceClient) EXPECT() *MockQueueServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockQueueServiceClient) Receive ¶
func (m *MockQueueServiceClient) Receive(arg0 context.Context, arg1 *v1.QueueReceiveRequest, arg2 ...grpc.CallOption) (*v1.QueueReceiveResponse, error)
Receive mocks base method.
func (*MockQueueServiceClient) Send ¶
func (m *MockQueueServiceClient) Send(arg0 context.Context, arg1 *v1.QueueSendRequest, arg2 ...grpc.CallOption) (*v1.QueueSendResponse, error)
Send mocks base method.
func (*MockQueueServiceClient) SendBatch ¶
func (m *MockQueueServiceClient) SendBatch(arg0 context.Context, arg1 *v1.QueueSendBatchRequest, arg2 ...grpc.CallOption) (*v1.QueueSendBatchResponse, error)
SendBatch mocks base method.
type MockQueueServiceClientMockRecorder ¶
type MockQueueServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockQueueServiceClientMockRecorder is the mock recorder for MockQueueServiceClient.
func (*MockQueueServiceClientMockRecorder) Complete ¶
func (mr *MockQueueServiceClientMockRecorder) Complete(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Complete indicates an expected call of Complete.
func (*MockQueueServiceClientMockRecorder) Receive ¶
func (mr *MockQueueServiceClientMockRecorder) Receive(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Receive indicates an expected call of Receive.
func (*MockQueueServiceClientMockRecorder) Send ¶
func (mr *MockQueueServiceClientMockRecorder) Send(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockQueueServiceClientMockRecorder) SendBatch ¶
func (mr *MockQueueServiceClientMockRecorder) SendBatch(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
SendBatch indicates an expected call of SendBatch.
type MockQueueServiceServer ¶
type MockQueueServiceServer struct {
// contains filtered or unexported fields
}
MockQueueServiceServer is a mock of QueueServiceServer interface.
func NewMockQueueServiceServer ¶
func NewMockQueueServiceServer(ctrl *gomock.Controller) *MockQueueServiceServer
NewMockQueueServiceServer creates a new mock instance.
func (*MockQueueServiceServer) Complete ¶
func (m *MockQueueServiceServer) Complete(arg0 context.Context, arg1 *v1.QueueCompleteRequest) (*v1.QueueCompleteResponse, error)
Complete mocks base method.
func (*MockQueueServiceServer) EXPECT ¶
func (m *MockQueueServiceServer) EXPECT() *MockQueueServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockQueueServiceServer) Receive ¶
func (m *MockQueueServiceServer) Receive(arg0 context.Context, arg1 *v1.QueueReceiveRequest) (*v1.QueueReceiveResponse, error)
Receive mocks base method.
func (*MockQueueServiceServer) Send ¶
func (m *MockQueueServiceServer) Send(arg0 context.Context, arg1 *v1.QueueSendRequest) (*v1.QueueSendResponse, error)
Send mocks base method.
func (*MockQueueServiceServer) SendBatch ¶
func (m *MockQueueServiceServer) SendBatch(arg0 context.Context, arg1 *v1.QueueSendBatchRequest) (*v1.QueueSendBatchResponse, error)
SendBatch mocks base method.
type MockQueueServiceServerMockRecorder ¶
type MockQueueServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockQueueServiceServerMockRecorder is the mock recorder for MockQueueServiceServer.
func (*MockQueueServiceServerMockRecorder) Complete ¶
func (mr *MockQueueServiceServerMockRecorder) Complete(arg0, arg1 interface{}) *gomock.Call
Complete indicates an expected call of Complete.
func (*MockQueueServiceServerMockRecorder) Receive ¶
func (mr *MockQueueServiceServerMockRecorder) Receive(arg0, arg1 interface{}) *gomock.Call
Receive indicates an expected call of Receive.
func (*MockQueueServiceServerMockRecorder) Send ¶
func (mr *MockQueueServiceServerMockRecorder) Send(arg0, arg1 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockQueueServiceServerMockRecorder) SendBatch ¶
func (mr *MockQueueServiceServerMockRecorder) SendBatch(arg0, arg1 interface{}) *gomock.Call
SendBatch indicates an expected call of SendBatch.
type MockResourceServiceClient ¶
type MockResourceServiceClient struct {
// contains filtered or unexported fields
}
MockResourceServiceClient is a mock of ResourceServiceClient interface.
func NewMockResourceServiceClient ¶
func NewMockResourceServiceClient(ctrl *gomock.Controller) *MockResourceServiceClient
NewMockResourceServiceClient creates a new mock instance.
func (*MockResourceServiceClient) Declare ¶
func (m *MockResourceServiceClient) Declare(arg0 context.Context, arg1 *v1.ResourceDeclareRequest, arg2 ...grpc.CallOption) (*v1.ResourceDeclareResponse, error)
Declare mocks base method.
func (*MockResourceServiceClient) EXPECT ¶
func (m *MockResourceServiceClient) EXPECT() *MockResourceServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockResourceServiceClientMockRecorder ¶
type MockResourceServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockResourceServiceClientMockRecorder is the mock recorder for MockResourceServiceClient.
func (*MockResourceServiceClientMockRecorder) Declare ¶
func (mr *MockResourceServiceClientMockRecorder) Declare(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Declare indicates an expected call of Declare.
type MockSecretServiceClient ¶
type MockSecretServiceClient struct {
// contains filtered or unexported fields
}
MockSecretServiceClient is a mock of SecretServiceClient interface.
func NewMockSecretServiceClient ¶
func NewMockSecretServiceClient(ctrl *gomock.Controller) *MockSecretServiceClient
NewMockSecretServiceClient creates a new mock instance.
func (*MockSecretServiceClient) Access ¶
func (m *MockSecretServiceClient) Access(arg0 context.Context, arg1 *v1.SecretAccessRequest, arg2 ...grpc.CallOption) (*v1.SecretAccessResponse, error)
Access mocks base method.
func (*MockSecretServiceClient) EXPECT ¶
func (m *MockSecretServiceClient) EXPECT() *MockSecretServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSecretServiceClient) Put ¶
func (m *MockSecretServiceClient) Put(arg0 context.Context, arg1 *v1.SecretPutRequest, arg2 ...grpc.CallOption) (*v1.SecretPutResponse, error)
Put mocks base method.
type MockSecretServiceClientMockRecorder ¶
type MockSecretServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockSecretServiceClientMockRecorder is the mock recorder for MockSecretServiceClient.
func (*MockSecretServiceClientMockRecorder) Access ¶
func (mr *MockSecretServiceClientMockRecorder) Access(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Access indicates an expected call of Access.
func (*MockSecretServiceClientMockRecorder) Put ¶
func (mr *MockSecretServiceClientMockRecorder) Put(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Put indicates an expected call of Put.
type MockSecretServiceServer ¶
type MockSecretServiceServer struct {
// contains filtered or unexported fields
}
MockSecretServiceServer is a mock of SecretServiceServer interface.
func NewMockSecretServiceServer ¶
func NewMockSecretServiceServer(ctrl *gomock.Controller) *MockSecretServiceServer
NewMockSecretServiceServer creates a new mock instance.
func (*MockSecretServiceServer) Access ¶
func (m *MockSecretServiceServer) Access(arg0 context.Context, arg1 *v1.SecretAccessRequest) (*v1.SecretAccessResponse, error)
Access mocks base method.
func (*MockSecretServiceServer) EXPECT ¶
func (m *MockSecretServiceServer) EXPECT() *MockSecretServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSecretServiceServer) Put ¶
func (m *MockSecretServiceServer) Put(arg0 context.Context, arg1 *v1.SecretPutRequest) (*v1.SecretPutResponse, error)
Put mocks base method.
type MockSecretServiceServerMockRecorder ¶
type MockSecretServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockSecretServiceServerMockRecorder is the mock recorder for MockSecretServiceServer.
func (*MockSecretServiceServerMockRecorder) Access ¶
func (mr *MockSecretServiceServerMockRecorder) Access(arg0, arg1 interface{}) *gomock.Call
Access indicates an expected call of Access.
func (*MockSecretServiceServerMockRecorder) Put ¶
func (mr *MockSecretServiceServerMockRecorder) Put(arg0, arg1 interface{}) *gomock.Call
Put indicates an expected call of Put.
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) Delete ¶
func (m *MockStorageServiceClient) Delete(arg0 context.Context, arg1 *v1.StorageDeleteRequest, arg2 ...grpc.CallOption) (*v1.StorageDeleteResponse, error)
Delete mocks base method.
func (*MockStorageServiceClient) EXPECT ¶
func (m *MockStorageServiceClient) EXPECT() *MockStorageServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockStorageServiceClient) PreSignUrl ¶
func (m *MockStorageServiceClient) PreSignUrl(arg0 context.Context, arg1 *v1.StoragePreSignUrlRequest, arg2 ...grpc.CallOption) (*v1.StoragePreSignUrlResponse, error)
PreSignUrl mocks base method.
func (*MockStorageServiceClient) Read ¶
func (m *MockStorageServiceClient) Read(arg0 context.Context, arg1 *v1.StorageReadRequest, arg2 ...grpc.CallOption) (*v1.StorageReadResponse, error)
Read mocks base method.
func (*MockStorageServiceClient) Write ¶
func (m *MockStorageServiceClient) Write(arg0 context.Context, arg1 *v1.StorageWriteRequest, arg2 ...grpc.CallOption) (*v1.StorageWriteResponse, error)
Write mocks base method.
type MockStorageServiceClientMockRecorder ¶
type MockStorageServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockStorageServiceClientMockRecorder is the mock recorder for MockStorageServiceClient.
func (*MockStorageServiceClientMockRecorder) Delete ¶
func (mr *MockStorageServiceClientMockRecorder) Delete(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockStorageServiceClientMockRecorder) PreSignUrl ¶
func (mr *MockStorageServiceClientMockRecorder) PreSignUrl(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
PreSignUrl indicates an expected call of PreSignUrl.
func (*MockStorageServiceClientMockRecorder) Read ¶
func (mr *MockStorageServiceClientMockRecorder) Read(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Read indicates an expected call of Read.
func (*MockStorageServiceClientMockRecorder) Write ¶
func (mr *MockStorageServiceClientMockRecorder) Write(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Write indicates an expected call of Write.
type MockStorageServiceServer ¶
type MockStorageServiceServer struct {
// contains filtered or unexported fields
}
MockStorageServiceServer is a mock of StorageServiceServer interface.
func NewMockStorageServiceServer ¶
func NewMockStorageServiceServer(ctrl *gomock.Controller) *MockStorageServiceServer
NewMockStorageServiceServer creates a new mock instance.
func (*MockStorageServiceServer) Delete ¶
func (m *MockStorageServiceServer) Delete(arg0 context.Context, arg1 *v1.StorageDeleteRequest) (*v1.StorageDeleteResponse, error)
Delete mocks base method.
func (*MockStorageServiceServer) EXPECT ¶
func (m *MockStorageServiceServer) EXPECT() *MockStorageServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockStorageServiceServer) PreSignUrl ¶
func (m *MockStorageServiceServer) PreSignUrl(arg0 context.Context, arg1 *v1.StoragePreSignUrlRequest) (*v1.StoragePreSignUrlResponse, error)
PreSignUrl mocks base method.
func (*MockStorageServiceServer) Read ¶
func (m *MockStorageServiceServer) Read(arg0 context.Context, arg1 *v1.StorageReadRequest) (*v1.StorageReadResponse, error)
Read mocks base method.
func (*MockStorageServiceServer) Write ¶
func (m *MockStorageServiceServer) Write(arg0 context.Context, arg1 *v1.StorageWriteRequest) (*v1.StorageWriteResponse, error)
Write mocks base method.
type MockStorageServiceServerMockRecorder ¶
type MockStorageServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockStorageServiceServerMockRecorder is the mock recorder for MockStorageServiceServer.
func (*MockStorageServiceServerMockRecorder) Delete ¶
func (mr *MockStorageServiceServerMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockStorageServiceServerMockRecorder) PreSignUrl ¶
func (mr *MockStorageServiceServerMockRecorder) PreSignUrl(arg0, arg1 interface{}) *gomock.Call
PreSignUrl indicates an expected call of PreSignUrl.
func (*MockStorageServiceServerMockRecorder) Read ¶
func (mr *MockStorageServiceServerMockRecorder) Read(arg0, arg1 interface{}) *gomock.Call
Read indicates an expected call of Read.
func (*MockStorageServiceServerMockRecorder) Write ¶
func (mr *MockStorageServiceServerMockRecorder) Write(arg0, arg1 interface{}) *gomock.Call
Write indicates an expected call of Write.
type MockTopicServiceClient ¶
type MockTopicServiceClient struct {
// contains filtered or unexported fields
}
MockTopicServiceClient is a mock of TopicServiceClient interface.
func NewMockTopicServiceClient ¶
func NewMockTopicServiceClient(ctrl *gomock.Controller) *MockTopicServiceClient
NewMockTopicServiceClient creates a new mock instance.
func (*MockTopicServiceClient) EXPECT ¶
func (m *MockTopicServiceClient) EXPECT() *MockTopicServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTopicServiceClient) List ¶
func (m *MockTopicServiceClient) List(arg0 context.Context, arg1 *v1.TopicListRequest, arg2 ...grpc.CallOption) (*v1.TopicListResponse, error)
List mocks base method.
type MockTopicServiceClientMockRecorder ¶
type MockTopicServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockTopicServiceClientMockRecorder is the mock recorder for MockTopicServiceClient.
func (*MockTopicServiceClientMockRecorder) List ¶
func (mr *MockTopicServiceClientMockRecorder) List(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
List indicates an expected call of List.
type MockTopicServiceServer ¶
type MockTopicServiceServer struct {
// contains filtered or unexported fields
}
MockTopicServiceServer is a mock of TopicServiceServer interface.
func NewMockTopicServiceServer ¶
func NewMockTopicServiceServer(ctrl *gomock.Controller) *MockTopicServiceServer
NewMockTopicServiceServer creates a new mock instance.
func (*MockTopicServiceServer) EXPECT ¶
func (m *MockTopicServiceServer) EXPECT() *MockTopicServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTopicServiceServer) List ¶
func (m *MockTopicServiceServer) List(arg0 context.Context, arg1 *v1.TopicListRequest) (*v1.TopicListResponse, error)
List mocks base method.
type MockTopicServiceServerMockRecorder ¶
type MockTopicServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockTopicServiceServerMockRecorder is the mock recorder for MockTopicServiceServer.
func (*MockTopicServiceServerMockRecorder) List ¶
func (mr *MockTopicServiceServerMockRecorder) List(arg0, arg1 interface{}) *gomock.Call
List indicates an expected call of List.