Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AWSSqsSource ¶
type AWSSqsSource struct {
// contains filtered or unexported fields
}
AWSSqsSource represents an AWS SQS source with necessary attributes.
func NewAWSSqsSource ¶
func NewAWSSqsSource(client *sqs.Client, queueURL *string) *AWSSqsSource
func (*AWSSqsSource) Ack ¶
func (s *AWSSqsSource) Ack(ctx context.Context, request sourcesdk.AckRequest)
Ack acknowledges the messages that have been read from the SQS queue by deleting them from the queue.
func (*AWSSqsSource) Partitions ¶
func (s *AWSSqsSource) Partitions(_ context.Context) []int32
func (*AWSSqsSource) Pending ¶
func (s *AWSSqsSource) Pending(_ context.Context) int64
Pending returns the approximate number of messages available for retrieval from the queue.
func (*AWSSqsSource) Read ¶
func (s *AWSSqsSource) Read(_ context.Context, readRequest sourcesdk.ReadRequest, messageCh chan<- sourcesdk.Message)
Read fetches messages from the SQS queue and sends them to the provided message channel.
Source Files
Click to show internal directories.
Click to hide internal directories.