Documentation ¶
Overview ¶
Code generated by mockery v1.0.0. DO NOT EDIT.
Index ¶
- type MessageQueue
- func (_m *MessageQueue) Close() error
- func (_m *MessageQueue) GetResult(ctx context.Context, result *pubsub.PublishResult) (string, error)
- func (_m *MessageQueue) Init(pubSubKey string, gProject string) error
- func (_m *MessageQueue) Publish(_a0 string, _a1 *message_queue.PubSubData) *pubsub.PublishResult
- func (_m *MessageQueue) SubscribeMessages(ctx context.Context, subscriptionId string, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageQueue ¶
MessageQueue is an autogenerated mock type for the MessageQueue type
func (*MessageQueue) Close ¶
func (_m *MessageQueue) Close() error
Close provides a mock function with given fields:
func (*MessageQueue) GetResult ¶
func (_m *MessageQueue) GetResult(ctx context.Context, result *pubsub.PublishResult) (string, error)
GetResult provides a mock function with given fields: ctx, result
func (*MessageQueue) Init ¶
func (_m *MessageQueue) Init(pubSubKey string, gProject string) error
Init provides a mock function with given fields: pubSubKey, gProject
func (*MessageQueue) Publish ¶
func (_m *MessageQueue) Publish(_a0 string, _a1 *message_queue.PubSubData) *pubsub.PublishResult
Publish provides a mock function with given fields: _a0, _a1
func (*MessageQueue) SubscribeMessages ¶
func (_m *MessageQueue) SubscribeMessages(ctx context.Context, subscriptionId string, subscribeFunction message_queue.SubscribeFunction) error
SubscribeMessages provides a mock function with given fields: ctx, subscriptionId, subscribeFunction
Click to show internal directories.
Click to hide internal directories.