mock_v1

Oct 3, 2024

Changes in this version

+ type MockBatchClient struct

+ func NewMockBatchClient(ctrl *gomock.Controller) *MockBatchClient

+ func (m *MockBatchClient) EXPECT() *MockBatchClientMockRecorder

+ func (m *MockBatchClient) SubmitJob(arg0 context.Context, arg1 *batchpb.JobSubmitRequest, arg2 ...grpc.CallOption) (*batchpb.JobSubmitResponse, error)

+ type MockBatchClientMockRecorder struct

+ func (mr *MockBatchClientMockRecorder) SubmitJob(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

Jun 18, 2024

Changes in this version

+ type MockKvStoreClient struct

+ func NewMockKvStoreClient(ctrl *gomock.Controller) *MockKvStoreClient

+ func (m *MockKvStoreClient) DeleteKey(arg0 context.Context, arg1 *kvstorepb.KvStoreDeleteKeyRequest, ...) (*kvstorepb.KvStoreDeleteKeyResponse, error)

+ func (m *MockKvStoreClient) EXPECT() *MockKvStoreClientMockRecorder

+ func (m *MockKvStoreClient) GetValue(arg0 context.Context, arg1 *kvstorepb.KvStoreGetValueRequest, ...) (*kvstorepb.KvStoreGetValueResponse, error)

+ func (m *MockKvStoreClient) ScanKeys(arg0 context.Context, arg1 *kvstorepb.KvStoreScanKeysRequest, ...) (kvstorepb.KvStore_ScanKeysClient, error)

+ func (m *MockKvStoreClient) SetValue(arg0 context.Context, arg1 *kvstorepb.KvStoreSetValueRequest, ...) (*kvstorepb.KvStoreSetValueResponse, error)

+ type MockKvStoreClientMockRecorder struct

+ func (mr *MockKvStoreClientMockRecorder) DeleteKey(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockKvStoreClientMockRecorder) GetValue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockKvStoreClientMockRecorder) ScanKeys(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockKvStoreClientMockRecorder) SetValue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ type MockKvStore_ScanKeysClient struct

+ func NewMockKvStore_ScanKeysClient(ctrl *gomock.Controller) *MockKvStore_ScanKeysClient

+ func (m *MockKvStore_ScanKeysClient) CloseSend() error

+ func (m *MockKvStore_ScanKeysClient) Context() context.Context

+ func (m *MockKvStore_ScanKeysClient) EXPECT() *MockKvStore_ScanKeysClientMockRecorder

+ func (m *MockKvStore_ScanKeysClient) Header() (metadata.MD, error)

+ func (m *MockKvStore_ScanKeysClient) Recv() (*kvstorepb.KvStoreScanKeysResponse, error)

+ func (m *MockKvStore_ScanKeysClient) RecvMsg(arg0 interface{}) error

+ func (m *MockKvStore_ScanKeysClient) SendMsg(arg0 interface{}) error

+ func (m *MockKvStore_ScanKeysClient) Trailer() metadata.MD

+ type MockKvStore_ScanKeysClientMockRecorder struct

+ func (mr *MockKvStore_ScanKeysClientMockRecorder) CloseSend() *gomock.Call

+ func (mr *MockKvStore_ScanKeysClientMockRecorder) Context() *gomock.Call

+ func (mr *MockKvStore_ScanKeysClientMockRecorder) Header() *gomock.Call

+ func (mr *MockKvStore_ScanKeysClientMockRecorder) Recv() *gomock.Call

+ func (mr *MockKvStore_ScanKeysClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

+ func (mr *MockKvStore_ScanKeysClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

+ func (mr *MockKvStore_ScanKeysClientMockRecorder) Trailer() *gomock.Call

+ type MockQueuesClient struct

+ func NewMockQueuesClient(ctrl *gomock.Controller) *MockQueuesClient

+ func (m *MockQueuesClient) Complete(arg0 context.Context, arg1 *queuespb.QueueCompleteRequest, ...) (*queuespb.QueueCompleteResponse, error)

+ func (m *MockQueuesClient) Dequeue(arg0 context.Context, arg1 *queuespb.QueueDequeueRequest, ...) (*queuespb.QueueDequeueResponse, error)

+ func (m *MockQueuesClient) EXPECT() *MockQueuesClientMockRecorder

+ func (m *MockQueuesClient) Enqueue(arg0 context.Context, arg1 *queuespb.QueueEnqueueRequest, ...) (*queuespb.QueueEnqueueResponse, error)

+ type MockQueuesClientMockRecorder struct

+ func (mr *MockQueuesClientMockRecorder) Complete(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockQueuesClientMockRecorder) Dequeue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockQueuesClientMockRecorder) Enqueue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ type MockSecretManagerClient struct

+ func NewMockSecretManagerClient(ctrl *gomock.Controller) *MockSecretManagerClient

+ func (m *MockSecretManagerClient) Access(arg0 context.Context, arg1 *secretspb.SecretAccessRequest, ...) (*secretspb.SecretAccessResponse, error)

+ func (m *MockSecretManagerClient) EXPECT() *MockSecretManagerClientMockRecorder

+ func (m *MockSecretManagerClient) Put(arg0 context.Context, arg1 *secretspb.SecretPutRequest, ...) (*secretspb.SecretPutResponse, error)

+ type MockSecretManagerClientMockRecorder struct

+ func (mr *MockSecretManagerClientMockRecorder) Access(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockSecretManagerClientMockRecorder) Put(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ type MockStorageClient struct

+ func NewMockStorageClient(ctrl *gomock.Controller) *MockStorageClient

+ func (m *MockStorageClient) Delete(arg0 context.Context, arg1 *storagepb.StorageDeleteRequest, ...) (*storagepb.StorageDeleteResponse, error)

+ func (m *MockStorageClient) EXPECT() *MockStorageClientMockRecorder

+ func (m *MockStorageClient) Exists(arg0 context.Context, arg1 *storagepb.StorageExistsRequest, ...) (*storagepb.StorageExistsResponse, error)

+ func (m *MockStorageClient) ListBlobs(arg0 context.Context, arg1 *storagepb.StorageListBlobsRequest, ...) (*storagepb.StorageListBlobsResponse, error)

+ func (m *MockStorageClient) PreSignUrl(arg0 context.Context, arg1 *storagepb.StoragePreSignUrlRequest, ...) (*storagepb.StoragePreSignUrlResponse, error)

+ func (m *MockStorageClient) Read(arg0 context.Context, arg1 *storagepb.StorageReadRequest, ...) (*storagepb.StorageReadResponse, error)

+ func (m *MockStorageClient) Write(arg0 context.Context, arg1 *storagepb.StorageWriteRequest, ...) (*storagepb.StorageWriteResponse, error)

+ type MockStorageClientMockRecorder struct

+ func (mr *MockStorageClientMockRecorder) Delete(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockStorageClientMockRecorder) Exists(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockStorageClientMockRecorder) ListBlobs(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockStorageClientMockRecorder) PreSignUrl(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockStorageClientMockRecorder) Read(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockStorageClientMockRecorder) Write(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ type MockTopicsClient struct

+ func NewMockTopicsClient(ctrl *gomock.Controller) *MockTopicsClient

+ func (m *MockTopicsClient) EXPECT() *MockTopicsClientMockRecorder

+ func (m *MockTopicsClient) Publish(arg0 context.Context, arg1 *topicspb.TopicPublishRequest, ...) (*topicspb.TopicPublishResponse, error)

+ type MockTopicsClientMockRecorder struct

+ func (mr *MockTopicsClientMockRecorder) Publish(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

Aug 9, 2023

Changes in this version

+ type MockClientConnInterface struct

+ func NewMockClientConnInterface(ctrl *gomock.Controller) *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 struct

+ func (mr *MockClientConnInterfaceMockRecorder) Invoke(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call

+ func (mr *MockClientConnInterfaceMockRecorder) NewStream(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call

+ type MockDocumentServiceClient struct

+ func NewMockDocumentServiceClient(ctrl *gomock.Controller) *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 struct

+ 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 struct

+ func NewMockDocumentServiceServer(ctrl *gomock.Controller) *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 struct

+ 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 struct

+ func NewMockDocumentService_QueryStreamClient(ctrl *gomock.Controller) *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 struct

+ 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 struct

+ func NewMockDocumentService_QueryStreamServer(ctrl *gomock.Controller) *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 struct

+ 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 struct

+ func NewMockEventServiceClient(ctrl *gomock.Controller) *MockEventServiceClient

+ func (m *MockEventServiceClient) EXPECT() *MockEventServiceClientMockRecorder

+ func (m *MockEventServiceClient) Publish(arg0 context.Context, arg1 *v1.EventPublishRequest, arg2 ...grpc.CallOption) (*v1.EventPublishResponse, error)

+ type MockEventServiceClientMockRecorder struct

+ func (mr *MockEventServiceClientMockRecorder) Publish(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ type MockEventServiceServer struct

+ func NewMockEventServiceServer(ctrl *gomock.Controller) *MockEventServiceServer

+ func (m *MockEventServiceServer) EXPECT() *MockEventServiceServerMockRecorder

+ func (m *MockEventServiceServer) Publish(arg0 context.Context, arg1 *v1.EventPublishRequest) (*v1.EventPublishResponse, error)

+ type MockEventServiceServerMockRecorder struct

+ func (mr *MockEventServiceServerMockRecorder) Publish(arg0, arg1 interface{}) *gomock.Call

+ type MockFaasServiceClient struct

+ func NewMockFaasServiceClient(ctrl *gomock.Controller) *MockFaasServiceClient

+ func (m *MockFaasServiceClient) EXPECT() *MockFaasServiceClientMockRecorder

+ func (m *MockFaasServiceClient) TriggerStream(arg0 context.Context, arg1 ...grpc.CallOption) (v1.FaasService_TriggerStreamClient, error)

+ type MockFaasServiceClientMockRecorder struct

+ func (mr *MockFaasServiceClientMockRecorder) TriggerStream(arg0 interface{}, arg1 ...interface{}) *gomock.Call

+ type MockFaasServiceServer struct

+ func NewMockFaasServiceServer(ctrl *gomock.Controller) *MockFaasServiceServer

+ func (m *MockFaasServiceServer) EXPECT() *MockFaasServiceServerMockRecorder

+ func (m *MockFaasServiceServer) TriggerStream(arg0 v1.FaasService_TriggerStreamServer) error

+ type MockFaasServiceServerMockRecorder struct

+ func (mr *MockFaasServiceServerMockRecorder) TriggerStream(arg0 interface{}) *gomock.Call

+ type MockFaasService_TriggerStreamClient struct

+ func NewMockFaasService_TriggerStreamClient(ctrl *gomock.Controller) *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 struct

+ 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 struct

+ func NewMockFaasService_TriggerStreamServer(ctrl *gomock.Controller) *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 struct

+ 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 struct

+ func NewMockQueueServiceClient(ctrl *gomock.Controller) *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 struct

+ 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 struct

+ func NewMockQueueServiceServer(ctrl *gomock.Controller) *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 struct

+ 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 struct

+ func NewMockResourceServiceClient(ctrl *gomock.Controller) *MockResourceServiceClient

+ func (m *MockResourceServiceClient) Declare(arg0 context.Context, arg1 *v1.ResourceDeclareRequest, arg2 ...grpc.CallOption) (*v1.ResourceDeclareResponse, error)

+ func (m *MockResourceServiceClient) Details(arg0 context.Context, arg1 *v1.ResourceDetailsRequest, arg2 ...grpc.CallOption) (*v1.ResourceDetailsResponse, error)

+ func (m *MockResourceServiceClient) EXPECT() *MockResourceServiceClientMockRecorder

+ type MockResourceServiceClientMockRecorder struct

+ func (mr *MockResourceServiceClientMockRecorder) Declare(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockResourceServiceClientMockRecorder) Details(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ type MockSecretServiceClient struct

+ func NewMockSecretServiceClient(ctrl *gomock.Controller) *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 struct

+ func (mr *MockSecretServiceClientMockRecorder) Access(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockSecretServiceClientMockRecorder) Put(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ type MockSecretServiceServer struct

+ func NewMockSecretServiceServer(ctrl *gomock.Controller) *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 struct

+ func (mr *MockSecretServiceServerMockRecorder) Access(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSecretServiceServerMockRecorder) Put(arg0, arg1 interface{}) *gomock.Call

+ type MockStorageServiceClient struct

+ func NewMockStorageServiceClient(ctrl *gomock.Controller) *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) ListFiles(arg0 context.Context, arg1 *v1.StorageListFilesRequest, ...) (*v1.StorageListFilesResponse, error)

+ 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 struct

+ func (mr *MockStorageServiceClientMockRecorder) Delete(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ func (mr *MockStorageServiceClientMockRecorder) ListFiles(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 struct

+ func NewMockStorageServiceServer(ctrl *gomock.Controller) *MockStorageServiceServer

+ func (m *MockStorageServiceServer) Delete(arg0 context.Context, arg1 *v1.StorageDeleteRequest) (*v1.StorageDeleteResponse, error)

+ func (m *MockStorageServiceServer) EXPECT() *MockStorageServiceServerMockRecorder

+ func (m *MockStorageServiceServer) ListFiles(arg0 context.Context, arg1 *v1.StorageListFilesRequest) (*v1.StorageListFilesResponse, error)

+ 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 struct

+ func (mr *MockStorageServiceServerMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockStorageServiceServerMockRecorder) ListFiles(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 struct

+ func NewMockTopicServiceClient(ctrl *gomock.Controller) *MockTopicServiceClient

+ func (m *MockTopicServiceClient) EXPECT() *MockTopicServiceClientMockRecorder

+ func (m *MockTopicServiceClient) List(arg0 context.Context, arg1 *v1.TopicListRequest, arg2 ...grpc.CallOption) (*v1.TopicListResponse, error)

+ type MockTopicServiceClientMockRecorder struct

+ func (mr *MockTopicServiceClientMockRecorder) List(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

+ type MockTopicServiceServer struct

+ func NewMockTopicServiceServer(ctrl *gomock.Controller) *MockTopicServiceServer

+ func (m *MockTopicServiceServer) EXPECT() *MockTopicServiceServerMockRecorder

+ func (m *MockTopicServiceServer) List(arg0 context.Context, arg1 *v1.TopicListRequest) (*v1.TopicListResponse, error)

+ type MockTopicServiceServerMockRecorder struct

+ func (mr *MockTopicServiceServerMockRecorder) List(arg0, arg1 interface{}) *gomock.Call