sqs

Oct 12, 2023

Changes in this version

+ const AttributeSqsDelaySeconds

+ const AttributeSqsMessageDeduplicationId

+ const AttributeSqsMessageGroupId

+ const DeadletterFifoSuffix

+ const DeduplicationIdMaxLen

+ const DefaultVisibilityTimeout

+ const FifoSuffix

+ const GroupIdMaxLen

+ const MaxDelaySeconds

+ const MetadataKeyQueues

+ var MessageDeduplicationId = Attribute

+ var MessageDelaySeconds = Attribute

+ var MessageGroupId = Attribute

+ func GetQueueName(config cfg.Config, queueSettings QueueNameSettingsAware) (string, error)

+ func NewClient(ctx context.Context, config cfg.Config, logger log.Logger, name string, ...) (*sqs.Client, error)

+ func NewService(ctx context.Context, config cfg.Config, logger log.Logger, clientName string, ...) (*service, error)

+ func NewServiceWithInterfaces(logger log.Logger, client Client, settings *ServiceSettings) *service

+ func ProvideClient(ctx context.Context, config cfg.Config, logger log.Logger, name string, ...) (*sqs.Client, error)

+ type Attribute struct

+ type AttributeEncodeHandler struct

+ func NewAttributeEncodeHandler(attribute Attribute, attributeProvider AttributeProvider) *AttributeEncodeHandler

+ func (g *AttributeEncodeHandler) Decode(ctx context.Context, _ interface{}, attributes map[string]interface{}) (context.Context, map[string]interface{}, error)

+ func (g *AttributeEncodeHandler) Encode(ctx context.Context, data interface{}, attributes map[string]interface{}) (context.Context, map[string]interface{}, error)

+ type AttributeProvider func(data interface{}) (interface{}, error)

+ type Client interface

+ CreateQueue func(ctx context.Context, params *sqs.CreateQueueInput, ...) (*sqs.CreateQueueOutput, error)

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

+ DeleteMessageBatch func(ctx context.Context, params *sqs.DeleteMessageBatchInput, ...) (*sqs.DeleteMessageBatchOutput, error)

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

+ GetQueueUrl func(ctx context.Context, params *sqs.GetQueueUrlInput, ...) (*sqs.GetQueueUrlOutput, error)

+ PurgeQueue func(ctx context.Context, params *sqs.PurgeQueueInput, optFns ...func(*sqs.Options)) (*sqs.PurgeQueueOutput, error)

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

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

+ SendMessageBatch func(ctx context.Context, params *sqs.SendMessageBatchInput, ...) (*sqs.SendMessageBatchOutput, error)

+ SetQueueAttributes func(ctx context.Context, params *sqs.SetQueueAttributesInput, ...) (*sqs.SetQueueAttributesOutput, error)

+ type ClientConfig struct

+ LoadOptions []func(options *awsCfg.LoadOptions) error

+ Settings ClientSettings

+ func (c ClientConfig) GetLoadOptions() []func(options *awsCfg.LoadOptions) error

+ func (c ClientConfig) GetRetryOptions() []func(*retry.StandardOptions)

+ func (c ClientConfig) GetSettings() gosoAws.ClientSettings

+ type ClientOption func(cfg *ClientConfig)

+ type ClientSettings struct

+ type FifoSettings struct

+ ContentBasedDeduplication bool

+ Enabled bool

+ type Message struct

+ Body *string

+ DelaySeconds int32

+ MessageDeduplicationId *string

+ MessageGroupId *string

+ type Properties struct

+ Arn string

+ Name string

+ Url string

+ type Queue interface

+ DeleteMessage func(ctx context.Context, receiptHandle string) error

+ DeleteMessageBatch func(ctx context.Context, receiptHandles []string) error

+ GetArn func() string

+ GetName func() string

+ GetUrl func() string

+ Receive func(ctx context.Context, maxNumberOfMessages int32, waitTime int32) ([]types.Message, error)

+ Send func(ctx context.Context, msg *Message) error

+ SendBatch func(ctx context.Context, messages []*Message) error

+ func NewQueue(ctx context.Context, config cfg.Config, logger log.Logger, settings *Settings, ...) (Queue, error)

+ func NewQueueWithInterfaces(logger log.Logger, client Client, props *Properties) Queue

+ func ProvideQueue(ctx context.Context, config cfg.Config, logger log.Logger, settings *Settings, ...) (Queue, error)

+ type QueueMetadata struct

+ AwsClientName string

+ QueueArn string

+ QueueName string

+ QueueNameFull string

+ QueueUrl string

+ type QueueNameSettings struct

+ AppId cfg.AppId

+ ClientName string

+ FifoEnabled bool

+ QueueId string

+ func (s QueueNameSettings) GetAppId() cfg.AppId

+ func (s QueueNameSettings) GetClientName() string

+ func (s QueueNameSettings) GetQueueId() string

+ func (s QueueNameSettings) IsFifoEnabled() bool

+ type QueueNameSettingsAware interface

+ GetAppId func() cfg.AppId

+ GetClientName func() string

+ GetQueueId func() string

+ IsFifoEnabled func() bool

+ type QueueNamingSettings struct

+ Pattern string

+ type RedrivePolicy struct

+ Enabled bool

+ MaxReceiveCount int

+ type Service interface

+ CreateQueue func(ctx context.Context, settings *Settings) (*Properties, error)

+ GetArn func(ctx context.Context, url string) (string, error)

+ GetPropertiesByArn func(ctx context.Context, arn string) (*Properties, error)

+ GetPropertiesByName func(ctx context.Context, name string) (*Properties, error)

+ GetUrl func(ctx context.Context, name string) (string, error)

+ Purge func(ctx context.Context, url string) error

+ QueueExists func(ctx context.Context, name string) (bool, error)

+ type ServiceSettings struct

+ AutoCreate bool

+ type Settings struct

+ ClientName string

+ Fifo FifoSettings

+ QueueName string

+ RedrivePolicy RedrivePolicy

+ VisibilityTimeout int