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
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 ¶ added in v0.12.0
func GenerateQueueObservation(url string, attr map[string]string) v1beta1.QueueObservation
GenerateQueueObservation returns a QueueObservation with information retrieved from AWS.
func GetConnectionDetails ¶ added in v0.17.0
func GetConnectionDetails(in v1beta1.Queue) managed.ConnectionDetails
GetConnectionDetails extracts managed.ConnectionDetails out of v1beta1.Queue.
func IsNotFound ¶
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
Types ¶
type Client ¶
type Client interface { CreateQueueRequest(input *sqs.CreateQueueInput) sqs.CreateQueueRequest DeleteQueueRequest(input *sqs.DeleteQueueInput) sqs.DeleteQueueRequest TagQueueRequest(input *sqs.TagQueueInput) sqs.TagQueueRequest ListQueueTagsRequest(*sqs.ListQueueTagsInput) sqs.ListQueueTagsRequest GetQueueAttributesRequest(*sqs.GetQueueAttributesInput) sqs.GetQueueAttributesRequest SetQueueAttributesRequest(input *sqs.SetQueueAttributesInput) sqs.SetQueueAttributesRequest UntagQueueRequest(input *sqs.UntagQueueInput) sqs.UntagQueueRequest GetQueueUrlRequest(input *sqs.GetQueueUrlInput) sqs.GetQueueUrlRequest }
Client defines Queue client operations
Click to show internal directories.
Click to hide internal directories.