adapter

Documentation

Index

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

Types

type Adapter

type Adapter struct {

	// QueueURL is the AWS SQS URL that we're polling messages from
	QueueURL string

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

	// Credentials is a credentials chain to be used by the SQS client
	Credentials *credentials.Credentials

	// OnFailedPollWaitSecs determines the interval to wait after a
	// failed poll before making another one
	OnFailedPollWaitSecs time.Duration
	// 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