Versions in this module Expand all Collapse all v0 v0.0.0 Aug 10, 2022 Changes in this version + const OriginalMessageIDAttributeKey + const OriginalMessageSentTimestampAttributeKey + func ExtructSentTimestamp(msg *types.Message) (int64, error) + type App struct + func New(ctx context.Context, opt *Option, optFns ...func(*config.LoadOptions) error) (*App, error) + func NewWithClient(ctx context.Context, client SQSClient, opt *Option) (*App, error) + func (app *App) HandleMessage(ctx context.Context, msg *types.Message) error + func (app *App) LambdaHandler(ctx context.Context, event *SQSEvent) (*SQSBatchResponse, error) + func (app *App) Run(ctx context.Context) error + type BatchItemFailureItem struct + ItemIdentifier string + type Option struct + EmitInterval time.Duration + IncomingQueueName string + IncomingQueueURL string + Offset time.Duration + OutgoingQueueName string + OutgoingQueueURL string + type OriginalAttributes struct + MessageID string + SentTimestamp int64 + func ExtructOriginalAttribute(msg *types.Message) (*OriginalAttributes, error) + func (attr *OriginalAttributes) DelayDuration(emitInterval, offset time.Duration) time.Duration + func (attr *OriginalAttributes) EmitTime(emitInterval, offset time.Duration) time.Time + func (attr *OriginalAttributes) SentTime() time.Time + func (attr *OriginalAttributes) SetMessageAttribute(attributes map[string]types.MessageAttributeValue) map[string]types.MessageAttributeValue + type SQSBatchResponse struct + BatchItemFailures []BatchItemFailureItem + type SQSClient interface + DeleteMessage func(ctx context.Context, params *sqs.DeleteMessageInput, ...) (*sqs.DeleteMessageOutput, error) + GetQueueUrl func(ctx context.Context, params *sqs.GetQueueUrlInput, ...) (*sqs.GetQueueUrlOutput, error) + ReceiveMessage func(ctx context.Context, params *sqs.ReceiveMessageInput, ...) (*sqs.ReceiveMessageOutput, error) + SendMessage func(ctx context.Context, params *sqs.SendMessageInput, ...) (*sqs.SendMessageOutput, error) + type SQSEvent struct + Records []types.Message
Go to main page