service

Documentation

Index

• type HealthCheck
  • func NewHealthCheck(healthCheckRepository domain.HealthCheckRepository) *HealthCheck
  • func (h *HealthCheck) Check(ctx context.Context) (*domain.HealthCheck, error)
• type Message
  • func NewMessage(messageRepository domain.MessageRepository, ...) *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 NewQueue(queueRepository domain.QueueRepository) *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 uint) ([]*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
• type Subscription
  • func NewSubscription(subscriptionRepository domain.SubscriptionRepository) *Subscription
  • func (s *Subscription) Create(ctx context.Context, subscription *domain.Subscription) error
  • func (s *Subscription) Delete(ctx context.Context, id string) error
  • func (s *Subscription) Get(ctx context.Context, id string) (*domain.Subscription, error)
  • func (s *Subscription) List(ctx context.Context, offset, limit uint) ([]*domain.Subscription, error)
• type Topic
  • func NewTopic(topicRepository domain.TopicRepository, ...) *Topic
  • func (t *Topic) Create(ctx context.Context, topic *domain.Topic) error
  • func (t *Topic) CreateMessage(ctx context.Context, topicID string, message *domain.Message) error
  • func (t *Topic) Delete(ctx context.Context, id string) error
  • func (t *Topic) Get(ctx context.Context, id string) (*domain.Topic, error)
  • func (t *Topic) List(ctx context.Context, offset, limit uint) ([]*domain.Topic, error)

Types

type HealthCheck

type HealthCheck struct {
	// contains filtered or unexported fields
}

HealthCheck is an implementation of domain.HealthCheckService.

func NewHealthCheck

func NewHealthCheck(healthCheckRepository domain.HealthCheckRepository) *HealthCheck

NewHealthCheck returns an implementation of domain.HealthCheckService.

func (*HealthCheck) Check

func (h *HealthCheck) Check(ctx context.Context) (*domain.HealthCheck, error)

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.

func (*Message) Ack

func (m *Message) Ack(ctx context.Context, id string) error

func (*Message) Create

func (m *Message) Create(ctx context.Context, message *domain.Message) error

func (*Message) List

func (m *Message) List(ctx context.Context, queueID string, label *string, limit uint) ([]*domain.Message, error)

func (*Message) Nack

func (m *Message) Nack(ctx context.Context, id string, visibilityTimeoutSeconds uint) error

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.

func (*Queue) Cleanup

func (q *Queue) Cleanup(ctx context.Context, id string) error

func (*Queue) Create

func (q *Queue) Create(ctx context.Context, queue *domain.Queue) error

func (*Queue) Delete

func (q *Queue) Delete(ctx context.Context, id string) error

func (*Queue) Get

func (q *Queue) Get(ctx context.Context, id string) (*domain.Queue, error)

func (*Queue) List

func (q *Queue) List(ctx context.Context, offset, limit uint) ([]*domain.Queue, error)

func (*Queue) Purge

func (q *Queue) Purge(ctx context.Context, id string) error

func (*Queue) Stats

func (q *Queue) Stats(ctx context.Context, id string) (*domain.QueueStats, error)

func (*Queue) Update

func (q *Queue) Update(ctx context.Context, queue *domain.Queue) error

type Subscription

type Subscription struct {
	// contains filtered or unexported fields
}

Subscription is an implementation of domain.SubscriptionService.

func NewSubscription

func NewSubscription(subscriptionRepository domain.SubscriptionRepository) *Subscription

NewSubscription returns an implementation of domain.SubscriptionService.

func (*Subscription) Create

func (s *Subscription) Create(ctx context.Context, subscription *domain.Subscription) error

func (*Subscription) Delete

func (s *Subscription) Delete(ctx context.Context, id string) error

func (*Subscription) Get

func (s *Subscription) Get(ctx context.Context, id string) (*domain.Subscription, error)

func (*Subscription) List

func (s *Subscription) List(ctx context.Context, offset, limit uint) ([]*domain.Subscription, error)

type Topic

type Topic struct {
	// contains filtered or unexported fields
}

Topic is an implementation of domain.TopicService.

func NewTopic

func NewTopic(topicRepository domain.TopicRepository, subscriptionRepository domain.SubscriptionRepository, queueRepository domain.QueueRepository, messageRepository domain.MessageRepository) *Topic

NewTopic returns an implementation of domain.TopicService.

func (*Topic) Create

func (t *Topic) Create(ctx context.Context, topic *domain.Topic) error

func (*Topic) CreateMessage

func (t *Topic) CreateMessage(ctx context.Context, topicID string, message *domain.Message) error

func (*Topic) Delete

func (t *Topic) Delete(ctx context.Context, id string) error

func (*Topic) Get

func (t *Topic) Get(ctx context.Context, id string) (*domain.Topic, error)

func (*Topic) List

func (t *Topic) List(ctx context.Context, offset, limit uint) ([]*domain.Topic, error)