mocks

package

Go to main page

Versions in this module

v0

v0.4.1

Oct 15, 2024

v0.4.0

Jan 3, 2024

v0.3.0

Jan 3, 2024

Changes in this version

+ type HealthCheckRepository struct

+ func NewHealthCheckRepository(t interface{ ... }) *HealthCheckRepository

+ func (_m *HealthCheckRepository) Check(ctx context.Context) (*domain.HealthCheck, error)

+ type HealthCheckService struct

+ func NewHealthCheckService(t interface{ ... }) *HealthCheckService

+ func (_m *HealthCheckService) Check(ctx context.Context) (*domain.HealthCheck, error)

v0.2.0

Jan 3, 2024

Changes in this version

type MessageRepository

+ func (_m *MessageRepository) CreateMany(ctx context.Context, messages []*domain.Message) error

+ type SubscriptionRepository struct

+ func NewSubscriptionRepository(t interface{ ... }) *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 struct

+ func NewSubscriptionService(t interface{ ... }) *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 struct

+ func NewTopicRepository(t interface{ ... }) *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 struct

+ func NewTopicService(t interface{ ... }) *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)

v0.1.0

Dec 29, 2023

Changes in this version

+ type MessageRepository struct

+ func NewMessageRepository(t interface{ ... }) *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 struct

+ func NewMessageService(t interface{ ... }) *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 struct

+ func NewQueueRepository(t interface{ ... }) *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 struct

+ func NewQueueService(t interface{ ... }) *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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL