sqs

Documentation

Index

• Constants
• func GenerateCreateAttributes(p *v1beta1.QueueParameters) map[string]string
• func GenerateQueueAttributes(p *v1beta1.QueueParameters) map[string]string
• func GenerateQueueObservation(url string, attr map[string]string) v1beta1.QueueObservation
• func GetConnectionDetails(in v1beta1.Queue) managed.ConnectionDetails
• func IsNotFound(err error) bool
• func IsUpToDate(p v1beta1.QueueParameters, attributes map[string]string, ...) bool
• func LateInitialize(in *v1beta1.QueueParameters, attributes map[string]string, ...)
• func TagsDiff(sqsTags map[string]string, newTags map[string]string) (removed, added map[string]string)
• type Client
  • func NewClient(cfg aws.Config) Client

Constants

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

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.