Documentation
¶
Overview ¶
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Index ¶
- type MockDelivery
- func (m *MockDelivery) Ack(ctx context.Context) error
- func (m *MockDelivery) Attempt() int
- func (m *MockDelivery) DeliveryID() string
- func (m *MockDelivery) EXPECT() *MockDeliveryMockRecorder
- func (m *MockDelivery) ExtendVisibilityTimeout(ctx context.Context, durationMillis int64) error
- func (m *MockDelivery) Message() messagequeue.Message
- func (m *MockDelivery) Metadata() map[string]string
- func (m *MockDelivery) Nack(ctx context.Context, requeueAfterMillis int64) error
- func (m *MockDelivery) ReceivedAt() int64
- func (m *MockDelivery) Reject(ctx context.Context, reason string) error
- type MockDeliveryMockRecorder
- func (mr *MockDeliveryMockRecorder) Ack(ctx any) *gomock.Call
- func (mr *MockDeliveryMockRecorder) Attempt() *gomock.Call
- func (mr *MockDeliveryMockRecorder) DeliveryID() *gomock.Call
- func (mr *MockDeliveryMockRecorder) ExtendVisibilityTimeout(ctx, durationMillis any) *gomock.Call
- func (mr *MockDeliveryMockRecorder) Message() *gomock.Call
- func (mr *MockDeliveryMockRecorder) Metadata() *gomock.Call
- func (mr *MockDeliveryMockRecorder) Nack(ctx, requeueAfterMillis any) *gomock.Call
- func (mr *MockDeliveryMockRecorder) ReceivedAt() *gomock.Call
- func (mr *MockDeliveryMockRecorder) Reject(ctx, reason any) *gomock.Call
- type MockPublisher
- func (m *MockPublisher) Close() error
- func (m *MockPublisher) EXPECT() *MockPublisherMockRecorder
- func (m *MockPublisher) Publish(ctx context.Context, topic string, message messagequeue.Message) error
- func (m *MockPublisher) PublishAfter(ctx context.Context, topic string, message messagequeue.Message, delayMs int64) error
- type MockPublisherMockRecorder
- type MockQueue
- type MockQueueMockRecorder
- type MockSubscriber
- type MockSubscriberMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockDelivery ¶
type MockDelivery struct {
// contains filtered or unexported fields
}
MockDelivery is a mock of Delivery interface.
func NewMockDelivery ¶
func NewMockDelivery(ctrl *gomock.Controller) *MockDelivery
NewMockDelivery creates a new mock instance.
func (*MockDelivery) Ack ¶
func (m *MockDelivery) Ack(ctx context.Context) error
Ack mocks base method.
func (*MockDelivery) DeliveryID ¶
func (m *MockDelivery) DeliveryID() string
DeliveryID mocks base method.
func (*MockDelivery) EXPECT ¶
func (m *MockDelivery) EXPECT() *MockDeliveryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDelivery) ExtendVisibilityTimeout ¶
func (m *MockDelivery) ExtendVisibilityTimeout(ctx context.Context, durationMillis int64) error
ExtendVisibilityTimeout mocks base method.
func (*MockDelivery) Message ¶
func (m *MockDelivery) Message() messagequeue.Message
Message mocks base method.
func (*MockDelivery) Metadata ¶
func (m *MockDelivery) Metadata() map[string]string
Metadata mocks base method.
func (*MockDelivery) Nack ¶
func (m *MockDelivery) Nack(ctx context.Context, requeueAfterMillis int64) error
Nack mocks base method.
func (*MockDelivery) ReceivedAt ¶
func (m *MockDelivery) ReceivedAt() int64
ReceivedAt mocks base method.
type MockDeliveryMockRecorder ¶
type MockDeliveryMockRecorder struct {
// contains filtered or unexported fields
}
MockDeliveryMockRecorder is the mock recorder for MockDelivery.
func (*MockDeliveryMockRecorder) Ack ¶
func (mr *MockDeliveryMockRecorder) Ack(ctx any) *gomock.Call
Ack indicates an expected call of Ack.
func (*MockDeliveryMockRecorder) Attempt ¶
func (mr *MockDeliveryMockRecorder) Attempt() *gomock.Call
Attempt indicates an expected call of Attempt.
func (*MockDeliveryMockRecorder) DeliveryID ¶
func (mr *MockDeliveryMockRecorder) DeliveryID() *gomock.Call
DeliveryID indicates an expected call of DeliveryID.
func (*MockDeliveryMockRecorder) ExtendVisibilityTimeout ¶
func (mr *MockDeliveryMockRecorder) ExtendVisibilityTimeout(ctx, durationMillis any) *gomock.Call
ExtendVisibilityTimeout indicates an expected call of ExtendVisibilityTimeout.
func (*MockDeliveryMockRecorder) Message ¶
func (mr *MockDeliveryMockRecorder) Message() *gomock.Call
Message indicates an expected call of Message.
func (*MockDeliveryMockRecorder) Metadata ¶
func (mr *MockDeliveryMockRecorder) Metadata() *gomock.Call
Metadata indicates an expected call of Metadata.
func (*MockDeliveryMockRecorder) Nack ¶
func (mr *MockDeliveryMockRecorder) Nack(ctx, requeueAfterMillis any) *gomock.Call
Nack indicates an expected call of Nack.
func (*MockDeliveryMockRecorder) ReceivedAt ¶
func (mr *MockDeliveryMockRecorder) ReceivedAt() *gomock.Call
ReceivedAt indicates an expected call of ReceivedAt.
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) EXPECT ¶
func (m *MockPublisher) EXPECT() *MockPublisherMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPublisher) Publish ¶
func (m *MockPublisher) Publish(ctx context.Context, topic string, message messagequeue.Message) error
Publish mocks base method.
func (*MockPublisher) PublishAfter ¶
func (m *MockPublisher) PublishAfter(ctx context.Context, topic string, message messagequeue.Message, delayMs int64) error
PublishAfter mocks base method.
type MockPublisherMockRecorder ¶
type MockPublisherMockRecorder struct {
// contains filtered or unexported fields
}
MockPublisherMockRecorder is the mock recorder for MockPublisher.
func (*MockPublisherMockRecorder) Close ¶
func (mr *MockPublisherMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockPublisherMockRecorder) Publish ¶
func (mr *MockPublisherMockRecorder) Publish(ctx, topic, message any) *gomock.Call
Publish indicates an expected call of Publish.
func (*MockPublisherMockRecorder) PublishAfter ¶
func (mr *MockPublisherMockRecorder) PublishAfter(ctx, topic, message, delayMs any) *gomock.Call
PublishAfter indicates an expected call of PublishAfter.
type MockQueue ¶
type MockQueue struct {
// contains filtered or unexported fields
}
MockQueue is a mock of Queue interface.
func NewMockQueue ¶
func NewMockQueue(ctrl *gomock.Controller) *MockQueue
NewMockQueue creates a new mock instance.
func (*MockQueue) EXPECT ¶
func (m *MockQueue) EXPECT() *MockQueueMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockQueue) Publisher ¶
func (m *MockQueue) Publisher() messagequeue.Publisher
Publisher mocks base method.
func (*MockQueue) Subscriber ¶
func (m *MockQueue) Subscriber() messagequeue.Subscriber
Subscriber mocks base method.
type MockQueueMockRecorder ¶
type MockQueueMockRecorder struct {
// contains filtered or unexported fields
}
MockQueueMockRecorder is the mock recorder for MockQueue.
func (*MockQueueMockRecorder) Close ¶
func (mr *MockQueueMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockQueueMockRecorder) Publisher ¶
func (mr *MockQueueMockRecorder) Publisher() *gomock.Call
Publisher indicates an expected call of Publisher.
func (*MockQueueMockRecorder) Subscriber ¶
func (mr *MockQueueMockRecorder) Subscriber() *gomock.Call
Subscriber indicates an expected call of Subscriber.
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) EXPECT ¶
func (m *MockSubscriber) EXPECT() *MockSubscriberMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSubscriber) Subscribe ¶
func (m *MockSubscriber) Subscribe(ctx context.Context, topic string, config messagequeue.SubscriptionConfig) (<-chan messagequeue.Delivery, error)
Subscribe mocks base method.
type MockSubscriberMockRecorder ¶
type MockSubscriberMockRecorder struct {
// contains filtered or unexported fields
}
MockSubscriberMockRecorder is the mock recorder for MockSubscriber.
func (*MockSubscriberMockRecorder) Close ¶
func (mr *MockSubscriberMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
Source Files