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.
Package mock_v1 is a generated GoMock package.
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 MockBatchClient
- type MockBatchClientMockRecorder
- 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 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
- 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
- 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
- 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
- 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
- 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
- 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
- type 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
- 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
- type MockTopicsClientMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockBatchClient ¶ added in v1.1.0
type MockBatchClient struct {
// contains filtered or unexported fields
}
MockBatchClient is a mock of BatchClient interface.
func NewMockBatchClient ¶ added in v1.1.0
func NewMockBatchClient(ctrl *gomock.Controller) *MockBatchClient
NewMockBatchClient creates a new mock instance.
func (*MockBatchClient) EXPECT ¶ added in v1.1.0
func (m *MockBatchClient) EXPECT() *MockBatchClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockBatchClient) SubmitJob ¶ added in v1.1.0
func (m *MockBatchClient) SubmitJob(arg0 context.Context, arg1 *batchpb.JobSubmitRequest, arg2 ...grpc.CallOption) (*batchpb.JobSubmitResponse, error)
SubmitJob mocks base method.
type MockBatchClientMockRecorder ¶ added in v1.1.0
type MockBatchClientMockRecorder struct {
// contains filtered or unexported fields
}
MockBatchClientMockRecorder is the mock recorder for MockBatchClient.
func (*MockBatchClientMockRecorder) SubmitJob ¶ added in v1.1.0
func (mr *MockBatchClientMockRecorder) SubmitJob(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
SubmitJob indicates an expected call of SubmitJob.
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 MockKvStoreClient ¶ added in v1.0.0
type MockKvStoreClient struct {
// contains filtered or unexported fields
}
MockKvStoreClient is a mock of KvStoreClient interface.
func NewMockKvStoreClient ¶ added in v1.0.0
func NewMockKvStoreClient(ctrl *gomock.Controller) *MockKvStoreClient
NewMockKvStoreClient creates a new mock instance.
func (*MockKvStoreClient) DeleteKey ¶ added in v1.0.0
func (m *MockKvStoreClient) DeleteKey(arg0 context.Context, arg1 *kvstorepb.KvStoreDeleteKeyRequest, arg2 ...grpc.CallOption) (*kvstorepb.KvStoreDeleteKeyResponse, error)
DeleteKey mocks base method.
func (*MockKvStoreClient) EXPECT ¶ added in v1.0.0
func (m *MockKvStoreClient) EXPECT() *MockKvStoreClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockKvStoreClient) GetValue ¶ added in v1.0.0
func (m *MockKvStoreClient) GetValue(arg0 context.Context, arg1 *kvstorepb.KvStoreGetValueRequest, arg2 ...grpc.CallOption) (*kvstorepb.KvStoreGetValueResponse, error)
GetValue mocks base method.
func (*MockKvStoreClient) ScanKeys ¶ added in v1.0.0
func (m *MockKvStoreClient) ScanKeys(arg0 context.Context, arg1 *kvstorepb.KvStoreScanKeysRequest, arg2 ...grpc.CallOption) (kvstorepb.KvStore_ScanKeysClient, error)
ScanKeys mocks base method.
func (*MockKvStoreClient) SetValue ¶ added in v1.0.0
func (m *MockKvStoreClient) SetValue(arg0 context.Context, arg1 *kvstorepb.KvStoreSetValueRequest, arg2 ...grpc.CallOption) (*kvstorepb.KvStoreSetValueResponse, error)
SetValue mocks base method.
type MockKvStoreClientMockRecorder ¶ added in v1.0.0
type MockKvStoreClientMockRecorder struct {
// contains filtered or unexported fields
}
MockKvStoreClientMockRecorder is the mock recorder for MockKvStoreClient.
func (*MockKvStoreClientMockRecorder) DeleteKey ¶ added in v1.0.0
func (mr *MockKvStoreClientMockRecorder) DeleteKey(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DeleteKey indicates an expected call of DeleteKey.
func (*MockKvStoreClientMockRecorder) GetValue ¶ added in v1.0.0
func (mr *MockKvStoreClientMockRecorder) GetValue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
GetValue indicates an expected call of GetValue.
func (*MockKvStoreClientMockRecorder) ScanKeys ¶ added in v1.0.0
func (mr *MockKvStoreClientMockRecorder) ScanKeys(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ScanKeys indicates an expected call of ScanKeys.
func (*MockKvStoreClientMockRecorder) SetValue ¶ added in v1.0.0
func (mr *MockKvStoreClientMockRecorder) SetValue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
SetValue indicates an expected call of SetValue.
type MockKvStore_ScanKeysClient ¶ added in v1.0.0
type MockKvStore_ScanKeysClient struct {
// contains filtered or unexported fields
}
MockKvStore_ScanKeysClient is a mock of KvStore_ScanKeysClient interface.
func NewMockKvStore_ScanKeysClient ¶ added in v1.0.0
func NewMockKvStore_ScanKeysClient(ctrl *gomock.Controller) *MockKvStore_ScanKeysClient
NewMockKvStore_ScanKeysClient creates a new mock instance.
func (*MockKvStore_ScanKeysClient) CloseSend ¶ added in v1.0.0
func (m *MockKvStore_ScanKeysClient) CloseSend() error
CloseSend mocks base method.
func (*MockKvStore_ScanKeysClient) Context ¶ added in v1.0.0
func (m *MockKvStore_ScanKeysClient) Context() context.Context
Context mocks base method.
func (*MockKvStore_ScanKeysClient) EXPECT ¶ added in v1.0.0
func (m *MockKvStore_ScanKeysClient) EXPECT() *MockKvStore_ScanKeysClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockKvStore_ScanKeysClient) Header ¶ added in v1.0.0
func (m *MockKvStore_ScanKeysClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockKvStore_ScanKeysClient) Recv ¶ added in v1.0.0
func (m *MockKvStore_ScanKeysClient) Recv() (*kvstorepb.KvStoreScanKeysResponse, error)
Recv mocks base method.
func (*MockKvStore_ScanKeysClient) RecvMsg ¶ added in v1.0.0
func (m *MockKvStore_ScanKeysClient) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockKvStore_ScanKeysClient) SendMsg ¶ added in v1.0.0
func (m *MockKvStore_ScanKeysClient) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockKvStore_ScanKeysClient) Trailer ¶ added in v1.0.0
func (m *MockKvStore_ScanKeysClient) Trailer() metadata.MD
Trailer mocks base method.
type MockKvStore_ScanKeysClientMockRecorder ¶ added in v1.0.0
type MockKvStore_ScanKeysClientMockRecorder struct {
// contains filtered or unexported fields
}
MockKvStore_ScanKeysClientMockRecorder is the mock recorder for MockKvStore_ScanKeysClient.
func (*MockKvStore_ScanKeysClientMockRecorder) CloseSend ¶ added in v1.0.0
func (mr *MockKvStore_ScanKeysClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockKvStore_ScanKeysClientMockRecorder) Context ¶ added in v1.0.0
func (mr *MockKvStore_ScanKeysClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockKvStore_ScanKeysClientMockRecorder) Header ¶ added in v1.0.0
func (mr *MockKvStore_ScanKeysClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockKvStore_ScanKeysClientMockRecorder) Recv ¶ added in v1.0.0
func (mr *MockKvStore_ScanKeysClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockKvStore_ScanKeysClientMockRecorder) RecvMsg ¶ added in v1.0.0
func (mr *MockKvStore_ScanKeysClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockKvStore_ScanKeysClientMockRecorder) SendMsg ¶ added in v1.0.0
func (mr *MockKvStore_ScanKeysClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockKvStore_ScanKeysClientMockRecorder) Trailer ¶ added in v1.0.0
func (mr *MockKvStore_ScanKeysClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockQueuesClient ¶ added in v1.0.0
type MockQueuesClient struct {
// contains filtered or unexported fields
}
MockQueuesClient is a mock of QueuesClient interface.
func NewMockQueuesClient ¶ added in v1.0.0
func NewMockQueuesClient(ctrl *gomock.Controller) *MockQueuesClient
NewMockQueuesClient creates a new mock instance.
func (*MockQueuesClient) Complete ¶ added in v1.0.0
func (m *MockQueuesClient) Complete(arg0 context.Context, arg1 *queuespb.QueueCompleteRequest, arg2 ...grpc.CallOption) (*queuespb.QueueCompleteResponse, error)
Complete mocks base method.
func (*MockQueuesClient) Dequeue ¶ added in v1.0.0
func (m *MockQueuesClient) Dequeue(arg0 context.Context, arg1 *queuespb.QueueDequeueRequest, arg2 ...grpc.CallOption) (*queuespb.QueueDequeueResponse, error)
Dequeue mocks base method.
func (*MockQueuesClient) EXPECT ¶ added in v1.0.0
func (m *MockQueuesClient) EXPECT() *MockQueuesClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockQueuesClient) Enqueue ¶ added in v1.0.0
func (m *MockQueuesClient) Enqueue(arg0 context.Context, arg1 *queuespb.QueueEnqueueRequest, arg2 ...grpc.CallOption) (*queuespb.QueueEnqueueResponse, error)
Enqueue mocks base method.
type MockQueuesClientMockRecorder ¶ added in v1.0.0
type MockQueuesClientMockRecorder struct {
// contains filtered or unexported fields
}
MockQueuesClientMockRecorder is the mock recorder for MockQueuesClient.
func (*MockQueuesClientMockRecorder) Complete ¶ added in v1.0.0
func (mr *MockQueuesClientMockRecorder) Complete(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Complete indicates an expected call of Complete.
func (*MockQueuesClientMockRecorder) Dequeue ¶ added in v1.0.0
func (mr *MockQueuesClientMockRecorder) Dequeue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Dequeue indicates an expected call of Dequeue.
func (*MockQueuesClientMockRecorder) Enqueue ¶ added in v1.0.0
func (mr *MockQueuesClientMockRecorder) Enqueue(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Enqueue indicates an expected call of Enqueue.
type MockSecretManagerClient ¶ added in v1.0.0
type MockSecretManagerClient struct {
// contains filtered or unexported fields
}
MockSecretManagerClient is a mock of SecretManagerClient interface.
func NewMockSecretManagerClient ¶ added in v1.0.0
func NewMockSecretManagerClient(ctrl *gomock.Controller) *MockSecretManagerClient
NewMockSecretManagerClient creates a new mock instance.
func (*MockSecretManagerClient) Access ¶ added in v1.0.0
func (m *MockSecretManagerClient) Access(arg0 context.Context, arg1 *secretspb.SecretAccessRequest, arg2 ...grpc.CallOption) (*secretspb.SecretAccessResponse, error)
Access mocks base method.
func (*MockSecretManagerClient) EXPECT ¶ added in v1.0.0
func (m *MockSecretManagerClient) EXPECT() *MockSecretManagerClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSecretManagerClient) Put ¶ added in v1.0.0
func (m *MockSecretManagerClient) Put(arg0 context.Context, arg1 *secretspb.SecretPutRequest, arg2 ...grpc.CallOption) (*secretspb.SecretPutResponse, error)
Put mocks base method.
type MockSecretManagerClientMockRecorder ¶ added in v1.0.0
type MockSecretManagerClientMockRecorder struct {
// contains filtered or unexported fields
}
MockSecretManagerClientMockRecorder is the mock recorder for MockSecretManagerClient.
func (*MockSecretManagerClientMockRecorder) Access ¶ added in v1.0.0
func (mr *MockSecretManagerClientMockRecorder) Access(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Access indicates an expected call of Access.
func (*MockSecretManagerClientMockRecorder) Put ¶ added in v1.0.0
func (mr *MockSecretManagerClientMockRecorder) Put(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Put indicates an expected call of Put.
type MockStorageClient ¶ added in v1.0.0
type MockStorageClient struct {
// contains filtered or unexported fields
}
MockStorageClient is a mock of StorageClient interface.
func NewMockStorageClient ¶ added in v1.0.0
func NewMockStorageClient(ctrl *gomock.Controller) *MockStorageClient
NewMockStorageClient creates a new mock instance.
func (*MockStorageClient) Delete ¶ added in v1.0.0
func (m *MockStorageClient) Delete(arg0 context.Context, arg1 *storagepb.StorageDeleteRequest, arg2 ...grpc.CallOption) (*storagepb.StorageDeleteResponse, error)
Delete mocks base method.
func (*MockStorageClient) EXPECT ¶ added in v1.0.0
func (m *MockStorageClient) EXPECT() *MockStorageClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockStorageClient) Exists ¶ added in v1.0.0
func (m *MockStorageClient) Exists(arg0 context.Context, arg1 *storagepb.StorageExistsRequest, arg2 ...grpc.CallOption) (*storagepb.StorageExistsResponse, error)
Exists mocks base method.
func (*MockStorageClient) ListBlobs ¶ added in v1.0.0
func (m *MockStorageClient) ListBlobs(arg0 context.Context, arg1 *storagepb.StorageListBlobsRequest, arg2 ...grpc.CallOption) (*storagepb.StorageListBlobsResponse, error)
ListBlobs mocks base method.
func (*MockStorageClient) PreSignUrl ¶ added in v1.0.0
func (m *MockStorageClient) PreSignUrl(arg0 context.Context, arg1 *storagepb.StoragePreSignUrlRequest, arg2 ...grpc.CallOption) (*storagepb.StoragePreSignUrlResponse, error)
PreSignUrl mocks base method.
func (*MockStorageClient) Read ¶ added in v1.0.0
func (m *MockStorageClient) Read(arg0 context.Context, arg1 *storagepb.StorageReadRequest, arg2 ...grpc.CallOption) (*storagepb.StorageReadResponse, error)
Read mocks base method.
func (*MockStorageClient) Write ¶ added in v1.0.0
func (m *MockStorageClient) Write(arg0 context.Context, arg1 *storagepb.StorageWriteRequest, arg2 ...grpc.CallOption) (*storagepb.StorageWriteResponse, error)
Write mocks base method.
type MockStorageClientMockRecorder ¶ added in v1.0.0
type MockStorageClientMockRecorder struct {
// contains filtered or unexported fields
}
MockStorageClientMockRecorder is the mock recorder for MockStorageClient.
func (*MockStorageClientMockRecorder) Delete ¶ added in v1.0.0
func (mr *MockStorageClientMockRecorder) Delete(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockStorageClientMockRecorder) Exists ¶ added in v1.0.0
func (mr *MockStorageClientMockRecorder) Exists(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Exists indicates an expected call of Exists.
func (*MockStorageClientMockRecorder) ListBlobs ¶ added in v1.0.0
func (mr *MockStorageClientMockRecorder) ListBlobs(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListBlobs indicates an expected call of ListBlobs.
func (*MockStorageClientMockRecorder) PreSignUrl ¶ added in v1.0.0
func (mr *MockStorageClientMockRecorder) PreSignUrl(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
PreSignUrl indicates an expected call of PreSignUrl.
func (*MockStorageClientMockRecorder) Read ¶ added in v1.0.0
func (mr *MockStorageClientMockRecorder) Read(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Read indicates an expected call of Read.
func (*MockStorageClientMockRecorder) Write ¶ added in v1.0.0
func (mr *MockStorageClientMockRecorder) Write(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Write indicates an expected call of Write.
type MockTopicsClient ¶ added in v1.0.0
type MockTopicsClient struct {
// contains filtered or unexported fields
}
MockTopicsClient is a mock of TopicsClient interface.
func NewMockTopicsClient ¶ added in v1.0.0
func NewMockTopicsClient(ctrl *gomock.Controller) *MockTopicsClient
NewMockTopicsClient creates a new mock instance.
func (*MockTopicsClient) EXPECT ¶ added in v1.0.0
func (m *MockTopicsClient) EXPECT() *MockTopicsClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTopicsClient) Publish ¶ added in v1.0.0
func (m *MockTopicsClient) Publish(arg0 context.Context, arg1 *topicspb.TopicPublishRequest, arg2 ...grpc.CallOption) (*topicspb.TopicPublishResponse, error)
Publish mocks base method.
type MockTopicsClientMockRecorder ¶ added in v1.0.0
type MockTopicsClientMockRecorder struct {
// contains filtered or unexported fields
}
MockTopicsClientMockRecorder is the mock recorder for MockTopicsClient.
func (*MockTopicsClientMockRecorder) Publish ¶ added in v1.0.0
func (mr *MockTopicsClientMockRecorder) Publish(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Publish indicates an expected call of Publish.