sqs

package

v1.0.2 Latest Latest Go to latest Published: Jan 23, 2026 License: MIT Imports: 12 Imported by: 0

Details

Package sqs provides an SQS implementation of the MessageQueueReader interface. It allows reading messages from AWS SQS queues without deleting them.

This section is empty.

This section is empty.

This section is empty.

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

SQSReader implements MessageQueueReader for AWS SQS

func NewSQSReader(cfg *mqreader.Config) (*SQSReader, error)

NewSQSReader creates a new SQS reader from a config

func (r *SQSReader) Close() error

Close releases resources (no-op for SQS as we don't maintain persistent connections)

func (r *SQSReader) Connect(ctx context.Context) error

Connect establishes connection to SQS

func (r *SQSReader) GetMetadata(ctx context.Context) (*mqreader.QueueMetadata, error)

GetMetadata returns information about the queue

func (r *SQSReader) Peek(ctx context.Context, maxMessages int) ([]mqreader.Message, error)

Peek reads messages from the queue without deleting them. It uses VisibilityTimeout=0 so messages are immediately available for other consumers.