v1beta1

package
v0.0.0-...-274ce61 Latest Latest
Warning

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

 Go to latest Published: May 9, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

+kubebuilder:object:generate=true +groupName=sqs.aws.upbound.io +versionName=v1beta1

Index

Constants

View Source 
const (
	CRDGroup   = "sqs.aws.upbound.io"
	CRDVersion = "v1beta1"
)

Package type metadata.

Variables

View Source 
var (
	// CRDGroupVersion is the API Group Version used to register the objects
	CRDGroupVersion = schema.GroupVersion{Group: CRDGroup, Version: CRDVersion}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: CRDGroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var (
	Queue_Kind             = "Queue"
	Queue_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Queue_Kind}.String()
	Queue_KindAPIVersion   = Queue_Kind + "." + CRDGroupVersion.String()
	Queue_GroupVersionKind = CRDGroupVersion.WithKind(Queue_Kind)
)

Repository type metadata.

View Source 
var (
	QueuePolicy_Kind             = "QueuePolicy"
	QueuePolicy_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: QueuePolicy_Kind}.String()
	QueuePolicy_KindAPIVersion   = QueuePolicy_Kind + "." + CRDGroupVersion.String()
	QueuePolicy_GroupVersionKind = CRDGroupVersion.WithKind(QueuePolicy_Kind)
)

Repository type metadata.

View Source 
var (
	QueueRedriveAllowPolicy_Kind             = "QueueRedriveAllowPolicy"
	QueueRedriveAllowPolicy_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: QueueRedriveAllowPolicy_Kind}.String()
	QueueRedriveAllowPolicy_KindAPIVersion   = QueueRedriveAllowPolicy_Kind + "." + CRDGroupVersion.String()
	QueueRedriveAllowPolicy_GroupVersionKind = CRDGroupVersion.WithKind(QueueRedriveAllowPolicy_Kind)
)

Repository type metadata.

View Source 
var (
	QueueRedrivePolicy_Kind             = "QueueRedrivePolicy"
	QueueRedrivePolicy_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: QueueRedrivePolicy_Kind}.String()
	QueueRedrivePolicy_KindAPIVersion   = QueueRedrivePolicy_Kind + "." + CRDGroupVersion.String()
	QueueRedrivePolicy_GroupVersionKind = CRDGroupVersion.WithKind(QueueRedrivePolicy_Kind)
)

Repository type metadata.

Functions

This section is empty.

Types

type Queue 

type Queue struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              QueueSpec   `json:"spec"`
	Status            QueueStatus `json:"status,omitempty"`
}

Queue is the Schema for the Queues API. Provides a SQS resource. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}

func (*Queue) DeepCopy 

func (in *Queue) DeepCopy() *Queue

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Queue.

func (*Queue) DeepCopyInto 

func (in *Queue) DeepCopyInto(out *Queue)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Queue) DeepCopyObject 

func (in *Queue) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Queue) GetCondition 

func (mg *Queue) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this Queue.

func (*Queue) GetConnectionDetailsMapping 

func (tr *Queue) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this Queue

func (*Queue) GetDeletionPolicy 

func (mg *Queue) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Queue.

func (*Queue) GetID 

func (tr *Queue) GetID() string

GetID returns ID of underlying Terraform resource of this Queue

func (*Queue) GetManagementPolicy 

func (mg *Queue) GetManagementPolicy() xpv1.ManagementPolicy

GetManagementPolicy of this Queue.

func (*Queue) GetObservation 

func (tr *Queue) GetObservation() (map[string]any, error)

GetObservation of this Queue

func (*Queue) GetParameters 

func (tr *Queue) GetParameters() (map[string]any, error)

GetParameters of this Queue

func (*Queue) GetProviderConfigReference 

func (mg *Queue) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this Queue.

func (*Queue) GetProviderReference 

func (mg *Queue) GetProviderReference() *xpv1.Reference

GetProviderReference of this Queue. Deprecated: Use GetProviderConfigReference.

func (*Queue) GetPublishConnectionDetailsTo 

func (mg *Queue) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this Queue.

func (*Queue) GetTerraformResourceType 

func (mg *Queue) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Queue

func (*Queue) GetTerraformSchemaVersion 

func (tr *Queue) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Queue) GetWriteConnectionSecretToReference 

func (mg *Queue) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this Queue.

func (*Queue) LateInitialize 

func (tr *Queue) LateInitialize(attrs []byte) (bool, error)

LateInitialize this Queue using its observed tfState. returns True if there are any spec changes for the resource.

func (*Queue) SetConditions 

func (mg *Queue) SetConditions(c ...xpv1.Condition)

SetConditions of this Queue.

func (*Queue) SetDeletionPolicy 

func (mg *Queue) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this Queue.

func (*Queue) SetManagementPolicy 

func (mg *Queue) SetManagementPolicy(r xpv1.ManagementPolicy)

SetManagementPolicy of this Queue.

func (*Queue) SetObservation 

func (tr *Queue) SetObservation(obs map[string]any) error

SetObservation for this Queue

func (*Queue) SetParameters 

func (tr *Queue) SetParameters(params map[string]any) error

SetParameters for this Queue

func (*Queue) SetProviderConfigReference 

func (mg *Queue) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this Queue.

func (*Queue) SetProviderReference 

func (mg *Queue) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this Queue. Deprecated: Use SetProviderConfigReference.

func (*Queue) SetPublishConnectionDetailsTo 

func (mg *Queue) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this Queue.

func (*Queue) SetWriteConnectionSecretToReference 

func (mg *Queue) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this Queue.

type QueueList 

type QueueList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Queue `json:"items"`
}

QueueList contains a list of Queues

func (*QueueList) DeepCopy 

func (in *QueueList) DeepCopy() *QueueList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueList.

func (*QueueList) DeepCopyInto 

func (in *QueueList) DeepCopyInto(out *QueueList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*QueueList) DeepCopyObject 

func (in *QueueList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*QueueList) GetItems 

func (l *QueueList) GetItems() []resource.Managed

GetItems of this QueueList.

type QueueObservation 

type QueueObservation struct {

	// The ARN of the SQS queue
	Arn *string `json:"arn,omitempty" tf:"arn,omitempty"`

	// Enables content-based deduplication for FIFO queues. For more information, see the related documentation
	ContentBasedDeduplication *bool `json:"contentBasedDeduplication,omitempty" tf:"content_based_deduplication,omitempty"`

	// Specifies whether message deduplication occurs at the message group or queue level. Valid values are messageGroup and queue (default).
	DeduplicationScope *string `json:"deduplicationScope,omitempty" tf:"deduplication_scope,omitempty"`

	// The time in seconds that the delivery of all messages in the queue will be delayed. An integer from 0 to 900 (15 minutes). The default for this attribute is 0 seconds.
	DelaySeconds *float64 `json:"delaySeconds,omitempty" tf:"delay_seconds,omitempty"`

	// Boolean designating a FIFO queue. If not set, it defaults to false making it standard.
	FifoQueue *bool `json:"fifoQueue,omitempty" tf:"fifo_queue,omitempty"`

	// Specifies whether the FIFO queue throughput quota applies to the entire queue or per message group. Valid values are perQueue (default) and perMessageGroupId.
	FifoThroughputLimit *string `json:"fifoThroughputLimit,omitempty" tf:"fifo_throughput_limit,omitempty"`

	// The URL for the created Amazon SQS queue.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The length of time, in seconds, for which Amazon SQS can reuse a data key to encrypt or decrypt messages before calling AWS KMS again. An integer representing seconds, between 60 seconds (1 minute) and 86,400 seconds (24 hours). The default is 300 (5 minutes).
	KMSDataKeyReusePeriodSeconds *float64 `json:"kmsDataKeyReusePeriodSeconds,omitempty" tf:"kms_data_key_reuse_period_seconds,omitempty"`

	// The ID of an AWS-managed customer master key (CMK) for Amazon SQS or a custom CMK. For more information, see Key Terms.
	KMSMasterKeyID *string `json:"kmsMasterKeyId,omitempty" tf:"kms_master_key_id,omitempty"`

	// The limit of how many bytes a message can contain before Amazon SQS rejects it. An integer from 1024 bytes (1 KiB) up to 262144 bytes (256 KiB). The default for this attribute is 262144 (256 KiB).
	MaxMessageSize *float64 `json:"maxMessageSize,omitempty" tf:"max_message_size,omitempty"`

	// The number of seconds Amazon SQS retains a message. Integer representing seconds, from 60 (1 minute) to 1209600 (14 days). The default for this attribute is 345600 (4 days).
	MessageRetentionSeconds *float64 `json:"messageRetentionSeconds,omitempty" tf:"message_retention_seconds,omitempty"`

	// The name of the queue. Queue names must be made up of only uppercase and lowercase ASCII letters, numbers, underscores, and hyphens, and must be between 1 and 80 characters long. For a FIFO (first-in-first-out) queue, the name must end with the .fifo suffix. Conflicts with name_prefix
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// The JSON policy for the SQS queue.
	Policy *string `json:"policy,omitempty" tf:"policy,omitempty"`

	// The time for which a ReceiveMessage call will wait for a message to arrive (long polling) before returning. An integer from 0 to 20 (seconds). The default for this attribute is 0, meaning that the call will return immediately.
	ReceiveWaitTimeSeconds *float64 `json:"receiveWaitTimeSeconds,omitempty" tf:"receive_wait_time_seconds,omitempty"`

	// The JSON policy to set up the Dead Letter Queue redrive permission, see AWS docs.
	RedriveAllowPolicy *string `json:"redriveAllowPolicy,omitempty" tf:"redrive_allow_policy,omitempty"`

	// The JSON policy to set up the Dead Letter Queue, see AWS docs. Note: when specifying maxReceiveCount, you must specify it as an integer (5), and not a string ("5").
	RedrivePolicy *string `json:"redrivePolicy,omitempty" tf:"redrive_policy,omitempty"`

	// Boolean to enable server-side encryption (SSE) of message content with SQS-owned encryption keys. See Encryption at rest.
	SqsManagedSseEnabled *bool `json:"sqsManagedSseEnabled,omitempty" tf:"sqs_managed_sse_enabled,omitempty"`

	// Key-value map of resource tags.
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`

	// A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.
	TagsAll map[string]*string `json:"tagsAll,omitempty" tf:"tags_all,omitempty"`

	// Same as id: The URL for the created Amazon SQS queue.
	URL *string `json:"url,omitempty" tf:"url,omitempty"`

	// The visibility timeout for the queue. An integer from 0 to 43200 (12 hours). The default for this attribute is 30. For more information about visibility timeout, see AWS docs.
	VisibilityTimeoutSeconds *float64 `json:"visibilityTimeoutSeconds,omitempty" tf:"visibility_timeout_seconds,omitempty"`
}

func (*QueueObservation) DeepCopy 

func (in *QueueObservation) DeepCopy() *QueueObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueObservation.

func (*QueueObservation) DeepCopyInto 

func (in *QueueObservation) DeepCopyInto(out *QueueObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueueParameters 

type QueueParameters struct {

	// Enables content-based deduplication for FIFO queues. For more information, see the related documentation
	// +kubebuilder:validation:Optional
	ContentBasedDeduplication *bool `json:"contentBasedDeduplication,omitempty" tf:"content_based_deduplication,omitempty"`

	// Specifies whether message deduplication occurs at the message group or queue level. Valid values are messageGroup and queue (default).
	// +kubebuilder:validation:Optional
	DeduplicationScope *string `json:"deduplicationScope,omitempty" tf:"deduplication_scope,omitempty"`

	// The time in seconds that the delivery of all messages in the queue will be delayed. An integer from 0 to 900 (15 minutes). The default for this attribute is 0 seconds.
	// +kubebuilder:validation:Optional
	DelaySeconds *float64 `json:"delaySeconds,omitempty" tf:"delay_seconds,omitempty"`

	// Boolean designating a FIFO queue. If not set, it defaults to false making it standard.
	// +kubebuilder:validation:Optional
	FifoQueue *bool `json:"fifoQueue,omitempty" tf:"fifo_queue,omitempty"`

	// Specifies whether the FIFO queue throughput quota applies to the entire queue or per message group. Valid values are perQueue (default) and perMessageGroupId.
	// +kubebuilder:validation:Optional
	FifoThroughputLimit *string `json:"fifoThroughputLimit,omitempty" tf:"fifo_throughput_limit,omitempty"`

	// The length of time, in seconds, for which Amazon SQS can reuse a data key to encrypt or decrypt messages before calling AWS KMS again. An integer representing seconds, between 60 seconds (1 minute) and 86,400 seconds (24 hours). The default is 300 (5 minutes).
	// +kubebuilder:validation:Optional
	KMSDataKeyReusePeriodSeconds *float64 `json:"kmsDataKeyReusePeriodSeconds,omitempty" tf:"kms_data_key_reuse_period_seconds,omitempty"`

	// The ID of an AWS-managed customer master key (CMK) for Amazon SQS or a custom CMK. For more information, see Key Terms.
	// +kubebuilder:validation:Optional
	KMSMasterKeyID *string `json:"kmsMasterKeyId,omitempty" tf:"kms_master_key_id,omitempty"`

	// The limit of how many bytes a message can contain before Amazon SQS rejects it. An integer from 1024 bytes (1 KiB) up to 262144 bytes (256 KiB). The default for this attribute is 262144 (256 KiB).
	// +kubebuilder:validation:Optional
	MaxMessageSize *float64 `json:"maxMessageSize,omitempty" tf:"max_message_size,omitempty"`

	// The number of seconds Amazon SQS retains a message. Integer representing seconds, from 60 (1 minute) to 1209600 (14 days). The default for this attribute is 345600 (4 days).
	// +kubebuilder:validation:Optional
	MessageRetentionSeconds *float64 `json:"messageRetentionSeconds,omitempty" tf:"message_retention_seconds,omitempty"`

	// The name of the queue. Queue names must be made up of only uppercase and lowercase ASCII letters, numbers, underscores, and hyphens, and must be between 1 and 80 characters long. For a FIFO (first-in-first-out) queue, the name must end with the .fifo suffix. Conflicts with name_prefix
	// +kubebuilder:validation:Optional
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// The JSON policy for the SQS queue.
	// +kubebuilder:validation:Optional
	Policy *string `json:"policy,omitempty" tf:"policy,omitempty"`

	// The time for which a ReceiveMessage call will wait for a message to arrive (long polling) before returning. An integer from 0 to 20 (seconds). The default for this attribute is 0, meaning that the call will return immediately.
	// +kubebuilder:validation:Optional
	ReceiveWaitTimeSeconds *float64 `json:"receiveWaitTimeSeconds,omitempty" tf:"receive_wait_time_seconds,omitempty"`

	// The JSON policy to set up the Dead Letter Queue redrive permission, see AWS docs.
	// +kubebuilder:validation:Optional
	RedriveAllowPolicy *string `json:"redriveAllowPolicy,omitempty" tf:"redrive_allow_policy,omitempty"`

	// The JSON policy to set up the Dead Letter Queue, see AWS docs. Note: when specifying maxReceiveCount, you must specify it as an integer (5), and not a string ("5").
	// +kubebuilder:validation:Optional
	RedrivePolicy *string `json:"redrivePolicy,omitempty" tf:"redrive_policy,omitempty"`

	// Region is the region you'd like your resource to be created in.
	// +upjet:crd:field:TFTag=-
	// +kubebuilder:validation:Required
	Region *string `json:"region" tf:"-"`

	// Boolean to enable server-side encryption (SSE) of message content with SQS-owned encryption keys. See Encryption at rest.
	// +kubebuilder:validation:Optional
	SqsManagedSseEnabled *bool `json:"sqsManagedSseEnabled,omitempty" tf:"sqs_managed_sse_enabled,omitempty"`

	// Key-value map of resource tags.
	// +kubebuilder:validation:Optional
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`

	// The visibility timeout for the queue. An integer from 0 to 43200 (12 hours). The default for this attribute is 30. For more information about visibility timeout, see AWS docs.
	// +kubebuilder:validation:Optional
	VisibilityTimeoutSeconds *float64 `json:"visibilityTimeoutSeconds,omitempty" tf:"visibility_timeout_seconds,omitempty"`
}

func (*QueueParameters) DeepCopy 

func (in *QueueParameters) DeepCopy() *QueueParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueParameters.

func (*QueueParameters) DeepCopyInto 

func (in *QueueParameters) DeepCopyInto(out *QueueParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueuePolicy 

type QueuePolicy struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.policy)",message="policy is a required parameter"
	Spec   QueuePolicySpec   `json:"spec"`
	Status QueuePolicyStatus `json:"status,omitempty"`
}

QueuePolicy is the Schema for the QueuePolicys API. Provides a SQS Queue Policy resource. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}

func (*QueuePolicy) DeepCopy 

func (in *QueuePolicy) DeepCopy() *QueuePolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueuePolicy.

func (*QueuePolicy) DeepCopyInto 

func (in *QueuePolicy) DeepCopyInto(out *QueuePolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*QueuePolicy) DeepCopyObject 

func (in *QueuePolicy) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*QueuePolicy) GetCondition 

func (mg *QueuePolicy) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this QueuePolicy.

func (*QueuePolicy) GetConnectionDetailsMapping 

func (tr *QueuePolicy) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this QueuePolicy

func (*QueuePolicy) GetDeletionPolicy 

func (mg *QueuePolicy) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this QueuePolicy.

func (*QueuePolicy) GetID 

func (tr *QueuePolicy) GetID() string

GetID returns ID of underlying Terraform resource of this QueuePolicy

func (*QueuePolicy) GetManagementPolicy 

func (mg *QueuePolicy) GetManagementPolicy() xpv1.ManagementPolicy

GetManagementPolicy of this QueuePolicy.

func (*QueuePolicy) GetObservation 

func (tr *QueuePolicy) GetObservation() (map[string]any, error)

GetObservation of this QueuePolicy

func (*QueuePolicy) GetParameters 

func (tr *QueuePolicy) GetParameters() (map[string]any, error)

GetParameters of this QueuePolicy

func (*QueuePolicy) GetProviderConfigReference 

func (mg *QueuePolicy) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this QueuePolicy.

func (*QueuePolicy) GetProviderReference 

func (mg *QueuePolicy) GetProviderReference() *xpv1.Reference

GetProviderReference of this QueuePolicy. Deprecated: Use GetProviderConfigReference.

func (*QueuePolicy) GetPublishConnectionDetailsTo 

func (mg *QueuePolicy) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this QueuePolicy.

func (*QueuePolicy) GetTerraformResourceType 

func (mg *QueuePolicy) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this QueuePolicy

func (*QueuePolicy) GetTerraformSchemaVersion 

func (tr *QueuePolicy) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*QueuePolicy) GetWriteConnectionSecretToReference 

func (mg *QueuePolicy) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this QueuePolicy.

func (*QueuePolicy) LateInitialize 

func (tr *QueuePolicy) LateInitialize(attrs []byte) (bool, error)

LateInitialize this QueuePolicy using its observed tfState. returns True if there are any spec changes for the resource.

func (*QueuePolicy) ResolveReferences 

func (mg *QueuePolicy) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this QueuePolicy.

func (*QueuePolicy) SetConditions 

func (mg *QueuePolicy) SetConditions(c ...xpv1.Condition)

SetConditions of this QueuePolicy.

func (*QueuePolicy) SetDeletionPolicy 

func (mg *QueuePolicy) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this QueuePolicy.

func (*QueuePolicy) SetManagementPolicy 

func (mg *QueuePolicy) SetManagementPolicy(r xpv1.ManagementPolicy)

SetManagementPolicy of this QueuePolicy.

func (*QueuePolicy) SetObservation 

func (tr *QueuePolicy) SetObservation(obs map[string]any) error

SetObservation for this QueuePolicy

func (*QueuePolicy) SetParameters 

func (tr *QueuePolicy) SetParameters(params map[string]any) error

SetParameters for this QueuePolicy

func (*QueuePolicy) SetProviderConfigReference 

func (mg *QueuePolicy) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this QueuePolicy.

func (*QueuePolicy) SetProviderReference 

func (mg *QueuePolicy) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this QueuePolicy. Deprecated: Use SetProviderConfigReference.

func (*QueuePolicy) SetPublishConnectionDetailsTo 

func (mg *QueuePolicy) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this QueuePolicy.

func (*QueuePolicy) SetWriteConnectionSecretToReference 

func (mg *QueuePolicy) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this QueuePolicy.

type QueuePolicyList 

type QueuePolicyList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []QueuePolicy `json:"items"`
}

QueuePolicyList contains a list of QueuePolicys

func (*QueuePolicyList) DeepCopy 

func (in *QueuePolicyList) DeepCopy() *QueuePolicyList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueuePolicyList.

func (*QueuePolicyList) DeepCopyInto 

func (in *QueuePolicyList) DeepCopyInto(out *QueuePolicyList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*QueuePolicyList) DeepCopyObject 

func (in *QueuePolicyList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*QueuePolicyList) GetItems 

func (l *QueuePolicyList) GetItems() []resource.Managed

GetItems of this QueuePolicyList.

type QueuePolicyObservation 

type QueuePolicyObservation struct {
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The JSON policy for the SQS queue.
	Policy *string `json:"policy,omitempty" tf:"policy,omitempty"`

	// The URL of the SQS Queue to which to attach the policy
	QueueURL *string `json:"queueUrl,omitempty" tf:"queue_url,omitempty"`
}

func (*QueuePolicyObservation) DeepCopy 

func (in *QueuePolicyObservation) DeepCopy() *QueuePolicyObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueuePolicyObservation.

func (*QueuePolicyObservation) DeepCopyInto 

func (in *QueuePolicyObservation) DeepCopyInto(out *QueuePolicyObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueuePolicyParameters 

type QueuePolicyParameters struct {

	// The JSON policy for the SQS queue.
	// +kubebuilder:validation:Optional
	Policy *string `json:"policy,omitempty" tf:"policy,omitempty"`

	// The URL of the SQS Queue to which to attach the policy
	// +crossplane:generate:reference:type=github.com/spirosco/upbound-provider-aws/apis/sqs/v1beta1.Queue
	// +crossplane:generate:reference:extractor=github.com/spirosco/upbound-provider-aws/config/common.TerraformID()
	// +kubebuilder:validation:Optional
	QueueURL *string `json:"queueUrl,omitempty" tf:"queue_url,omitempty"`

	// Reference to a Queue in sqs to populate queueUrl.
	// +kubebuilder:validation:Optional
	QueueURLRef *v1.Reference `json:"queueUrlRef,omitempty" tf:"-"`

	// Selector for a Queue in sqs to populate queueUrl.
	// +kubebuilder:validation:Optional
	QueueURLSelector *v1.Selector `json:"queueUrlSelector,omitempty" tf:"-"`

	// Region is the region you'd like your resource to be created in.
	// +upjet:crd:field:TFTag=-
	// +kubebuilder:validation:Required
	Region *string `json:"region" tf:"-"`
}

func (*QueuePolicyParameters) DeepCopy 

func (in *QueuePolicyParameters) DeepCopy() *QueuePolicyParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueuePolicyParameters.

func (*QueuePolicyParameters) DeepCopyInto 

func (in *QueuePolicyParameters) DeepCopyInto(out *QueuePolicyParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueuePolicySpec 

type QueuePolicySpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     QueuePolicyParameters `json:"forProvider"`
}

QueuePolicySpec defines the desired state of QueuePolicy

func (*QueuePolicySpec) DeepCopy 

func (in *QueuePolicySpec) DeepCopy() *QueuePolicySpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueuePolicySpec.

func (*QueuePolicySpec) DeepCopyInto 

func (in *QueuePolicySpec) DeepCopyInto(out *QueuePolicySpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueuePolicyStatus 

type QueuePolicyStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        QueuePolicyObservation `json:"atProvider,omitempty"`
}

QueuePolicyStatus defines the observed state of QueuePolicy.

func (*QueuePolicyStatus) DeepCopy 

func (in *QueuePolicyStatus) DeepCopy() *QueuePolicyStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueuePolicyStatus.

func (*QueuePolicyStatus) DeepCopyInto 

func (in *QueuePolicyStatus) DeepCopyInto(out *QueuePolicyStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueueRedriveAllowPolicy 

type QueueRedriveAllowPolicy struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.redriveAllowPolicy)",message="redriveAllowPolicy is a required parameter"
	Spec   QueueRedriveAllowPolicySpec   `json:"spec"`
	Status QueueRedriveAllowPolicyStatus `json:"status,omitempty"`
}

QueueRedriveAllowPolicy is the Schema for the QueueRedriveAllowPolicys API. Provides a SQS Queue Redrive Allow Policy resource. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}

func (*QueueRedriveAllowPolicy) DeepCopy 

func (in *QueueRedriveAllowPolicy) DeepCopy() *QueueRedriveAllowPolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueRedriveAllowPolicy.

func (*QueueRedriveAllowPolicy) DeepCopyInto 

func (in *QueueRedriveAllowPolicy) DeepCopyInto(out *QueueRedriveAllowPolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*QueueRedriveAllowPolicy) DeepCopyObject 

func (in *QueueRedriveAllowPolicy) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*QueueRedriveAllowPolicy) GetCondition 

func (mg *QueueRedriveAllowPolicy) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this QueueRedriveAllowPolicy.

func (*QueueRedriveAllowPolicy) GetConnectionDetailsMapping 

func (tr *QueueRedriveAllowPolicy) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this QueueRedriveAllowPolicy

func (*QueueRedriveAllowPolicy) GetDeletionPolicy 

func (mg *QueueRedriveAllowPolicy) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this QueueRedriveAllowPolicy.

func (*QueueRedriveAllowPolicy) GetID 

func (tr *QueueRedriveAllowPolicy) GetID() string

GetID returns ID of underlying Terraform resource of this QueueRedriveAllowPolicy

func (*QueueRedriveAllowPolicy) GetManagementPolicy 

func (mg *QueueRedriveAllowPolicy) GetManagementPolicy() xpv1.ManagementPolicy

GetManagementPolicy of this QueueRedriveAllowPolicy.

func (*QueueRedriveAllowPolicy) GetObservation 

func (tr *QueueRedriveAllowPolicy) GetObservation() (map[string]any, error)

GetObservation of this QueueRedriveAllowPolicy

func (*QueueRedriveAllowPolicy) GetParameters 

func (tr *QueueRedriveAllowPolicy) GetParameters() (map[string]any, error)

GetParameters of this QueueRedriveAllowPolicy

func (*QueueRedriveAllowPolicy) GetProviderConfigReference 

func (mg *QueueRedriveAllowPolicy) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this QueueRedriveAllowPolicy.

func (*QueueRedriveAllowPolicy) GetProviderReference 

func (mg *QueueRedriveAllowPolicy) GetProviderReference() *xpv1.Reference

GetProviderReference of this QueueRedriveAllowPolicy. Deprecated: Use GetProviderConfigReference.

func (*QueueRedriveAllowPolicy) GetPublishConnectionDetailsTo 

func (mg *QueueRedriveAllowPolicy) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this QueueRedriveAllowPolicy.

func (*QueueRedriveAllowPolicy) GetTerraformResourceType 

func (mg *QueueRedriveAllowPolicy) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this QueueRedriveAllowPolicy

func (*QueueRedriveAllowPolicy) GetTerraformSchemaVersion 

func (tr *QueueRedriveAllowPolicy) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*QueueRedriveAllowPolicy) GetWriteConnectionSecretToReference 

func (mg *QueueRedriveAllowPolicy) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this QueueRedriveAllowPolicy.

func (*QueueRedriveAllowPolicy) LateInitialize 

func (tr *QueueRedriveAllowPolicy) LateInitialize(attrs []byte) (bool, error)

LateInitialize this QueueRedriveAllowPolicy using its observed tfState. returns True if there are any spec changes for the resource.

func (*QueueRedriveAllowPolicy) ResolveReferences 

func (mg *QueueRedriveAllowPolicy) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this QueueRedriveAllowPolicy.

func (*QueueRedriveAllowPolicy) SetConditions 

func (mg *QueueRedriveAllowPolicy) SetConditions(c ...xpv1.Condition)

SetConditions of this QueueRedriveAllowPolicy.

func (*QueueRedriveAllowPolicy) SetDeletionPolicy 

func (mg *QueueRedriveAllowPolicy) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this QueueRedriveAllowPolicy.

func (*QueueRedriveAllowPolicy) SetManagementPolicy 

func (mg *QueueRedriveAllowPolicy) SetManagementPolicy(r xpv1.ManagementPolicy)

SetManagementPolicy of this QueueRedriveAllowPolicy.

func (*QueueRedriveAllowPolicy) SetObservation 

func (tr *QueueRedriveAllowPolicy) SetObservation(obs map[string]any) error

SetObservation for this QueueRedriveAllowPolicy

func (*QueueRedriveAllowPolicy) SetParameters 

func (tr *QueueRedriveAllowPolicy) SetParameters(params map[string]any) error

SetParameters for this QueueRedriveAllowPolicy

func (*QueueRedriveAllowPolicy) SetProviderConfigReference 

func (mg *QueueRedriveAllowPolicy) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this QueueRedriveAllowPolicy.

func (*QueueRedriveAllowPolicy) SetProviderReference 

func (mg *QueueRedriveAllowPolicy) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this QueueRedriveAllowPolicy. Deprecated: Use SetProviderConfigReference.

func (*QueueRedriveAllowPolicy) SetPublishConnectionDetailsTo 

func (mg *QueueRedriveAllowPolicy) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this QueueRedriveAllowPolicy.

func (*QueueRedriveAllowPolicy) SetWriteConnectionSecretToReference 

func (mg *QueueRedriveAllowPolicy) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this QueueRedriveAllowPolicy.

type QueueRedriveAllowPolicyList 

type QueueRedriveAllowPolicyList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []QueueRedriveAllowPolicy `json:"items"`
}

QueueRedriveAllowPolicyList contains a list of QueueRedriveAllowPolicys

func (*QueueRedriveAllowPolicyList) DeepCopy 

func (in *QueueRedriveAllowPolicyList) DeepCopy() *QueueRedriveAllowPolicyList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueRedriveAllowPolicyList.

func (*QueueRedriveAllowPolicyList) DeepCopyInto 

func (in *QueueRedriveAllowPolicyList) DeepCopyInto(out *QueueRedriveAllowPolicyList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*QueueRedriveAllowPolicyList) DeepCopyObject 

func (in *QueueRedriveAllowPolicyList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*QueueRedriveAllowPolicyList) GetItems 

func (l *QueueRedriveAllowPolicyList) GetItems() []resource.Managed

GetItems of this QueueRedriveAllowPolicyList.

type QueueRedriveAllowPolicyObservation 

type QueueRedriveAllowPolicyObservation struct {
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The URL of the SQS Queue to which to attach the policy
	QueueURL *string `json:"queueUrl,omitempty" tf:"queue_url,omitempty"`

	// The JSON redrive allow policy for the SQS queue. Learn more in the Amazon SQS dead-letter queues documentation.
	RedriveAllowPolicy *string `json:"redriveAllowPolicy,omitempty" tf:"redrive_allow_policy,omitempty"`
}

func (*QueueRedriveAllowPolicyObservation) DeepCopy 

func (in *QueueRedriveAllowPolicyObservation) DeepCopy() *QueueRedriveAllowPolicyObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueRedriveAllowPolicyObservation.

func (*QueueRedriveAllowPolicyObservation) DeepCopyInto 

func (in *QueueRedriveAllowPolicyObservation) DeepCopyInto(out *QueueRedriveAllowPolicyObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueueRedriveAllowPolicyParameters 

type QueueRedriveAllowPolicyParameters struct {

	// The URL of the SQS Queue to which to attach the policy
	// +crossplane:generate:reference:type=github.com/spirosco/upbound-provider-aws/apis/sqs/v1beta1.Queue
	// +crossplane:generate:reference:extractor=github.com/spirosco/upbound-provider-aws/config/common.TerraformID()
	// +kubebuilder:validation:Optional
	QueueURL *string `json:"queueUrl,omitempty" tf:"queue_url,omitempty"`

	// Reference to a Queue in sqs to populate queueUrl.
	// +kubebuilder:validation:Optional
	QueueURLRef *v1.Reference `json:"queueUrlRef,omitempty" tf:"-"`

	// Selector for a Queue in sqs to populate queueUrl.
	// +kubebuilder:validation:Optional
	QueueURLSelector *v1.Selector `json:"queueUrlSelector,omitempty" tf:"-"`

	// The JSON redrive allow policy for the SQS queue. Learn more in the Amazon SQS dead-letter queues documentation.
	// +kubebuilder:validation:Optional
	RedriveAllowPolicy *string `json:"redriveAllowPolicy,omitempty" tf:"redrive_allow_policy,omitempty"`

	// Region is the region you'd like your resource to be created in.
	// +upjet:crd:field:TFTag=-
	// +kubebuilder:validation:Required
	Region *string `json:"region" tf:"-"`
}

func (*QueueRedriveAllowPolicyParameters) DeepCopy 

func (in *QueueRedriveAllowPolicyParameters) DeepCopy() *QueueRedriveAllowPolicyParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueRedriveAllowPolicyParameters.

func (*QueueRedriveAllowPolicyParameters) DeepCopyInto 

func (in *QueueRedriveAllowPolicyParameters) DeepCopyInto(out *QueueRedriveAllowPolicyParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueueRedriveAllowPolicySpec 

type QueueRedriveAllowPolicySpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     QueueRedriveAllowPolicyParameters `json:"forProvider"`
}

QueueRedriveAllowPolicySpec defines the desired state of QueueRedriveAllowPolicy

func (*QueueRedriveAllowPolicySpec) DeepCopy 

func (in *QueueRedriveAllowPolicySpec) DeepCopy() *QueueRedriveAllowPolicySpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueRedriveAllowPolicySpec.

func (*QueueRedriveAllowPolicySpec) DeepCopyInto 

func (in *QueueRedriveAllowPolicySpec) DeepCopyInto(out *QueueRedriveAllowPolicySpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueueRedriveAllowPolicyStatus 

type QueueRedriveAllowPolicyStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        QueueRedriveAllowPolicyObservation `json:"atProvider,omitempty"`
}

QueueRedriveAllowPolicyStatus defines the observed state of QueueRedriveAllowPolicy.

func (*QueueRedriveAllowPolicyStatus) DeepCopy 

func (in *QueueRedriveAllowPolicyStatus) DeepCopy() *QueueRedriveAllowPolicyStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueRedriveAllowPolicyStatus.

func (*QueueRedriveAllowPolicyStatus) DeepCopyInto 

func (in *QueueRedriveAllowPolicyStatus) DeepCopyInto(out *QueueRedriveAllowPolicyStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueueRedrivePolicy 

type QueueRedrivePolicy struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="self.managementPolicy == 'ObserveOnly' || has(self.forProvider.redrivePolicy)",message="redrivePolicy is a required parameter"
	Spec   QueueRedrivePolicySpec   `json:"spec"`
	Status QueueRedrivePolicyStatus `json:"status,omitempty"`
}

QueueRedrivePolicy is the Schema for the QueueRedrivePolicys API. Provides a SQS Queue Redrive Policy resource. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}

func (*QueueRedrivePolicy) DeepCopy 

func (in *QueueRedrivePolicy) DeepCopy() *QueueRedrivePolicy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueRedrivePolicy.

func (*QueueRedrivePolicy) DeepCopyInto 

func (in *QueueRedrivePolicy) DeepCopyInto(out *QueueRedrivePolicy)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*QueueRedrivePolicy) DeepCopyObject 

func (in *QueueRedrivePolicy) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*QueueRedrivePolicy) GetCondition 

func (mg *QueueRedrivePolicy) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this QueueRedrivePolicy.

func (*QueueRedrivePolicy) GetConnectionDetailsMapping 

func (tr *QueueRedrivePolicy) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this QueueRedrivePolicy

func (*QueueRedrivePolicy) GetDeletionPolicy 

func (mg *QueueRedrivePolicy) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this QueueRedrivePolicy.

func (*QueueRedrivePolicy) GetID 

func (tr *QueueRedrivePolicy) GetID() string

GetID returns ID of underlying Terraform resource of this QueueRedrivePolicy

func (*QueueRedrivePolicy) GetManagementPolicy 

func (mg *QueueRedrivePolicy) GetManagementPolicy() xpv1.ManagementPolicy

GetManagementPolicy of this QueueRedrivePolicy.

func (*QueueRedrivePolicy) GetObservation 

func (tr *QueueRedrivePolicy) GetObservation() (map[string]any, error)

GetObservation of this QueueRedrivePolicy

func (*QueueRedrivePolicy) GetParameters 

func (tr *QueueRedrivePolicy) GetParameters() (map[string]any, error)

GetParameters of this QueueRedrivePolicy

func (*QueueRedrivePolicy) GetProviderConfigReference 

func (mg *QueueRedrivePolicy) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this QueueRedrivePolicy.

func (*QueueRedrivePolicy) GetProviderReference 

func (mg *QueueRedrivePolicy) GetProviderReference() *xpv1.Reference

GetProviderReference of this QueueRedrivePolicy. Deprecated: Use GetProviderConfigReference.

func (*QueueRedrivePolicy) GetPublishConnectionDetailsTo 

func (mg *QueueRedrivePolicy) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this QueueRedrivePolicy.

func (*QueueRedrivePolicy) GetTerraformResourceType 

func (mg *QueueRedrivePolicy) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this QueueRedrivePolicy

func (*QueueRedrivePolicy) GetTerraformSchemaVersion 

func (tr *QueueRedrivePolicy) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*QueueRedrivePolicy) GetWriteConnectionSecretToReference 

func (mg *QueueRedrivePolicy) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this QueueRedrivePolicy.

func (*QueueRedrivePolicy) LateInitialize 

func (tr *QueueRedrivePolicy) LateInitialize(attrs []byte) (bool, error)

LateInitialize this QueueRedrivePolicy using its observed tfState. returns True if there are any spec changes for the resource.

func (*QueueRedrivePolicy) ResolveReferences 

func (mg *QueueRedrivePolicy) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this QueueRedrivePolicy.

func (*QueueRedrivePolicy) SetConditions 

func (mg *QueueRedrivePolicy) SetConditions(c ...xpv1.Condition)

SetConditions of this QueueRedrivePolicy.

func (*QueueRedrivePolicy) SetDeletionPolicy 

func (mg *QueueRedrivePolicy) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this QueueRedrivePolicy.

func (*QueueRedrivePolicy) SetManagementPolicy 

func (mg *QueueRedrivePolicy) SetManagementPolicy(r xpv1.ManagementPolicy)

SetManagementPolicy of this QueueRedrivePolicy.

func (*QueueRedrivePolicy) SetObservation 

func (tr *QueueRedrivePolicy) SetObservation(obs map[string]any) error

SetObservation for this QueueRedrivePolicy

func (*QueueRedrivePolicy) SetParameters 

func (tr *QueueRedrivePolicy) SetParameters(params map[string]any) error

SetParameters for this QueueRedrivePolicy

func (*QueueRedrivePolicy) SetProviderConfigReference 

func (mg *QueueRedrivePolicy) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this QueueRedrivePolicy.

func (*QueueRedrivePolicy) SetProviderReference 

func (mg *QueueRedrivePolicy) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this QueueRedrivePolicy. Deprecated: Use SetProviderConfigReference.

func (*QueueRedrivePolicy) SetPublishConnectionDetailsTo 

func (mg *QueueRedrivePolicy) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this QueueRedrivePolicy.

func (*QueueRedrivePolicy) SetWriteConnectionSecretToReference 

func (mg *QueueRedrivePolicy) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this QueueRedrivePolicy.

type QueueRedrivePolicyList 

type QueueRedrivePolicyList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []QueueRedrivePolicy `json:"items"`
}

QueueRedrivePolicyList contains a list of QueueRedrivePolicys

func (*QueueRedrivePolicyList) DeepCopy 

func (in *QueueRedrivePolicyList) DeepCopy() *QueueRedrivePolicyList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueRedrivePolicyList.

func (*QueueRedrivePolicyList) DeepCopyInto 

func (in *QueueRedrivePolicyList) DeepCopyInto(out *QueueRedrivePolicyList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*QueueRedrivePolicyList) DeepCopyObject 

func (in *QueueRedrivePolicyList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*QueueRedrivePolicyList) GetItems 

func (l *QueueRedrivePolicyList) GetItems() []resource.Managed

GetItems of this QueueRedrivePolicyList.

type QueueRedrivePolicyObservation 

type QueueRedrivePolicyObservation struct {
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The URL of the SQS Queue to which to attach the policy
	QueueURL *string `json:"queueUrl,omitempty" tf:"queue_url,omitempty"`

	// The JSON redrive policy for the SQS queue. Accepts two key/val pairs: deadLetterTargetArn and maxReceiveCount. Learn more in the Amazon SQS dead-letter queues documentation.
	RedrivePolicy *string `json:"redrivePolicy,omitempty" tf:"redrive_policy,omitempty"`
}

func (*QueueRedrivePolicyObservation) DeepCopy 

func (in *QueueRedrivePolicyObservation) DeepCopy() *QueueRedrivePolicyObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueRedrivePolicyObservation.

func (*QueueRedrivePolicyObservation) DeepCopyInto 

func (in *QueueRedrivePolicyObservation) DeepCopyInto(out *QueueRedrivePolicyObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueueRedrivePolicyParameters 

type QueueRedrivePolicyParameters struct {

	// The URL of the SQS Queue to which to attach the policy
	// +crossplane:generate:reference:type=github.com/spirosco/upbound-provider-aws/apis/sqs/v1beta1.Queue
	// +crossplane:generate:reference:extractor=github.com/spirosco/upbound-provider-aws/config/common.TerraformID()
	// +kubebuilder:validation:Optional
	QueueURL *string `json:"queueUrl,omitempty" tf:"queue_url,omitempty"`

	// Reference to a Queue in sqs to populate queueUrl.
	// +kubebuilder:validation:Optional
	QueueURLRef *v1.Reference `json:"queueUrlRef,omitempty" tf:"-"`

	// Selector for a Queue in sqs to populate queueUrl.
	// +kubebuilder:validation:Optional
	QueueURLSelector *v1.Selector `json:"queueUrlSelector,omitempty" tf:"-"`

	// The JSON redrive policy for the SQS queue. Accepts two key/val pairs: deadLetterTargetArn and maxReceiveCount. Learn more in the Amazon SQS dead-letter queues documentation.
	// +kubebuilder:validation:Optional
	RedrivePolicy *string `json:"redrivePolicy,omitempty" tf:"redrive_policy,omitempty"`

	// Region is the region you'd like your resource to be created in.
	// +upjet:crd:field:TFTag=-
	// +kubebuilder:validation:Required
	Region *string `json:"region" tf:"-"`
}

func (*QueueRedrivePolicyParameters) DeepCopy 

func (in *QueueRedrivePolicyParameters) DeepCopy() *QueueRedrivePolicyParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueRedrivePolicyParameters.

func (*QueueRedrivePolicyParameters) DeepCopyInto 

func (in *QueueRedrivePolicyParameters) DeepCopyInto(out *QueueRedrivePolicyParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueueRedrivePolicySpec 

type QueueRedrivePolicySpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     QueueRedrivePolicyParameters `json:"forProvider"`
}

QueueRedrivePolicySpec defines the desired state of QueueRedrivePolicy

func (*QueueRedrivePolicySpec) DeepCopy 

func (in *QueueRedrivePolicySpec) DeepCopy() *QueueRedrivePolicySpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueRedrivePolicySpec.

func (*QueueRedrivePolicySpec) DeepCopyInto 

func (in *QueueRedrivePolicySpec) DeepCopyInto(out *QueueRedrivePolicySpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueueRedrivePolicyStatus 

type QueueRedrivePolicyStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        QueueRedrivePolicyObservation `json:"atProvider,omitempty"`
}

QueueRedrivePolicyStatus defines the observed state of QueueRedrivePolicy.

func (*QueueRedrivePolicyStatus) DeepCopy 

func (in *QueueRedrivePolicyStatus) DeepCopy() *QueueRedrivePolicyStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueRedrivePolicyStatus.

func (*QueueRedrivePolicyStatus) DeepCopyInto 

func (in *QueueRedrivePolicyStatus) DeepCopyInto(out *QueueRedrivePolicyStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueueSpec 

type QueueSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     QueueParameters `json:"forProvider"`
}

QueueSpec defines the desired state of Queue

func (*QueueSpec) DeepCopy 

func (in *QueueSpec) DeepCopy() *QueueSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueSpec.

func (*QueueSpec) DeepCopyInto 

func (in *QueueSpec) DeepCopyInto(out *QueueSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueueStatus 

type QueueStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        QueueObservation `json:"atProvider,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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.