sqs

package

v1.8.16 Latest Latest Go to latest Published: Jan 9, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type SQSConfig struct {
	Region     string
	SQSBaseUrl string
}

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

SQSMessageQueue is a concrete implementation of IMessageQueue using AWS SQS.

func New(cfg SQSConfig) (*SQSMessageQueue, error)

New initializes a new SQSQueue instance.

func (q *SQSMessageQueue) Count(ctx context.Context, queueName string) (int, error)

Count returns the number of messages in the specified queue.

func (q *SQSMessageQueue) Delete(ctx context.Context, queueName string, id string) error

Delete deletes a message from the specified queue.

func (q *SQSMessageQueue) Dequeue(ctx context.Context, queueName string, options ...types.DequeueOptions) ([]types.DequeuedMessage, error)

Dequeue receives a message from the specified queue and deletes it after processing.

func (q *SQSMessageQueue) Enqueue(ctx context.Context, queueName string, payload string, options ...types.EnqueueOptions) error

Enqueue sends a message to the specified queue.