sqs

package
v0.0.0-...-00906a0 Latest Latest
Warning

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

Go to latest
Published: Apr 26, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	*aws.Config

	MessageGroupId string
	QueueName      string
	QueueURL       string
}

type Message

type Message struct {
	MessageId                        string
	MessageGroupId                   string
	MessageDeduplicationId           string
	SentTimestamp                    time.Time
	SenderId                         string
	SequenceNumber                   string
	Body                             string
	ReceiptHandle                    string
	ApproximateReceiveCount          int
	ApproximateFirstReceiveTimestamp time.Time
}

type SQS

type SQS struct {
	sqsiface.SQSAPI
	// contains filtered or unexported fields
}

func New

func New(config *Config) (*SQS, error)

func (*SQS) Delete

func (s *SQS) Delete(ctx context.Context, receiptHandle string) error

func (*SQS) Receive

func (s *SQS) Receive(ctx context.Context) ([]*Message, error)

func (*SQS) Send

func (s *SQS) Send(ctx context.Context, m json.Marshaler) error

Jump to

Keyboard shortcuts

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