sqs

Documentation

Overview

Package sqs - simple for sqs.

Index

• type BatchOutput
• type SQS
  • func New(AWSID, AWSKEY, Region, URL string) *SQS
  • func (s SQS) Delete(ReceiptHandle *string) (*sqs.DeleteMessageOutput, error)
  • func (s SQS) PurgeQueue() (*sqs.PurgeQueueOutput, error)
  • func (s SQS) Receive(Visibility int64) (*sqs.ReceiveMessageOutput, error)
  • func (s SQS) Send(Body string) (*sqs.SendMessageOutput, error)
  • func (s SQS) SendBatch(Bodies []string) []*BatchOutput

Types

type BatchOutput

type BatchOutput struct {
	Output *sqs.SendMessageBatchOutput
	Error  error
}

BatchOutput struct

type SQS

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

SQS struct

func New

func New(AWSID, AWSKEY, Region, URL string) *SQS

New to new a sqs.

func (SQS) Delete

func (s SQS) Delete(ReceiptHandle *string) (*sqs.DeleteMessageOutput, error)

Delete to delete a queue message.

func (SQS) PurgeQueue

func (s SQS) PurgeQueue() (*sqs.PurgeQueueOutput, error)

PurgeQueue to purge queue all messages.

func (SQS) Receive

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

Receive to receive a queue message.

func (SQS) Send

func (s SQS) Send(Body string) (*sqs.SendMessageOutput, error)

Send to send a queue message.

func (SQS) SendBatch

func (s SQS) SendBatch(Bodies []string) []*BatchOutput

SendBatch to split Bodies into batch messages and send.