queue

package
v0.0.0-...-3f72e9c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 20, 2020 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type SQSClient

type SQSClient struct {
	*sqs.SQS
	// contains filtered or unexported fields
}

func NewSQSClient

func NewSQSClient(queueName string, options ...SQSClientOption) (*SQSClient, error)

func (*SQSClient) Delete

func (c *SQSClient) Delete(receiptHandle string) error

func (*SQSClient) Publish

func (c *SQSClient) Publish(data interface{}) (*sqs.SendMessageOutput, error)

func (*SQSClient) Receive

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

type SQSClientOption

type SQSClientOption func(client *SQSClient)

func WithSQSBatchSize

func WithSQSBatchSize(batchSize int64) SQSClientOption

func WithSQSLocalstackSession

func WithSQSLocalstackSession() SQSClientOption

func WithSQSPublishDelay

func WithSQSPublishDelay(publishDelay int64) SQSClientOption

func WithSQSRegion

func WithSQSRegion(region string) SQSClientOption

func WithSQSVisibilityTimeout

func WithSQSVisibilityTimeout(visibilityTimeout int64) SQSClientOption

Jump to

Keyboard shortcuts

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