awssqs

Documentation

Index

• type Adapter
  • func (a *Adapter) Start(ctx context.Context, stopCh <-chan struct{}) error

Types

type Adapter

type Adapter struct {

	// QueueName is the AWS SQS name
	QueueName string

	// Region is the AWS SQS region
	Region string

	// Goroutine workers to listen to SQS queue
	Workers int

	// SinkURI is the URI messages will be forwarded on to.
	SinkURI string

	// SqsIamRoleArn is the pre-existing AWS IAM role to access SQS queue, it is required when using KIAM approach.
	SqsIamRoleArn string

	// CredsFile is the full path of the AWS credentials file, it is required when using k8s secret approach.
	CredsFile string

	// Deliver multiple messages or single message
	BulkDelivery bool
	// contains filtered or unexported fields
}

Adapter implements the AWS SQS adapter to deliver SQS messages from an SQS queue to a Sink.

func (*Adapter) Start

func (a *Adapter) Start(ctx context.Context, stopCh <-chan struct{}) error

Start function