queue

Documentation

Index

• type SQSClient
  • func NewSQSClient(queueName string, options ...SQSClientOption) (*SQSClient, error)
  • func (c *SQSClient) Delete(receiptHandle string) error
  • func (c *SQSClient) Publish(data interface{}) (*sqs.SendMessageOutput, error)
  • func (c *SQSClient) Receive() (*sqs.ReceiveMessageOutput, error)
• type SQSClientOption
  • func WithSQSBatchSize(batchSize int64) SQSClientOption
  • func WithSQSLocalstackSession() SQSClientOption
  • func WithSQSPublishDelay(publishDelay int64) SQSClientOption
  • func WithSQSRegion(region string) SQSClientOption
  • func WithSQSVisibilityTimeout(visibilityTimeout int64) SQSClientOption

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