Versions in this module Expand all Collapse all v0 v0.1.0 Feb 26, 2024 Changes in this version + type AWSSqsSource struct + func NewAWSSqsSource(client *sqs.Client, queueURL *string) *AWSSqsSource + func (s *AWSSqsSource) Ack(ctx context.Context, request sourcesdk.AckRequest) + func (s *AWSSqsSource) Partitions(_ context.Context) []int32 + func (s *AWSSqsSource) Pending(_ context.Context) int64 + func (s *AWSSqsSource) Read(_ context.Context, readRequest sourcesdk.ReadRequest, ...)
Go to main page