sqs

Documentation

Index

• func WithConsumeMaxNumberOfMessages(max int) func(m any)
• func WithConsumeMessageAttributeNames(names []string) func(m any)
• func WithConsumeMessageSystemAttributeNames(attributes []string) func(m any)
• func WithConsumeRequestAttemptId(id string) func(m any)
• func WithConsumeVisibilityTimeout(timeout int64) func(m any)
• func WithConsumeWaitTimeSeconds(wait int64) func(m any)
• func WithEnqueueDelaySeconds(delay int64) func(m any)
• func WithEnqueueMessageAttributes(attrs map[string]*sqs.MessageAttributeValue) func(m any)
• func WithEnqueueMessageDeduplicationId(id string) func(m any)
• func WithEnqueueMessageGroupId(id string) func(m any)
• func WithEnqueueMessageSystemAttributes(attrs map[string]*sqs.MessageSystemAttributeValue) func(m any)
• type Driver
  • func New(options ...Option) (*Driver, error)
  • func (c *Driver) Ack(queue, messageID string) error
  • func (d *Driver) Consume(queue string, opts ...func(message any)) (*driver.ConsumerController, error)
  • func (d *Driver) Enqueue(queue string, data []byte, opts ...func(message any)) error
  • func (d *Driver) Ping() error
• type Option
  • func AutoTestConnection() Option
  • func WithClient(c sqsClient) Option
  • func WithRegion(region string) Option
  • func WithUrl(name string) Option

Functions

func WithConsumeMaxNumberOfMessages

func WithConsumeMaxNumberOfMessages(max int) func(m any)

func WithConsumeMessageAttributeNames

func WithConsumeMessageAttributeNames(names []string) func(m any)

func WithConsumeMessageSystemAttributeNames

func WithConsumeMessageSystemAttributeNames(attributes []string) func(m any)

func WithConsumeRequestAttemptId

func WithConsumeRequestAttemptId(id string) func(m any)

func WithConsumeVisibilityTimeout

func WithConsumeVisibilityTimeout(timeout int64) func(m any)

func WithConsumeWaitTimeSeconds

func WithConsumeWaitTimeSeconds(wait int64) func(m any)

func WithEnqueueDelaySeconds

func WithEnqueueDelaySeconds(delay int64) func(m any)

func WithEnqueueMessageAttributes

func WithEnqueueMessageAttributes(attrs map[string]*sqs.MessageAttributeValue) func(m any)

func WithEnqueueMessageDeduplicationId

func WithEnqueueMessageDeduplicationId(id string) func(m any)

func WithEnqueueMessageGroupId

func WithEnqueueMessageGroupId(id string) func(m any)

func WithEnqueueMessageSystemAttributes

func WithEnqueueMessageSystemAttributes(attrs map[string]*sqs.MessageSystemAttributeValue) func(m any)

Types

type Driver

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

func New

func New(options ...Option) (*Driver, error)

func (*Driver) Ack

func (c *Driver) Ack(queue, messageID string) error

func (*Driver) Consume

func (d *Driver) Consume(queue string, opts ...func(message any)) (*driver.ConsumerController, error)

func (*Driver) Enqueue

func (d *Driver) Enqueue(queue string, data []byte, opts ...func(message any)) error

func (*Driver) Ping

func (d *Driver) Ping() error

type Option

type Option func(*Driver)

func AutoTestConnection

func AutoTestConnection() Option

func WithClient

func WithClient(c sqsClient) Option

func WithRegion

func WithRegion(region string) Option

func WithUrl

func WithUrl(name string) Option