sqs

package

v0.0.0-...-f1594a2 Latest Latest Go to latest Published: Aug 8, 2018 License: MIT Imports: 8 Imported by: 2

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/architsmat38/golang-aws-sqs

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Decode(value []byte) ([]byte, error)
func Delete(ReceiptHandle *string) (*sqs.DeleteMessageOutput, error)
func Encode(value []byte) []byte
func Initialize(options ...func() error) error
func New(queue, region, id, secret, token string) func() error
func NewUsingConfig(queue string, config *aws.Config) func() error
func Purge() (*sqs.PurgeQueueOutput, error)
func Receive() (*sqs.ReceiveMessageOutput, error)
func Send(message string) (*sqs.SendMessageOutput, error)
func SendBatch(messages []string) (*sqs.SendMessageBatchOutput, error)
func SetMaxCountMessage(maxCount int64) func() error
func SetVisibilitySeconds(timeout int64) func() error
func SetWaitSeconds(waitTime int64) func() error
type SQSMessageBatchOutput
- func ProcessAndSendBatch(messages []string) []*SQSMessageBatchOutput
type SQSStruct

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	SQSClient         SQSStruct
	MaxCountMessage   int64 = 10
	VisibilitySeconds int64 = 10
	WaitSeconds       int64 = 10
)

View Source

var MAX_BATCH_MESSAGE_COUNT = 10

View Source

var MAX_SQS_BATCH_SIZE_KB = 150

Max batch size of messages that can be sent to SQS This is excluding the metadata that is sent along with the message

Functions ¶

func Decode ¶

func Decode(value []byte) ([]byte, error)

*

Decodes the value using base64

func Delete ¶

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

*

Delete a message from SQS queue

func Encode ¶

func Encode(value []byte) []byte

*

Encodes the value in base64

func Initialize ¶

func Initialize(options ...func() error) error

*

Initialize SQS and corresponding configuration
Uses "Functional Options Pattern"
Reference: https://dave.cheney.net/2014/10/17/functional-options-for-friendly-apis

func New ¶

func New(queue, region, id, secret, token string) func() error

*

Create SQS client using required AWS params (including creds)

func NewUsingConfig ¶

func NewUsingConfig(queue string, config *aws.Config) func() error

*

Create SQS client using AWS config

func Purge ¶

func Purge() (*sqs.PurgeQueueOutput, error)

*

Purge all messages from SQS queue

func Receive ¶

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

*

Receive messages from SQS queue

func Send ¶

func Send(message string) (*sqs.SendMessageOutput, error)

*

Send message to SQS queue

func SendBatch ¶

func SendBatch(messages []string) (*sqs.SendMessageBatchOutput, error)

*

Send messages in batch to SQS
This reduces the number of calls to SQS, also it reduces the cost as well :)

func SetMaxCountMessage ¶

func SetMaxCountMessage(maxCount int64) func() error

*

Sets the max count of message that can be returned by Amazon SQS
The value can range between 1 to 10

func SetVisibilitySeconds ¶

func SetVisibilitySeconds(timeout int64) func() error

*

Sets the duration for which the received messages are hidden from subsequent retrieve requests

func SetWaitSeconds ¶

func SetWaitSeconds(waitTime int64) func() error

*

Sets the duration for which the call waits for a message to appear in queue

Types ¶

type SQSMessageBatchOutput ¶

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

SQS message batch output

func ProcessAndSendBatch ¶

func ProcessAndSendBatch(messages []string) []*SQSMessageBatchOutput

*

Group all messages into chunks of 256 KB each and then send these chunks to SQS

type SQSStruct ¶

type SQSStruct struct {
	SQS *sqs.SQS
	URL string
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL