Documentation
¶
Overview ¶
Package pubsub is a generated GoMock package.
Package pubsub is a generated GoMock package.
Index ¶
- type MockPublisher
- func (m *MockPublisher) CreateTopic(ctx context.Context, topicID string) (*pubsub.Topic, error)
- func (m *MockPublisher) DeleteTopic(ctx context.Context, topicID string) error
- func (m *MockPublisher) EXPECT() *MockPublisherMockRecorder
- func (m *MockPublisher) Init(ctx context.Context, projectID string) error
- func (m *MockPublisher) PublishSampleMessage(ctx context.Context, topicID string) error
- type MockPublisherMockRecorder
- func (mr *MockPublisherMockRecorder) CreateTopic(ctx, topicID interface{}) *gomock.Call
- func (mr *MockPublisherMockRecorder) DeleteTopic(ctx, topicID interface{}) *gomock.Call
- func (mr *MockPublisherMockRecorder) Init(ctx, projectID interface{}) *gomock.Call
- func (mr *MockPublisherMockRecorder) PublishSampleMessage(ctx, topicID interface{}) *gomock.Call
- type MockSubscriber
- func (m *MockSubscriber) CreateSubscription(ctx context.Context, subscriptionID, topicID string) (*pubsub.Subscription, error)
- func (m *MockSubscriber) EXPECT() *MockSubscriberMockRecorder
- func (m *MockSubscriber) Init(ctx context.Context, projectID string) error
- func (m *MockSubscriber) ReceiveSampleMessages(ctx context.Context, subscriptionID string) error
- type MockSubscriberMockRecorder
- func (mr *MockSubscriberMockRecorder) CreateSubscription(ctx, subscriptionID, topicID interface{}) *gomock.Call
- func (mr *MockSubscriberMockRecorder) Init(ctx, projectID interface{}) *gomock.Call
- func (mr *MockSubscriberMockRecorder) ReceiveSampleMessages(ctx, subscriptionID interface{}) *gomock.Call
- type Publisher
- type Subscriber
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockPublisher ¶
type MockPublisher struct {
// contains filtered or unexported fields
}
MockPublisher is a mock of Publisher interface
func NewMockPublisher ¶
func NewMockPublisher(ctrl *gomock.Controller) *MockPublisher
NewMockPublisher creates a new mock instance
func (*MockPublisher) CreateTopic ¶
CreateTopic mocks base method
func (*MockPublisher) DeleteTopic ¶
func (m *MockPublisher) DeleteTopic(ctx context.Context, topicID string) error
DeleteTopic mocks base method
func (*MockPublisher) EXPECT ¶
func (m *MockPublisher) EXPECT() *MockPublisherMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockPublisher) Init ¶
func (m *MockPublisher) Init(ctx context.Context, projectID string) error
Init mocks base method
func (*MockPublisher) PublishSampleMessage ¶
func (m *MockPublisher) PublishSampleMessage(ctx context.Context, topicID string) error
PublishSampleMessage mocks base method
type MockPublisherMockRecorder ¶
type MockPublisherMockRecorder struct {
// contains filtered or unexported fields
}
MockPublisherMockRecorder is the mock recorder for MockPublisher
func (*MockPublisherMockRecorder) CreateTopic ¶
func (mr *MockPublisherMockRecorder) CreateTopic(ctx, topicID interface{}) *gomock.Call
CreateTopic indicates an expected call of CreateTopic
func (*MockPublisherMockRecorder) DeleteTopic ¶
func (mr *MockPublisherMockRecorder) DeleteTopic(ctx, topicID interface{}) *gomock.Call
DeleteTopic indicates an expected call of DeleteTopic
func (*MockPublisherMockRecorder) Init ¶
func (mr *MockPublisherMockRecorder) Init(ctx, projectID interface{}) *gomock.Call
Init indicates an expected call of Init
func (*MockPublisherMockRecorder) PublishSampleMessage ¶
func (mr *MockPublisherMockRecorder) PublishSampleMessage(ctx, topicID interface{}) *gomock.Call
PublishSampleMessage indicates an expected call of PublishSampleMessage
type MockSubscriber ¶
type MockSubscriber struct {
// contains filtered or unexported fields
}
MockSubscriber is a mock of Subscriber interface
func NewMockSubscriber ¶
func NewMockSubscriber(ctrl *gomock.Controller) *MockSubscriber
NewMockSubscriber creates a new mock instance
func (*MockSubscriber) CreateSubscription ¶
func (m *MockSubscriber) CreateSubscription(ctx context.Context, subscriptionID, topicID string) (*pubsub.Subscription, error)
CreateSubscription mocks base method
func (*MockSubscriber) EXPECT ¶
func (m *MockSubscriber) EXPECT() *MockSubscriberMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockSubscriber) Init ¶
func (m *MockSubscriber) Init(ctx context.Context, projectID string) error
Init mocks base method
func (*MockSubscriber) ReceiveSampleMessages ¶
func (m *MockSubscriber) ReceiveSampleMessages(ctx context.Context, subscriptionID string) error
ReceiveSampleMessages mocks base method
type MockSubscriberMockRecorder ¶
type MockSubscriberMockRecorder struct {
// contains filtered or unexported fields
}
MockSubscriberMockRecorder is the mock recorder for MockSubscriber
func (*MockSubscriberMockRecorder) CreateSubscription ¶
func (mr *MockSubscriberMockRecorder) CreateSubscription(ctx, subscriptionID, topicID interface{}) *gomock.Call
CreateSubscription indicates an expected call of CreateSubscription
func (*MockSubscriberMockRecorder) Init ¶
func (mr *MockSubscriberMockRecorder) Init(ctx, projectID interface{}) *gomock.Call
Init indicates an expected call of Init
func (*MockSubscriberMockRecorder) ReceiveSampleMessages ¶
func (mr *MockSubscriberMockRecorder) ReceiveSampleMessages(ctx, subscriptionID interface{}) *gomock.Call
ReceiveSampleMessages indicates an expected call of ReceiveSampleMessages
type Publisher ¶
type Publisher interface {
CreateTopic(ctx context.Context, topicID string) (*pubsub.Topic, error)
DeleteTopic(ctx context.Context, topicID string) error
PublishSampleMessage(ctx context.Context, topicID string) error
Init(ctx context.Context, projectID string) error
}
func NewPublisher ¶
func NewPublisher() Publisher
type Subscriber ¶
type Subscriber interface {
CreateSubscription(ctx context.Context, subscriptionID string, topicID string) (*pubsub.Subscription, error)
ReceiveSampleMessages(ctx context.Context, subscriptionID string) error
Init(ctx context.Context, projectID string) error
}
func NewSubscriber ¶
func NewSubscriber() Subscriber
Source Files