Documentation ¶
Overview ¶
+k8s:deepcopy-gen=package Package v1alpha1 is the v1alpha1 version of the sqs.services.k8s.aws API. +groupName=sqs.services.k8s.aws
Index ¶
- Variables
- type BatchResultErrorEntry
- type ChangeMessageVisibilityBatchRequestEntry
- type ChangeMessageVisibilityBatchResultEntry
- type DeleteMessageBatchRequestEntry
- type DeleteMessageBatchResultEntry
- type Message
- type MessageAttributeValue
- type MessageSystemAttributeName
- type MessageSystemAttributeNameForSends
- type MessageSystemAttributeValue
- type Queue
- type QueueAttributeName
- type QueueList
- type QueueSpec
- type QueueStatus
- type SendMessageBatchRequestEntry
- type SendMessageBatchResultEntry
Constants ¶
This section is empty.
Variables ¶
var ( // GroupVersion is the API Group Version used to register the objects GroupVersion = schema.GroupVersion{Group: "sqs.services.k8s.aws", Version: "v1alpha1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion} // AddToScheme adds the types in this group-version to the given scheme. AddToScheme = SchemeBuilder.AddToScheme )
Functions ¶
This section is empty.
Types ¶
type BatchResultErrorEntry ¶
type BatchResultErrorEntry struct { Code *string `json:"code,omitempty"` ID *string `json:"id,omitempty"` Message *string `json:"message,omitempty"` }
Gives a detailed description of the result of an action on each entry in the request.
func (*BatchResultErrorEntry) DeepCopy ¶
func (in *BatchResultErrorEntry) DeepCopy() *BatchResultErrorEntry
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BatchResultErrorEntry.
func (*BatchResultErrorEntry) DeepCopyInto ¶
func (in *BatchResultErrorEntry) DeepCopyInto(out *BatchResultErrorEntry)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ChangeMessageVisibilityBatchRequestEntry ¶
type ChangeMessageVisibilityBatchRequestEntry struct { ID *string `json:"id,omitempty"` ReceiptHandle *string `json:"receiptHandle,omitempty"` }
Encloses a receipt handle and an entry id for each message in ChangeMessageVisibilityBatch.
All of the following list parameters must be prefixed with ChangeMessageVisibilityBatchRequestEntry.n, where n is an integer value starting with 1. For example, a parameter list for this action might look like this:
&ChangeMessageVisibilityBatchRequestEntry.1.Id=change_visibility_msg_2
&ChangeMessageVisibilityBatchRequestEntry.1.ReceiptHandle=your_receipt_handle
&ChangeMessageVisibilityBatchRequestEntry.1.VisibilityTimeout=45
func (*ChangeMessageVisibilityBatchRequestEntry) DeepCopy ¶
func (in *ChangeMessageVisibilityBatchRequestEntry) DeepCopy() *ChangeMessageVisibilityBatchRequestEntry
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChangeMessageVisibilityBatchRequestEntry.
func (*ChangeMessageVisibilityBatchRequestEntry) DeepCopyInto ¶
func (in *ChangeMessageVisibilityBatchRequestEntry) DeepCopyInto(out *ChangeMessageVisibilityBatchRequestEntry)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ChangeMessageVisibilityBatchResultEntry ¶
type ChangeMessageVisibilityBatchResultEntry struct {
ID *string `json:"id,omitempty"`
}
Encloses the Id of an entry in ChangeMessageVisibilityBatch.
func (*ChangeMessageVisibilityBatchResultEntry) DeepCopy ¶
func (in *ChangeMessageVisibilityBatchResultEntry) DeepCopy() *ChangeMessageVisibilityBatchResultEntry
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChangeMessageVisibilityBatchResultEntry.
func (*ChangeMessageVisibilityBatchResultEntry) DeepCopyInto ¶
func (in *ChangeMessageVisibilityBatchResultEntry) DeepCopyInto(out *ChangeMessageVisibilityBatchResultEntry)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeleteMessageBatchRequestEntry ¶
type DeleteMessageBatchRequestEntry struct { ID *string `json:"id,omitempty"` ReceiptHandle *string `json:"receiptHandle,omitempty"` }
Encloses a receipt handle and an identifier for it.
func (*DeleteMessageBatchRequestEntry) DeepCopy ¶
func (in *DeleteMessageBatchRequestEntry) DeepCopy() *DeleteMessageBatchRequestEntry
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeleteMessageBatchRequestEntry.
func (*DeleteMessageBatchRequestEntry) DeepCopyInto ¶
func (in *DeleteMessageBatchRequestEntry) DeepCopyInto(out *DeleteMessageBatchRequestEntry)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DeleteMessageBatchResultEntry ¶
type DeleteMessageBatchResultEntry struct {
ID *string `json:"id,omitempty"`
}
Encloses the Id of an entry in DeleteMessageBatch.
func (*DeleteMessageBatchResultEntry) DeepCopy ¶
func (in *DeleteMessageBatchResultEntry) DeepCopy() *DeleteMessageBatchResultEntry
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DeleteMessageBatchResultEntry.
func (*DeleteMessageBatchResultEntry) DeepCopyInto ¶
func (in *DeleteMessageBatchResultEntry) DeepCopyInto(out *DeleteMessageBatchResultEntry)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Message ¶
type Message struct { Body *string `json:"body,omitempty"` MD5OfBody *string `json:"md5OfBody,omitempty"` MD5OfMessageAttributes *string `json:"md5OfMessageAttributes,omitempty"` MessageID *string `json:"messageID,omitempty"` ReceiptHandle *string `json:"receiptHandle,omitempty"` }
An Amazon SQS message.
func (*Message) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Message.
func (*Message) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MessageAttributeValue ¶
type MessageAttributeValue struct { DataType *string `json:"dataType,omitempty"` StringValue *string `json:"stringValue,omitempty"` }
The user-specified message attribute value. For string data types, the Value attribute has the same restrictions on the content as the message body. For more information, see SendMessage.
Name, type, value and the message body must not be empty or null. All parts of the message attribute, including Name, Type, and Value, are part of the message size restriction (256 KB or 262,144 bytes).
func (*MessageAttributeValue) DeepCopy ¶
func (in *MessageAttributeValue) DeepCopy() *MessageAttributeValue
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MessageAttributeValue.
func (*MessageAttributeValue) DeepCopyInto ¶
func (in *MessageAttributeValue) DeepCopyInto(out *MessageAttributeValue)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MessageSystemAttributeName ¶
type MessageSystemAttributeName string
const ( MessageSystemAttributeName_SenderId MessageSystemAttributeName = "SenderId" MessageSystemAttributeName_SentTimestamp MessageSystemAttributeName = "SentTimestamp" MessageSystemAttributeName_ApproximateReceiveCount MessageSystemAttributeName = "ApproximateReceiveCount" MessageSystemAttributeName_ApproximateFirstReceiveTimestamp MessageSystemAttributeName = "ApproximateFirstReceiveTimestamp" MessageSystemAttributeName_SequenceNumber MessageSystemAttributeName = "SequenceNumber" MessageSystemAttributeName_MessageDeduplicationId MessageSystemAttributeName = "MessageDeduplicationId" MessageSystemAttributeName_MessageGroupId MessageSystemAttributeName = "MessageGroupId" MessageSystemAttributeName_AWSTraceHeader MessageSystemAttributeName = "AWSTraceHeader" )
type MessageSystemAttributeNameForSends ¶
type MessageSystemAttributeNameForSends string
const (
MessageSystemAttributeNameForSends_AWSTraceHeader MessageSystemAttributeNameForSends = "AWSTraceHeader"
)
type MessageSystemAttributeValue ¶
type MessageSystemAttributeValue struct { DataType *string `json:"dataType,omitempty"` StringValue *string `json:"stringValue,omitempty"` }
The user-specified message system attribute value. For string data types, the Value attribute has the same restrictions on the content as the message body. For more information, see SendMessage.
Name, type, value and the message body must not be empty or null.
func (*MessageSystemAttributeValue) DeepCopy ¶
func (in *MessageSystemAttributeValue) DeepCopy() *MessageSystemAttributeValue
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MessageSystemAttributeValue.
func (*MessageSystemAttributeValue) DeepCopyInto ¶
func (in *MessageSystemAttributeValue) DeepCopyInto(out *MessageSystemAttributeValue)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Queue ¶
type Queue struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec QueueSpec `json:"spec,omitempty"` Status QueueStatus `json:"status,omitempty"` }
Queue is the Schema for the Queues API +kubebuilder:object:root=true +kubebuilder:subresource:status
func (*Queue) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Queue.
func (*Queue) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Queue) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type QueueAttributeName ¶
type QueueAttributeName string
const ( QueueAttributeName_All QueueAttributeName = "All" QueueAttributeName_Policy QueueAttributeName = "Policy" QueueAttributeName_VisibilityTimeout QueueAttributeName = "VisibilityTimeout" QueueAttributeName_MaximumMessageSize QueueAttributeName = "MaximumMessageSize" QueueAttributeName_MessageRetentionPeriod QueueAttributeName = "MessageRetentionPeriod" QueueAttributeName_ApproximateNumberOfMessages QueueAttributeName = "ApproximateNumberOfMessages" QueueAttributeName_ApproximateNumberOfMessagesNotVisible QueueAttributeName = "ApproximateNumberOfMessagesNotVisible" QueueAttributeName_CreatedTimestamp QueueAttributeName = "CreatedTimestamp" QueueAttributeName_LastModifiedTimestamp QueueAttributeName = "LastModifiedTimestamp" QueueAttributeName_QueueArn QueueAttributeName = "QueueArn" QueueAttributeName_ApproximateNumberOfMessagesDelayed QueueAttributeName = "ApproximateNumberOfMessagesDelayed" QueueAttributeName_DelaySeconds QueueAttributeName = "DelaySeconds" QueueAttributeName_ReceiveMessageWaitTimeSeconds QueueAttributeName = "ReceiveMessageWaitTimeSeconds" QueueAttributeName_RedrivePolicy QueueAttributeName = "RedrivePolicy" QueueAttributeName_FifoQueue QueueAttributeName = "FifoQueue" QueueAttributeName_ContentBasedDeduplication QueueAttributeName = "ContentBasedDeduplication" QueueAttributeName_KmsMasterKeyId QueueAttributeName = "KmsMasterKeyId" QueueAttributeName_KmsDataKeyReusePeriodSeconds QueueAttributeName = "KmsDataKeyReusePeriodSeconds" QueueAttributeName_DeduplicationScope QueueAttributeName = "DeduplicationScope" QueueAttributeName_FifoThroughputLimit QueueAttributeName = "FifoThroughputLimit" QueueAttributeName_RedriveAllowPolicy QueueAttributeName = "RedriveAllowPolicy" QueueAttributeName_SqsManagedSseEnabled QueueAttributeName = "SqsManagedSseEnabled" )
type QueueList ¶
type QueueList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Queue `json:"items"` }
QueueList contains a list of Queue +kubebuilder:object:root=true
func (*QueueList) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueList.
func (*QueueList) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*QueueList) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type QueueSpec ¶
type QueueSpec struct { ContentBasedDeduplication *string `json:"contentBasedDeduplication,omitempty"` DelaySeconds *string `json:"delaySeconds,omitempty"` FIFOQueue *string `json:"fifoQueue,omitempty"` KMSDataKeyReusePeriodSeconds *string `json:"kmsDataKeyReusePeriodSeconds,omitempty"` KMSMasterKeyID *string `json:"kmsMasterKeyID,omitempty"` KMSMasterKeyRef *ackv1alpha1.AWSResourceReferenceWrapper `json:"kmsMasterKeyRef,omitempty"` MaximumMessageSize *string `json:"maximumMessageSize,omitempty"` MessageRetentionPeriod *string `json:"messageRetentionPeriod,omitempty"` Policy *string `json:"policy,omitempty"` PolicyRef *ackv1alpha1.AWSResourceReferenceWrapper `json:"policyRef,omitempty"` // +kubebuilder:validation:Required QueueName *string `json:"queueName"` ReceiveMessageWaitTimeSeconds *string `json:"receiveMessageWaitTimeSeconds,omitempty"` RedrivePolicy *string `json:"redrivePolicy,omitempty"` // Add cost allocation tags to the specified Amazon SQS queue. For an overview, // see Tagging Your Amazon SQS Queues (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-queue-tags.html) // in the Amazon SQS Developer Guide. // // When you use queue tags, keep the following guidelines in mind: // // - Adding more than 50 tags to a queue isn't recommended. // // - Tags don't have any semantic meaning. Amazon SQS interprets tags as // character strings. // // - Tags are case-sensitive. // // - A new tag with a key identical to that of an existing tag overwrites // the existing tag. // // For a full list of tag restrictions, see Quotas related to queues (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-limits.html#limits-queues) // in the Amazon SQS Developer Guide. // // To be able to tag a queue on creation, you must have the sqs:CreateQueue // and sqs:TagQueue permissions. // // Cross-account permissions don't apply to this action. For more information, // see Grant cross-account permissions to a role and a user name (https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-customer-managed-policy-examples.html#grant-cross-account-permissions-to-role-and-user-name) // in the Amazon SQS Developer Guide. Tags map[string]*string `json:"tags,omitempty"` VisibilityTimeout *string `json:"visibilityTimeout,omitempty"` }
QueueSpec defines the desired state of Queue.
func (*QueueSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueSpec.
func (*QueueSpec) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type QueueStatus ¶
type QueueStatus struct { // All CRs managed by ACK have a common `Status.ACKResourceMetadata` member // that is used to contain resource sync state, account ownership, // constructed ARN for the resource // +kubebuilder:validation:Optional ACKResourceMetadata *ackv1alpha1.ResourceMetadata `json:"ackResourceMetadata"` // All CRS managed by ACK have a common `Status.Conditions` member that // contains a collection of `ackv1alpha1.Condition` objects that describe // the various terminal states of the CR and its backend AWS service API // resource // +kubebuilder:validation:Optional Conditions []*ackv1alpha1.Condition `json:"conditions"` // The URL of the created Amazon SQS queue. // +kubebuilder:validation:Optional QueueURL *string `json:"queueURL,omitempty"` }
QueueStatus defines the observed state of Queue
func (*QueueStatus) DeepCopy ¶
func (in *QueueStatus) DeepCopy() *QueueStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueStatus.
func (*QueueStatus) DeepCopyInto ¶
func (in *QueueStatus) DeepCopyInto(out *QueueStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SendMessageBatchRequestEntry ¶
type SendMessageBatchRequestEntry struct { ID *string `json:"id,omitempty"` MessageBody *string `json:"messageBody,omitempty"` MessageDeduplicationID *string `json:"messageDeduplicationID,omitempty"` MessageGroupID *string `json:"messageGroupID,omitempty"` }
Contains the details of a single Amazon SQS message along with an Id.
func (*SendMessageBatchRequestEntry) DeepCopy ¶
func (in *SendMessageBatchRequestEntry) DeepCopy() *SendMessageBatchRequestEntry
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SendMessageBatchRequestEntry.
func (*SendMessageBatchRequestEntry) DeepCopyInto ¶
func (in *SendMessageBatchRequestEntry) DeepCopyInto(out *SendMessageBatchRequestEntry)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SendMessageBatchResultEntry ¶
type SendMessageBatchResultEntry struct { ID *string `json:"id,omitempty"` MD5OfMessageAttributes *string `json:"md5OfMessageAttributes,omitempty"` MD5OfMessageBody *string `json:"md5OfMessageBody,omitempty"` MD5OfMessageSystemAttributes *string `json:"md5OfMessageSystemAttributes,omitempty"` MessageID *string `json:"messageID,omitempty"` SequenceNumber *string `json:"sequenceNumber,omitempty"` }
Encloses a MessageId for a successfully-enqueued message in a SendMessageBatch.
func (*SendMessageBatchResultEntry) DeepCopy ¶
func (in *SendMessageBatchResultEntry) DeepCopy() *SendMessageBatchResultEntry
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SendMessageBatchResultEntry.
func (*SendMessageBatchResultEntry) DeepCopyInto ¶
func (in *SendMessageBatchResultEntry) DeepCopyInto(out *SendMessageBatchResultEntry)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.