domain

package

Go to main page

Versions in this module

v0

v0.4.1

Oct 15, 2024

v0.4.0

Jan 3, 2024

Changes in this version

type Config

+ MetricsHost string

+ MetricsPort uint

v0.3.0

Jan 3, 2024

Changes in this version

+ type HealthCheck struct

+ Success bool

+ type HealthCheckRepository interface

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

+ type HealthCheckService interface

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

v0.2.0

Jan 3, 2024

Changes in this version

+ var ErrSubscriptionAlreadyExists = errors.New("subscription already exists")

+ var ErrSubscriptionNotFound = errors.New("subscription not found")

+ var ErrTopicAlreadyExists = errors.New("topic already exists")

+ var ErrTopicNotFound = errors.New("topic not found")

type MessageRepository

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

+ type Subscription struct

+ CreatedAt time.Time

+ ID string

+ MessageFilters map[string][]string

+ QueueID string

+ TopicID string

+ func (s *Subscription) ShouldCreateMessage(message *Message) bool

+ func (s Subscription) Validate() error

+ type SubscriptionRepository interface

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

+ Delete func(ctx context.Context, id string) error

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

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

+ ListByTopic func(ctx context.Context, topicID string, offset, limit uint) ([]*Subscription, error)

+ type SubscriptionService interface

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

+ Delete func(ctx context.Context, id string) error

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

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

+ type Topic struct

+ CreatedAt time.Time

+ ID string

+ func (t Topic) Validate() error

+ type TopicRepository interface

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

+ Delete func(ctx context.Context, id string) error

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

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

+ type TopicService interface

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

+ CreateMessage func(ctx context.Context, topicID string, message *Message) error

+ Delete func(ctx context.Context, id string) error

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

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

v0.1.0

Dec 29, 2023

Changes in this version

+ var ErrMessageAlreadyExists = errors.New("message already exists")

+ var ErrMessageNotFound = errors.New("message not found")

+ var ErrQueueAlreadyExists = errors.New("queue already exists")

+ var ErrQueueNotFound = errors.New("queue not found")

+ func NewLogger(logLevel string) *slog.Logger

+ type Config struct

+ DatabaseMaxConns uint

+ DatabaseMinConns uint

+ DatabaseURL string

+ LogLevel string

+ QueueMaxNumberOfMessages uint

+ ServerHost string

+ ServerPort uint

+ ServerReadHeaderTimeoutSeconds uint

+ TestDatabaseURL string

+ Testing bool

+ func NewConfig() *Config

+ type Message struct

+ Attributes map[string]string

+ Body string

+ CreatedAt time.Time

+ DeliveryAttempts uint

+ ExpiredAt time.Time

+ ID string

+ Label *string

+ QueueID string

+ ScheduledAt time.Time

+ UpdatedAt time.Time

+ func (m *Message) Ack(now time.Time)

+ func (m *Message) DeliverySetup(queue *Queue, now time.Time)

+ func (m *Message) Enqueue(queue *Queue, now time.Time)

+ func (m *Message) Nack(now time.Time, visibilityTimeoutSeconds uint)

+ func (m Message) Validate() error

+ type MessageRepository interface

+ Ack func(ctx context.Context, id string) error

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

+ Get func(ctx context.Context, id string) (*Message, error)

+ List func(ctx context.Context, queue *Queue, label *string, limit uint) ([]*Message, error)

+ Nack func(ctx context.Context, id string, visibilityTimeoutSeconds uint) error

+ type MessageService interface

+ Ack func(ctx context.Context, id string) error

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

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

+ Nack func(ctx context.Context, id string, visibilityTimeoutSeconds uint) error

+ type Queue struct

+ AckDeadlineSeconds uint

+ CreatedAt time.Time

+ DeliveryDelaySeconds uint

+ ID string

+ MessageRetentionSeconds uint

+ UpdatedAt time.Time

+ func (q Queue) Validate() error

+ type QueueRepository interface

+ Cleanup func(ctx context.Context, id string) error

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

+ Delete func(ctx context.Context, id string) error

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

+ List func(ctx context.Context, offset, limit int) ([]*Queue, error)

+ Purge func(ctx context.Context, id string) error

+ Stats func(ctx context.Context, id string) (*QueueStats, error)

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

+ type QueueService interface

+ Cleanup func(ctx context.Context, id string) error

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

+ Delete func(ctx context.Context, id string) error

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

+ List func(ctx context.Context, offset, limit int) ([]*Queue, error)

+ Purge func(ctx context.Context, id string) error

+ Stats func(ctx context.Context, id string) (*QueueStats, error)

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

+ type QueueStats struct

+ NumUndeliveredMessages int

+ OldestUnackedMessageAgeSeconds int

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