messaging

Documentation

Overview

Package messaging is for components that enable messaging to other systems.

Index

• type NewQueueOptions
• type Queue
  • func NewQueue(opts NewQueueOptions) *Queue
  • func (q *Queue) Delete(ctx context.Context, receiptID string) error
  • func (q *Queue) Receive(ctx context.Context) (*model.Message, string, error)
  • func (q *Queue) Send(ctx context.Context, m model.Message) error

Types

type NewQueueOptions

type NewQueueOptions struct {
	Config   aws.Config
	Log      *zap.Logger
	Name     string
	WaitTime time.Duration
}

type Queue

type Queue struct {
	Client *sqs.Client
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue(opts NewQueueOptions) *Queue

func (*Queue) Delete

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

Delete a message by receipt ID.

func (*Queue) Receive

func (q *Queue) Receive(ctx context.Context) (*model.Message, string, error)

Receive a message and its receipt ID from the queue. Returns nil if no message is available.

func (*Queue) Send

func (q *Queue) Send(ctx context.Context, m model.Message) error

Send a message to the queue as JSON.