sqs

Documentation

Index

• type AWSSqsSource
  • 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, ...)

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.