sqs

Documentation

Index

• func NewProcessor(queueName string, sqsClient sqsiface.ClientAPI, handler taskqueue.Handler, ...) (taskqueue.Processor, error)
• func NewProcessorCtor(queueName string, sqsClient sqsiface.ClientAPI, opts ...Option) taskqueue.ProcessorCtor
• func NewSubmitter(queueName string, sqsClient sqsiface.ClientAPI, opts ...Option) (taskqueue.Submitter, error)
• type Option
  • func WithMaxVisibilityExtensions(max int) Option
  • func WithPausedStart() Option
  • func WithPollingInterval(interval time.Duration) Option
  • func WithTaskConcurrency(concurrency int) Option
  • func WithVisibilityExtensionEnabled(enabled bool) Option
  • func WithVisibilityTimeout(timeout time.Duration) Option

Functions

func NewProcessor

func NewProcessor(queueName string, sqsClient sqsiface.ClientAPI, handler taskqueue.Handler, opts ...Option) (taskqueue.Processor, error)

func NewProcessorCtor

func NewProcessorCtor(queueName string, sqsClient sqsiface.ClientAPI, opts ...Option) taskqueue.ProcessorCtor

func NewSubmitter

func NewSubmitter(queueName string, sqsClient sqsiface.ClientAPI, opts ...Option) (taskqueue.Submitter, error)

Types

type Option

type Option func(c *config)

Option configures a Processor.

func WithMaxVisibilityExtensions

func WithMaxVisibilityExtensions(max int) Option

WithMaxVisibilityExtensions configures the maximum number of visibility extensions per message.

func WithPausedStart

func WithPausedStart() Option

WithPausedStart configures the processor to be initialized in a paused state.

func WithPollingInterval

func WithPollingInterval(interval time.Duration) Option

WithPollingInterval configures the polling interval.

func WithTaskConcurrency

func WithTaskConcurrency(concurrency int) Option

WithTaskConcurrency configures the task concurrency.

func WithVisibilityExtensionEnabled

func WithVisibilityExtensionEnabled(enabled bool) Option

WithVisibilityExtensionEnabled configures whether or not visibility extensions are enabled.

func WithVisibilityTimeout

func WithVisibilityTimeout(timeout time.Duration) Option

WithVisibilityTimeout configures the visibility timeout.