repository

package

v0.1.0 Latest Latest Go to latest Published: Dec 29, 2023 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

func SetupDatabaseConnection(ctx context.Context, cfg *domain.Config) (*pgxpool.Pool, error)

SetupDatabaseConnection returns a configured pgx pool.

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

Message is an implementation of domain.MessageRepository.

func NewMessage(pool *pgxpool.Pool) *Message

NewMessage returns an implementation of domain.MessageRepository.

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

func (m *Message) Create(ctx context.Context, message *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 struct {
	// contains filtered or unexported fields
}

Queue is an implementation of domain.QueueRepository.

func NewQueue(pool *pgxpool.Pool) *Queue

NewQueue returns an implementation of domain.QueueRepository.

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