Documentation
¶
Index ¶
- type Message
- func (m *Message) Ack(ctx context.Context, id string) error
- func (m *Message) Create(ctx context.Context, message *domain.Message) error
- func (m *Message) List(ctx context.Context, queueID string, label *string, limit uint) ([]*domain.Message, error)
- func (m *Message) Nack(ctx context.Context, id string, visibilityTimeoutSeconds uint) error
- type Queue
- func (q *Queue) Cleanup(ctx context.Context, id string) error
- func (q *Queue) Create(ctx context.Context, queue *domain.Queue) error
- func (q *Queue) Delete(ctx context.Context, id string) error
- func (q *Queue) Get(ctx context.Context, id string) (*domain.Queue, error)
- func (q *Queue) List(ctx context.Context, offset, limit int) ([]*domain.Queue, error)
- func (q *Queue) Purge(ctx context.Context, id string) error
- func (q *Queue) Stats(ctx context.Context, id string) (*domain.QueueStats, error)
- func (q *Queue) 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 Message ¶
type Message struct {
// contains filtered or unexported fields
}
Message is an implementation of domain.MessageService
func NewMessage ¶
func NewMessage(messageRepository domain.MessageRepository, queueRepository domain.QueueRepository) *Message
NewMessage returns an implementation of domain.MessageService.
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
Queue is an implementation of domain.QueueService.
func NewQueue ¶
func NewQueue(queueRepository domain.QueueRepository) *Queue
NewQueue returns an implementation of domain.QueueService.
Source Files
Click to show internal directories.
Click to hide internal directories.