Documentation
¶
Index ¶
- type MessageRepository
- func (_m *MessageRepository) Ack(ctx context.Context, id string) error
- func (_m *MessageRepository) Create(ctx context.Context, message *domain.Message) error
- func (_m *MessageRepository) Get(ctx context.Context, id string) (*domain.Message, error)
- func (_m *MessageRepository) List(ctx context.Context, queue *domain.Queue, label *string, limit uint) ([]*domain.Message, error)
- func (_m *MessageRepository) Nack(ctx context.Context, id string, visibilityTimeoutSeconds uint) error
- type MessageService
- func (_m *MessageService) Ack(ctx context.Context, id string) error
- func (_m *MessageService) Create(ctx context.Context, message *domain.Message) error
- func (_m *MessageService) List(ctx context.Context, queueID string, label *string, limit uint) ([]*domain.Message, error)
- func (_m *MessageService) Nack(ctx context.Context, id string, visibilityTimeoutSeconds uint) error
- type QueueRepository
- func (_m *QueueRepository) Cleanup(ctx context.Context, id string) error
- func (_m *QueueRepository) Create(ctx context.Context, queue *domain.Queue) error
- func (_m *QueueRepository) Delete(ctx context.Context, id string) error
- func (_m *QueueRepository) Get(ctx context.Context, id string) (*domain.Queue, error)
- func (_m *QueueRepository) List(ctx context.Context, offset int, limit int) ([]*domain.Queue, error)
- func (_m *QueueRepository) Purge(ctx context.Context, id string) error
- func (_m *QueueRepository) Stats(ctx context.Context, id string) (*domain.QueueStats, error)
- func (_m *QueueRepository) Update(ctx context.Context, queue *domain.Queue) error
- type QueueService
- func (_m *QueueService) Cleanup(ctx context.Context, id string) error
- func (_m *QueueService) Create(ctx context.Context, queue *domain.Queue) error
- func (_m *QueueService) Delete(ctx context.Context, id string) error
- func (_m *QueueService) Get(ctx context.Context, id string) (*domain.Queue, error)
- func (_m *QueueService) List(ctx context.Context, offset int, limit int) ([]*domain.Queue, error)
- func (_m *QueueService) Purge(ctx context.Context, id string) error
- func (_m *QueueService) Stats(ctx context.Context, id string) (*domain.QueueStats, error)
- func (_m *QueueService) Update(ctx context.Context, queue *domain.Queue) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageRepository ¶
MessageRepository is an autogenerated mock type for the MessageRepository type
func NewMessageRepository ¶
func NewMessageRepository(t interface {
mock.TestingT
Cleanup(func())
}) *MessageRepository
NewMessageRepository creates a new instance of MessageRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MessageRepository) Ack ¶
func (_m *MessageRepository) Ack(ctx context.Context, id string) error
Ack provides a mock function with given fields: ctx, id
type MessageService ¶
MessageService is an autogenerated mock type for the MessageService type
func NewMessageService ¶
func NewMessageService(t interface {
mock.TestingT
Cleanup(func())
}) *MessageService
NewMessageService creates a new instance of MessageService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*MessageService) Ack ¶
func (_m *MessageService) Ack(ctx context.Context, id string) error
Ack provides a mock function with given fields: ctx, id
type QueueRepository ¶
QueueRepository is an autogenerated mock type for the QueueRepository type
func NewQueueRepository ¶
func NewQueueRepository(t interface {
mock.TestingT
Cleanup(func())
}) *QueueRepository
NewQueueRepository creates a new instance of QueueRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*QueueRepository) Cleanup ¶
func (_m *QueueRepository) Cleanup(ctx context.Context, id string) error
Cleanup provides a mock function with given fields: ctx, id
func (*QueueRepository) Delete ¶
func (_m *QueueRepository) Delete(ctx context.Context, id string) error
Delete provides a mock function with given fields: ctx, id
func (*QueueRepository) List ¶
func (_m *QueueRepository) List(ctx context.Context, offset int, limit int) ([]*domain.Queue, error)
List provides a mock function with given fields: ctx, offset, limit
func (*QueueRepository) Purge ¶
func (_m *QueueRepository) Purge(ctx context.Context, id string) error
Purge provides a mock function with given fields: ctx, id
func (*QueueRepository) Stats ¶
func (_m *QueueRepository) Stats(ctx context.Context, id string) (*domain.QueueStats, error)
Stats provides a mock function with given fields: ctx, id
type QueueService ¶
QueueService is an autogenerated mock type for the QueueService type
func NewQueueService ¶
func NewQueueService(t interface {
mock.TestingT
Cleanup(func())
}) *QueueService
NewQueueService creates a new instance of QueueService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*QueueService) Cleanup ¶
func (_m *QueueService) Cleanup(ctx context.Context, id string) error
Cleanup provides a mock function with given fields: ctx, id
func (*QueueService) Delete ¶
func (_m *QueueService) Delete(ctx context.Context, id string) error
Delete provides a mock function with given fields: ctx, id
func (*QueueService) Purge ¶
func (_m *QueueService) Purge(ctx context.Context, id string) error
Purge provides a mock function with given fields: ctx, id
func (*QueueService) Stats ¶
func (_m *QueueService) Stats(ctx context.Context, id string) (*domain.QueueStats, error)
Stats provides a mock function with given fields: ctx, id
Source Files