Versions in this module Expand all Collapse all v1 v1.0.0 Aug 15, 2023 Changes in this version + var ErrMissingDeduplicationID = errors.New("deduplication id is missing") + type FifoDeduplicationMiddleware struct + func FifoMiddleware(next xsqs.Handler[*sqs.Message], storage Storage) FifoDeduplicationMiddleware + func (middleware FifoDeduplicationMiddleware) Handle(ctx context.Context, message *sqs.Message) error + type Storage interface + Exists func(ctx context.Context, deduplicationID string) (bool, error) + Save func(ctx context.Context, deduplicationID string) error + func NewDynamoDB(db dynamodbiface.DynamoDBAPI, table string, ttl time.Duration) Storage
Go to main page