sqs

package
v0.43.0-rc.0 Latest Latest
Warning

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

Go to latest
Published: Jul 28, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// QueueNotFound is the code that is returned by AWS when the given QueueURL is not valid
	QueueNotFound = "AWS.SimpleQueueService.NonExistentQueue"
)

Variables

This section is empty.

Functions

func GenerateCreateAttributes

func GenerateCreateAttributes(p *v1beta1.QueueParameters) map[string]string

GenerateCreateAttributes returns a map of queue attributes for Create operation

func GenerateQueueAttributes

func GenerateQueueAttributes(p *v1beta1.QueueParameters) map[string]string

GenerateQueueAttributes returns a map of queue attributes

func GenerateQueueObservation

func GenerateQueueObservation(url string, attr map[string]string) v1beta1.QueueObservation

GenerateQueueObservation returns a QueueObservation with information retrieved from AWS.

func GetConnectionDetails

func GetConnectionDetails(in v1beta1.Queue) managed.ConnectionDetails

GetConnectionDetails extracts managed.ConnectionDetails out of v1beta1.Queue.

func IsNotFound

func IsNotFound(err error) bool

IsNotFound checks if the error returned by AWS API says that the queue being probed doesn't exist

func IsUpToDate

func IsUpToDate(p v1beta1.QueueParameters, attributes map[string]string, tags map[string]string) bool

IsUpToDate checks whether there is a change in any of the modifiable fields.

func LateInitialize

func LateInitialize(in *v1beta1.QueueParameters, attributes map[string]string, tags map[string]string)

LateInitialize fills the empty fields in *v1beta1.QueueParameters with the values seen in queue.Attributes

func TagsDiff

func TagsDiff(sqsTags map[string]string, newTags map[string]string) (removed, added map[string]string)

TagsDiff returns the tags added and removed from spec when compared to the AWS SQS tags.

Types

type Client

type Client interface {
	CreateQueue(ctx context.Context, input *sqs.CreateQueueInput, opts ...func(*sqs.Options)) (*sqs.CreateQueueOutput, error)
	DeleteQueue(ctx context.Context, input *sqs.DeleteQueueInput, opts ...func(*sqs.Options)) (*sqs.DeleteQueueOutput, error)
	TagQueue(ctx context.Context, input *sqs.TagQueueInput, opts ...func(*sqs.Options)) (*sqs.TagQueueOutput, error)
	UntagQueue(ctx context.Context, input *sqs.UntagQueueInput, opts ...func(*sqs.Options)) (*sqs.UntagQueueOutput, error)
	ListQueueTags(ctx context.Context, input *sqs.ListQueueTagsInput, opts ...func(*sqs.Options)) (*sqs.ListQueueTagsOutput, error)
	GetQueueAttributes(ctx context.Context, input *sqs.GetQueueAttributesInput, opts ...func(*sqs.Options)) (*sqs.GetQueueAttributesOutput, error)
	SetQueueAttributes(ctx context.Context, input *sqs.SetQueueAttributesInput, opts ...func(*sqs.Options)) (*sqs.SetQueueAttributesOutput, error)
	GetQueueUrl(ctx context.Context, input *sqs.GetQueueUrlInput, opts ...func(*sqs.Options)) (*sqs.GetQueueUrlOutput, error)
}

Client defines Queue client operations

func NewClient

func NewClient(cfg aws.Config) Client

NewClient returns a new SQS Client.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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