sqsfacade

Documentation

Index

• Constants
• func ToSimpleQueueEntry(body string, idx int) *sqs.SendMessageBatchRequestEntry
• type SQS
  • func New(queueUrl string, accessKeyId string, accessKeySecret string) *SQS
  • func (s *SQS) AckReceived(receiveOutput *sqs.ReceiveMessageOutput) error
  • func (s *SQS) Receive() (*sqs.ReceiveMessageOutput, error)
  • func (s *SQS) Send(ctx context.Context, batch []*sqs.SendMessageBatchRequestEntry, ...) error

Constants

const (
	MaxItemsPerBatch = 10 // AWS limitation
)

Functions

func ToSimpleQueueEntry

func ToSimpleQueueEntry(body string, idx int) *sqs.SendMessageBatchRequestEntry

Types

type SQS

type SQS struct {
	// contains filtered or unexported fields
}

func New

func New(queueUrl string, accessKeyId string, accessKeySecret string) *SQS

func (*SQS) AckReceived

func (s *SQS) AckReceived(receiveOutput *sqs.ReceiveMessageOutput) error

func (*SQS) Receive

func (s *SQS) Receive() (*sqs.ReceiveMessageOutput, error)

func (*SQS) Send

func (s *SQS) Send(
	ctx context.Context,
	batch []*sqs.SendMessageBatchRequestEntry,
	timeout time.Duration,
	failed func(err error),
) error