sqs

package
v1.1.1 Latest Latest
Warning

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

Go to latest
Published: May 25, 2022 License: MIT Imports: 6 Imported by: 0

Documentation

Overview

Package SQS is the AWS SQS implementation of an event stream.

Index

Constants

View Source
const (
	// QueueNameOption is the queue name option.
	QueueNameOption = "queue_name"

	// ExplicitHashKeyOption is the explicit hash key option.
	DelaySecondsOption = "delay_seconds"

	// MessageGroupIDOption is the grouping id sequence option.
	MessageGroupIDOption = "message_group_id"

	// MessageDedupIDOption is the deduplication id option.
	MessageDedupIDOption = "message_dedup_id"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type SQS

type SQS struct {
	// contains filtered or unexported fields
}

SQS is the wrapper for the SQS library.

func New

func New(conn sqsiface.SQSAPI) *SQS

New creates a new instance of SQS.

func (*SQS) Send

func (r *SQS) Send(ctx context.Context, evt *outboxer.OutboxMessage) error

Send sends the message to the event stream.

Jump to

Keyboard shortcuts

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