go_sqs_extended

Documentation

Index

• Constants
• Variables
• type ExtendedConfiguration
• type ExtendedSQS
  • func NewExtended(sqs *sqs.SQS, options *ExtendedConfiguration) (*ExtendedSQS, error)
  • func (esc *ExtendedSQS) ChangeMessageVisibility(input *sqs.ChangeMessageVisibilityInput) (*sqs.ChangeMessageVisibilityOutput, error)
  • func (esc *ExtendedSQS) ChangeMessageVisibilityBatch(input *sqs.ChangeMessageVisibilityBatchInput) (*sqs.ChangeMessageVisibilityBatchOutput, error)
  • func (esc *ExtendedSQS) DeleteMessage(input *sqs.DeleteMessageInput) (*sqs.DeleteMessageOutput, error)
  • func (esc *ExtendedSQS) DeleteMessageBatch(input *sqs.DeleteMessageBatchInput) (*sqs.DeleteMessageBatchOutput, error)
  • func (esc *ExtendedSQS) ReceiveMessage(input *sqs.ReceiveMessageInput) (*sqs.ReceiveMessageOutput, error)
  • func (esc *ExtendedSQS) SendMessage(input *sqs.SendMessageInput) (*sqs.SendMessageOutput, error)
  • func (esc *ExtendedSQS) SendMessageBatch(input *sqs.SendMessageBatchInput) (*sqs.SendMessageBatchOutput, error)
• type ReservedAttribute
• type S3Configuration

Constants

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

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

Variables

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

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
}