go_sqs_extended

package
v0.0.0-...-856ad79 Latest Latest
Warning

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

 Go to latest Published: Mar 23, 2023 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultLargeMessageSize  int64 = 262144 // bytes
	MaximumAllowedAttributes       = 9      // 10 - 1 for reserved
	S3BucketNameMarker             = "-..s3BucketName..-"
	S3KeyMarker                    = "-..s3Key..-"

	AttributeName       ReservedAttribute = "ExtendedPayloadSize"
	LegacyAttributeName ReservedAttribute = "SQSLargePayloadSize"
)

Variables

View Source 
var ReceiptHandleRegexp = regexp.MustCompile(fmt.Sprintf(
	"^(%s)(.*)(%s)(.*)(%s)(.*)(%s){1}",
	S3BucketNameMarker, S3BucketNameMarker, S3KeyMarker, S3KeyMarker,
))

Functions

This section is empty.

Types

type ExtendedConfiguration 

type ExtendedConfiguration struct {
	AlwaysSendThroughS3            bool
	LargeMessageThreshold          int64
	UseLegacyReservedAttributeName bool
	S3Configuration                *S3Configuration
}

type ExtendedSQS 

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

func NewExtended 

func NewExtended(sqs *sqs.SQS, options *ExtendedConfiguration) (*ExtendedSQS, error)

func (*ExtendedSQS) ChangeMessageVisibility 

func (esc *ExtendedSQS) ChangeMessageVisibility(input *sqs.ChangeMessageVisibilityInput) (*sqs.ChangeMessageVisibilityOutput, error)

func (*ExtendedSQS) ChangeMessageVisibilityBatch 

func (esc *ExtendedSQS) ChangeMessageVisibilityBatch(input *sqs.ChangeMessageVisibilityBatchInput) (*sqs.ChangeMessageVisibilityBatchOutput, error)

func (*ExtendedSQS) DeleteMessage 

func (esc *ExtendedSQS) DeleteMessage(input *sqs.DeleteMessageInput) (*sqs.DeleteMessageOutput, error)

func (*ExtendedSQS) DeleteMessageBatch 

func (esc *ExtendedSQS) DeleteMessageBatch(input *sqs.DeleteMessageBatchInput) (*sqs.DeleteMessageBatchOutput, error)

func (*ExtendedSQS) ReceiveMessage 

func (esc *ExtendedSQS) ReceiveMessage(input *sqs.ReceiveMessageInput) (*sqs.ReceiveMessageOutput, error)

func (*ExtendedSQS) SendMessage 

func (esc *ExtendedSQS) SendMessage(input *sqs.SendMessageInput) (*sqs.SendMessageOutput, error)

SendMessage creates and inserts a record into the given SQS queue If large message processing is enabled, the contents of the message are inserted to S3 as a new object. Then, a reference to the object will be sent as the SQS record instead. If large message processing is disabled, the contents of the message are sent to SQS as normal.

func (*ExtendedSQS) SendMessageBatch 

func (esc *ExtendedSQS) SendMessageBatch(input *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error)

type ReservedAttribute 

type ReservedAttribute string

type S3Configuration 

type S3Configuration struct {
	Client                *s3.S3
	BucketName            string
	CleanupAfterOperation bool
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.