sqs_common

package
v3.8.30 Latest Latest
Warning

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

Go to latest
Published: Apr 3, 2024 License: BSD-2-Clause Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetCredentials

func GetCredentials(t, akid, secret string) (*credentials.Credentials, error)

Types

type Config

type Config struct {
	Queue       string
	Region      string
	Credentials *credentials.Credentials
}

type SQS

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

func SQSListener

func SQSListener(c *Config) (*SQS, error)

Creates a new SQS connection from a given Config object.

func (*SQS) DeleteMessages

func (s *SQS) DeleteMessages(m []*sqs.Message, lg *log.Logger) error

func (*SQS) GetMessages

func (s *SQS) GetMessages() ([]*sqs.Message, error)

Returns one or more messages from the queue on this SQS object.

Jump to

Keyboard shortcuts

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