blob: a8af3e97bebe3c3de8c19be0f39f2b6a9516e0bb [file] [log] [blame]
// Code generated by MockGen. DO NOT EDIT.
// Source: client.go
// Package pubsub is a generated GoMock package.
package pubsub
import (
context "context"
reflect "reflect"
iam "cloud.google.com/go/iam"
pubsub "cloud.google.com/go/pubsub"
gomock "github.com/golang/mock/gomock"
)
// MockPubsubClient is a mock of PubsubClient interface.
type MockPubsubClient struct {
ctrl *gomock.Controller
recorder *MockPubsubClientMockRecorder
}
// MockPubsubClientMockRecorder is the mock recorder for MockPubsubClient.
type MockPubsubClientMockRecorder struct {
mock *MockPubsubClient
}
// NewMockPubsubClient creates a new mock instance.
func NewMockPubsubClient(ctrl *gomock.Controller) *MockPubsubClient {
mock := &MockPubsubClient{ctrl: ctrl}
mock.recorder = &MockPubsubClientMockRecorder{mock}
return mock
}
// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockPubsubClient) EXPECT() *MockPubsubClientMockRecorder {
return m.recorder
}
// Close mocks base method.
func (m *MockPubsubClient) Close() error {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "Close")
ret0, _ := ret[0].(error)
return ret0
}
// Close indicates an expected call of Close.
func (mr *MockPubsubClientMockRecorder) Close() *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Close", reflect.TypeOf((*MockPubsubClient)(nil).Close))
}
// GetIAMPolicy mocks base method.
func (m *MockPubsubClient) GetIAMPolicy(ctx context.Context) (*iam.Policy, error) {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "GetIAMPolicy", ctx)
ret0, _ := ret[0].(*iam.Policy)
ret1, _ := ret[1].(error)
return ret0, ret1
}
// GetIAMPolicy indicates an expected call of GetIAMPolicy.
func (mr *MockPubsubClientMockRecorder) GetIAMPolicy(ctx interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetIAMPolicy", reflect.TypeOf((*MockPubsubClient)(nil).GetIAMPolicy), ctx)
}
// Publish mocks base method.
func (m *MockPubsubClient) Publish(ctx context.Context, msg *pubsub.Message) error {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "Publish", ctx, msg)
ret0, _ := ret[0].(error)
return ret0
}
// Publish indicates an expected call of Publish.
func (mr *MockPubsubClientMockRecorder) Publish(ctx, msg interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Publish", reflect.TypeOf((*MockPubsubClient)(nil).Publish), ctx, msg)
}
// SetIAMPolicy mocks base method.
func (m *MockPubsubClient) SetIAMPolicy(ctx context.Context, policy *iam.Policy) error {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "SetIAMPolicy", ctx, policy)
ret0, _ := ret[0].(error)
return ret0
}
// SetIAMPolicy indicates an expected call of SetIAMPolicy.
func (mr *MockPubsubClientMockRecorder) SetIAMPolicy(ctx, policy interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetIAMPolicy", reflect.TypeOf((*MockPubsubClient)(nil).SetIAMPolicy), ctx, policy)
}