sqs

Jun 10, 2024

Changes in this version

+ type Client interface

+ DeleteMessage func(ctx context.Context, params *sqs.DeleteMessageInput, ...) (*sqs.DeleteMessageOutput, error)

+ GetQueueAttributes func(ctx context.Context, params *sqs.GetQueueAttributesInput, ...) (*sqs.GetQueueAttributesOutput, error)

+ ReceiveMessage func(ctx context.Context, params *sqs.ReceiveMessageInput, ...) (*sqs.ReceiveMessageOutput, error)

+ SendMessage func(ctx context.Context, params *sqs.SendMessageInput, ...) (*sqs.SendMessageOutput, error)

+ type Config struct

+ AccessKeyID string

+ QueueURL string

+ Region string

+ SecretKey string

+ type Queue struct

+ func NewQueueFromAWSConfig[T types.Marshallable](cfg aws.Config, queueURL string) (*Queue[T], error)

+ func NewQueueFromConfig[T types.Marshallable](cfg Config) (*Queue[T], error)

+ func (q *Queue[T]) Delete(messageID string) error

+ func (q *Queue[T]) Len() int

+ func (q *Queue[T]) Push(item T) (string, error)

+ func (q *Queue[T]) Receive() (string, T, bool)

+ func (q *Queue[T]) ReceiveMany(num int32) ([]string, []T, error)