Versions in this module Expand all Collapse all v3 v3.0.2 Sep 30, 2024 v3.0.1 Aug 22, 2024 Changes in this version + var LoggerFromContext = logevent.FromContext + var StatFromContext = xstats.FromContext + type ConsumerChain []ConsumerDecorator + func (c ConsumerChain) Apply(base SQSMessageConsumer) SQSMessageConsumer + type ConsumerDecorator func(SQSMessageConsumer) SQSMessageConsumer + type DefaultSQSProducer struct + Queue sqsiface.SQSAPI + func NewDefaultSQSProducer(queue sqsiface.SQSAPI, url string) *DefaultSQSProducer + func (producer *DefaultSQSProducer) BatchProduceMessage(ctx context.Context, messageInput *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error) + func (producer *DefaultSQSProducer) ProduceMessage(ctx context.Context, messageInput *sqs.SendMessageInput) error + func (producer *DefaultSQSProducer) QueueURL() string + type DefaultSQSProducerComponent struct + func NewDefaultSQSProducerComponent() *DefaultSQSProducerComponent + func (c *DefaultSQSProducerComponent) New(ctx context.Context, config *DefaultSQSProducerConfig) (DefaultSQSProducer, error) + func (c *DefaultSQSProducerComponent) Settings() *DefaultSQSProducerConfig + type DefaultSQSProducerConfig struct + AWSEndpoint string + QueueRegion string + QueueURL string + func (*DefaultSQSProducerConfig) Name() string + type DefaultSQSQueueConsumer struct + LogFn LogFn + MessageConsumer SQSMessageConsumer + PollInterval time.Duration + Queue sqsiface.SQSAPI + QueueURL string + func (m *DefaultSQSQueueConsumer) GetSQSMessageConsumer() SQSMessageConsumer + func (m *DefaultSQSQueueConsumer) StartConsuming(ctx context.Context) error + func (m *DefaultSQSQueueConsumer) StopConsuming(ctx context.Context) error + type DefaultSQSQueueConsumerComponent struct + func NewDefaultSQSQueueConsumerComponent() *DefaultSQSQueueConsumerComponent + func (c *DefaultSQSQueueConsumerComponent) New(ctx context.Context, config *DefaultSQSQueueConsumerConfig) (DefaultSQSQueueConsumer, error) + func (c *DefaultSQSQueueConsumerComponent) Settings() *DefaultSQSQueueConsumerConfig + type DefaultSQSQueueConsumerConfig struct + AWSEndpoint string + PollInterval time.Duration + QueueRegion string + QueueURL string + func (*DefaultSQSQueueConsumerConfig) Name() string + type LogFn func(context.Context) Logger + type Logger = logevent.Logger + type ProducerChain []ProducerDecorator + func (c ProducerChain) Apply(base SQSProducer) SQSProducer + type ProducerDecorator func(SQSProducer) SQSProducer + type RetryableConsumerError struct + VisibilityTimeout int64 + WrappedError error + func (e RetryableConsumerError) Error() string + type SQSConsumer interface + GetSQSMessageConsumer func() SQSMessageConsumer + StartConsuming func(ctx context.Context) error + StopConsuming func(ctx context.Context) error + type SQSMessageConsumer interface + ConsumeMessage func(ctx context.Context, message *sqs.Message) SQSMessageConsumerError + DeadLetter func(ctx context.Context, message *sqs.Message) + type SQSMessageConsumerError interface + Error func() string + IsRetryable func() bool + RetryAfter func() int64 + type SQSProducer interface + BatchProduceMessage func(ctx context.Context, messageBatchInput *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error) + ProduceMessage func(ctx context.Context, messageInput *sqs.SendMessageInput) error + QueueURL func() string + type SmartSQSConsumer struct + LogFn LogFn + MaxNumberOfMessages uint64 + MaxRetries uint64 + MessageConsumer SQSMessageConsumer + MessagePoolSize uint64 + NumWorkers uint64 + PollInterval time.Duration + Queue sqsiface.SQSAPI + QueueURL string + func (m *SmartSQSConsumer) GetSQSMessageConsumer() SQSMessageConsumer + func (m *SmartSQSConsumer) StartConsuming(ctx context.Context) error + func (m *SmartSQSConsumer) StopConsuming(ctx context.Context) error + type SmartSQSQueueConsumerComponent struct + func NewSmartSQSQueueConsumerComponent() *SmartSQSQueueConsumerComponent + func (c *SmartSQSQueueConsumerComponent) New(ctx context.Context, config *SmartSQSQueueConsumerConfig) (SmartSQSConsumer, error) + func (c *SmartSQSQueueConsumerComponent) Settings() *SmartSQSQueueConsumerConfig + type SmartSQSQueueConsumerConfig struct + AWSEndpoint string + MaxNumberOfMessages uint64 + MaxRetries uint64 + MessagePoolSize uint64 + NumWorkers uint64 + PollInterval time.Duration + QueueRegion string + QueueURL string + func (*SmartSQSQueueConsumerConfig) Name() string + type Stat = xstats.XStater + type StatFn func(context.Context) Stat Other modules containing this package github.com/asecurityteam/runsqs github.com/asecurityteam/runsqs/v2
Go to main page