Documentation
¶
Index ¶
- func SetupDatabaseConnection(ctx context.Context, cfg *domain.Config) (*pgxpool.Pool, error)
- type HealthCheck
- 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) CreateMany(ctx context.Context, messages []*domain.Message) error
- func (m *Message) Get(ctx context.Context, id string) (*domain.Message, error)
- func (m *Message) List(ctx context.Context, queue *domain.Queue, 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 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 (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)
- func (s *Subscription) ListByTopic(ctx context.Context, topicID string, offset, limit uint) ([]*domain.Subscription, error)
- type Topic
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type HealthCheck ¶ added in v0.3.0
type HealthCheck struct {
// contains filtered or unexported fields
}
HealthCheck is an implementation of domain.HealthCheckRepository.
func NewHealthCheck ¶ added in v0.3.0
func NewHealthCheck(pool *pgxpool.Pool) *HealthCheck
NewHealthCheck returns an implementation of domain.HealthCheckRepository.
func (*HealthCheck) Check ¶ added in v0.3.0
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.MessageRepository.
func NewMessage ¶
NewMessage returns an implementation of domain.MessageRepository.
func (*Message) CreateMany ¶ added in v0.2.0
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
Queue is an implementation of domain.QueueRepository.
type Subscription ¶ added in v0.2.0
type Subscription struct {
// contains filtered or unexported fields
}
Subscription is an implementation of domain.SubscriptionRepository.
func NewSubscription ¶ added in v0.2.0
func NewSubscription(pool *pgxpool.Pool) *Subscription
NewSubscription returns an implementation of domain.SubscriptionRepository.
func (*Subscription) Create ¶ added in v0.2.0
func (s *Subscription) Create(ctx context.Context, subscription *domain.Subscription) error
func (*Subscription) Delete ¶ added in v0.2.0
func (s *Subscription) Delete(ctx context.Context, id string) error
func (*Subscription) Get ¶ added in v0.2.0
func (s *Subscription) Get(ctx context.Context, id string) (*domain.Subscription, error)
func (*Subscription) List ¶ added in v0.2.0
func (s *Subscription) List(ctx context.Context, offset, limit uint) ([]*domain.Subscription, error)
func (*Subscription) ListByTopic ¶ added in v0.2.0
func (s *Subscription) ListByTopic(ctx context.Context, topicID string, offset, limit uint) ([]*domain.Subscription, error)
type Topic ¶ added in v0.2.0
type Topic struct {
// contains filtered or unexported fields
}
Topic is an implementation of domain.TopicRepository.
Source Files
Click to show internal directories.
Click to hide internal directories.