Documentation ¶ Index ¶ Constants type SQS func NewSQS(session *session.Session, timeout time.Duration) SQS func (s SQS) Delete(ctx context.Context, url, handle string) error func (s SQS) Poll(ctx context.Context, chn chan<- *sqs.Message, sqsQueueUrl string, ...) func (s SQS) Receive(ctx context.Context, url string, maxMsg int64) ([]*sqs.Message, error) Constants ¶ View Source const DefaultWaitTime = 1 // Default polling SQS interval in seconds Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type SQS ¶ type SQS struct { // contains filtered or unexported fields } func NewSQS ¶ func NewSQS(session *session.Session, timeout time.Duration) SQS func (SQS) Delete ¶ func (s SQS) Delete(ctx context.Context, url, handle string) error func (SQS) Poll ¶ func (s SQS) Poll(ctx context.Context, chn chan<- *sqs.Message, sqsQueueUrl string, maxMessages int64) func (SQS) Receive ¶ func (s SQS) Receive(ctx context.Context, url string, maxMsg int64) ([]*sqs.Message, error) Source Files ¶ View all Source files sqs.go Click to show internal directories. Click to hide internal directories.