Documentation ¶
Index ¶
- type HealthCheckRepository
- type HealthCheckService
- 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) CreateMany(ctx context.Context, messages []*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 uint, limit uint) ([]*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 uint, limit uint) ([]*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
- type SubscriptionRepository
- func (_m *SubscriptionRepository) Create(ctx context.Context, subscription *domain.Subscription) error
- func (_m *SubscriptionRepository) Delete(ctx context.Context, id string) error
- func (_m *SubscriptionRepository) Get(ctx context.Context, id string) (*domain.Subscription, error)
- func (_m *SubscriptionRepository) List(ctx context.Context, offset uint, limit uint) ([]*domain.Subscription, error)
- func (_m *SubscriptionRepository) ListByTopic(ctx context.Context, topicID string, offset uint, limit uint) ([]*domain.Subscription, error)
- type SubscriptionService
- func (_m *SubscriptionService) Create(ctx context.Context, subscription *domain.Subscription) error
- func (_m *SubscriptionService) Delete(ctx context.Context, id string) error
- func (_m *SubscriptionService) Get(ctx context.Context, id string) (*domain.Subscription, error)
- func (_m *SubscriptionService) List(ctx context.Context, offset uint, limit uint) ([]*domain.Subscription, error)
- type TopicRepository
- func (_m *TopicRepository) Create(ctx context.Context, topic *domain.Topic) error
- func (_m *TopicRepository) Delete(ctx context.Context, id string) error
- func (_m *TopicRepository) Get(ctx context.Context, id string) (*domain.Topic, error)
- func (_m *TopicRepository) List(ctx context.Context, offset uint, limit uint) ([]*domain.Topic, error)
- type TopicService
- func (_m *TopicService) Create(ctx context.Context, topic *domain.Topic) error
- func (_m *TopicService) CreateMessage(ctx context.Context, topicID string, message *domain.Message) error
- func (_m *TopicService) Delete(ctx context.Context, id string) error
- func (_m *TopicService) Get(ctx context.Context, id string) (*domain.Topic, error)
- func (_m *TopicService) List(ctx context.Context, offset uint, limit uint) ([]*domain.Topic, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HealthCheckRepository ¶ added in v0.3.0
HealthCheckRepository is an autogenerated mock type for the HealthCheckRepository type
func NewHealthCheckRepository ¶ added in v0.3.0
func NewHealthCheckRepository(t interface { mock.TestingT Cleanup(func()) }) *HealthCheckRepository
NewHealthCheckRepository creates a new instance of HealthCheckRepository. 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 (*HealthCheckRepository) Check ¶ added in v0.3.0
func (_m *HealthCheckRepository) Check(ctx context.Context) (*domain.HealthCheck, error)
Check provides a mock function with given fields: ctx
type HealthCheckService ¶ added in v0.3.0
HealthCheckService is an autogenerated mock type for the HealthCheckService type
func NewHealthCheckService ¶ added in v0.3.0
func NewHealthCheckService(t interface { mock.TestingT Cleanup(func()) }) *HealthCheckService
NewHealthCheckService creates a new instance of HealthCheckService. 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 (*HealthCheckService) Check ¶ added in v0.3.0
func (_m *HealthCheckService) Check(ctx context.Context) (*domain.HealthCheck, error)
Check provides a mock function with given fields: ctx
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
func (*MessageRepository) CreateMany ¶ added in v0.2.0
CreateMany provides a mock function with given fields: ctx, messages
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 uint, limit uint) ([]*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
type SubscriptionRepository ¶ added in v0.2.0
SubscriptionRepository is an autogenerated mock type for the SubscriptionRepository type
func NewSubscriptionRepository ¶ added in v0.2.0
func NewSubscriptionRepository(t interface { mock.TestingT Cleanup(func()) }) *SubscriptionRepository
NewSubscriptionRepository creates a new instance of SubscriptionRepository. 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 (*SubscriptionRepository) Create ¶ added in v0.2.0
func (_m *SubscriptionRepository) Create(ctx context.Context, subscription *domain.Subscription) error
Create provides a mock function with given fields: ctx, subscription
func (*SubscriptionRepository) Delete ¶ added in v0.2.0
func (_m *SubscriptionRepository) Delete(ctx context.Context, id string) error
Delete provides a mock function with given fields: ctx, id
func (*SubscriptionRepository) Get ¶ added in v0.2.0
func (_m *SubscriptionRepository) Get(ctx context.Context, id string) (*domain.Subscription, error)
Get provides a mock function with given fields: ctx, id
func (*SubscriptionRepository) List ¶ added in v0.2.0
func (_m *SubscriptionRepository) List(ctx context.Context, offset uint, limit uint) ([]*domain.Subscription, error)
List provides a mock function with given fields: ctx, offset, limit
func (*SubscriptionRepository) ListByTopic ¶ added in v0.2.0
func (_m *SubscriptionRepository) ListByTopic(ctx context.Context, topicID string, offset uint, limit uint) ([]*domain.Subscription, error)
ListByTopic provides a mock function with given fields: ctx, topicID, offset, limit
type SubscriptionService ¶ added in v0.2.0
SubscriptionService is an autogenerated mock type for the SubscriptionService type
func NewSubscriptionService ¶ added in v0.2.0
func NewSubscriptionService(t interface { mock.TestingT Cleanup(func()) }) *SubscriptionService
NewSubscriptionService creates a new instance of SubscriptionService. 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 (*SubscriptionService) Create ¶ added in v0.2.0
func (_m *SubscriptionService) Create(ctx context.Context, subscription *domain.Subscription) error
Create provides a mock function with given fields: ctx, subscription
func (*SubscriptionService) Delete ¶ added in v0.2.0
func (_m *SubscriptionService) Delete(ctx context.Context, id string) error
Delete provides a mock function with given fields: ctx, id
func (*SubscriptionService) Get ¶ added in v0.2.0
func (_m *SubscriptionService) Get(ctx context.Context, id string) (*domain.Subscription, error)
Get provides a mock function with given fields: ctx, id
func (*SubscriptionService) List ¶ added in v0.2.0
func (_m *SubscriptionService) List(ctx context.Context, offset uint, limit uint) ([]*domain.Subscription, error)
List provides a mock function with given fields: ctx, offset, limit
type TopicRepository ¶ added in v0.2.0
TopicRepository is an autogenerated mock type for the TopicRepository type
func NewTopicRepository ¶ added in v0.2.0
func NewTopicRepository(t interface { mock.TestingT Cleanup(func()) }) *TopicRepository
NewTopicRepository creates a new instance of TopicRepository. 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 (*TopicRepository) Create ¶ added in v0.2.0
Create provides a mock function with given fields: ctx, topic
func (*TopicRepository) Delete ¶ added in v0.2.0
func (_m *TopicRepository) Delete(ctx context.Context, id string) error
Delete provides a mock function with given fields: ctx, id
type TopicService ¶ added in v0.2.0
TopicService is an autogenerated mock type for the TopicService type
func NewTopicService ¶ added in v0.2.0
func NewTopicService(t interface { mock.TestingT Cleanup(func()) }) *TopicService
NewTopicService creates a new instance of TopicService. 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 (*TopicService) Create ¶ added in v0.2.0
Create provides a mock function with given fields: ctx, topic
func (*TopicService) CreateMessage ¶ added in v0.2.0
func (_m *TopicService) CreateMessage(ctx context.Context, topicID string, message *domain.Message) error
CreateMessage provides a mock function with given fields: ctx, topicID, message
func (*TopicService) Delete ¶ added in v0.2.0
func (_m *TopicService) Delete(ctx context.Context, id string) error
Delete provides a mock function with given fields: ctx, id