v1alpha1

package
v0.8.2 Latest Latest
Warning

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

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

Documentation

Overview

+kubebuilder:object:generate=true +groupName=tcmq.tencentcloud.crossplane.io +versionName=v1alpha1

Index

Constants

View Source 
const (
	CRDGroup   = "tcmq.tencentcloud.crossplane.io"
	CRDVersion = "v1alpha1"
)

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 (
	Subscribe_Kind             = "Subscribe"
	Subscribe_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Subscribe_Kind}.String()
	Subscribe_KindAPIVersion   = Subscribe_Kind + "." + CRDGroupVersion.String()
	Subscribe_GroupVersionKind = CRDGroupVersion.WithKind(Subscribe_Kind)
)

Repository type metadata.

View Source 
var (
	Topic_Kind             = "Topic"
	Topic_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Topic_Kind}.String()
	Topic_KindAPIVersion   = Topic_Kind + "." + CRDGroupVersion.String()
	Topic_GroupVersionKind = CRDGroupVersion.WithKind(Topic_Kind)
)

Repository type metadata.

Functions

This section is empty.

Types

type Queue 

type Queue struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.queueName) || (has(self.initProvider) && has(self.initProvider.queueName))",message="spec.forProvider.queueName is a required parameter"
	Spec   QueueSpec   `json:"spec"`
	Status QueueStatus `json:"status,omitempty"`
}

Queue is the Schema for the Queues API. Provides a resource to create a tcmq queue +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:resource:scope=Cluster,categories={crossplane,managed,tencentcloud}

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) GetInitParameters 

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

GetInitParameters of this Queue

func (*Queue) GetManagementPolicies 

func (mg *Queue) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this Queue.

func (*Queue) GetMergedParameters 

func (tr *Queue) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

GetInitParameters 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) 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) Hub 

func (tr *Queue) Hub()

Hub marks this type as a conversion hub.

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) SetManagementPolicies 

func (mg *Queue) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies 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) 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 QueueInitParameters 

type QueueInitParameters struct {

	// Dead letter queue name.
	// Dead letter queue name.
	DeadLetterQueueName *string `json:"deadLetterQueueName,omitempty" tf:"dead_letter_queue_name,omitempty"`

	// First lookback interval.
	// First lookback interval.
	FirstQueryInterval *float64 `json:"firstQueryInterval,omitempty" tf:"first_query_interval,omitempty"`

	// Maximum number of heaped messages. The value range is 1,000,000-10,000,000 during the beta test and can be 1,000,000-1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	// Maximum number of heaped messages. The value range is 1,000,000-10,000,000 during the beta test and can be 1,000,000-1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	MaxMsgHeapNum *float64 `json:"maxMsgHeapNum,omitempty" tf:"max_msg_heap_num,omitempty"`

	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize *float64 `json:"maxMsgSize,omitempty" tf:"max_msg_size,omitempty"`

	// Maximum number of lookbacks.
	// Maximum number of lookbacks.
	MaxQueryCount *float64 `json:"maxQueryCount,omitempty" tf:"max_query_count,omitempty"`

	// Maximum receipt times. Value range: 1-1000.
	// Maximum receipt times. Value range: 1-1000.
	MaxReceiveCount *float64 `json:"maxReceiveCount,omitempty" tf:"max_receive_count,omitempty"`

	// Maximum period in seconds before an unconsumed message expires, which is required if policy is 1. Value range: 300-43200. This value should be smaller than msgRetentionSeconds (maximum message retention period).
	// Maximum period in seconds before an unconsumed message expires, which is required if `policy` is 1. Value range: 300-43200. This value should be smaller than `msgRetentionSeconds` (maximum message retention period).
	MaxTimeToLive *float64 `json:"maxTimeToLive,omitempty" tf:"max_time_to_live,omitempty"`

	// The max period during which a message is retained before it is automatically acknowledged. Value range: 30-43,200 seconds (30 seconds to 12 hours). Default value: 3600 seconds (1 hour).
	// The max period during which a message is retained before it is automatically acknowledged. Value range: 30-43,200 seconds (30 seconds to 12 hours). Default value: 3600 seconds (1 hour).
	MsgRetentionSeconds *float64 `json:"msgRetentionSeconds,omitempty" tf:"msg_retention_seconds,omitempty"`

	// Dead letter policy. 0: message has been consumed multiple times but not deleted; 1: Time-To-Live has elapsed.
	// Dead letter policy. 0: message has been consumed multiple times but not deleted; 1: `Time-To-Live` has elapsed.
	Policy *float64 `json:"policy,omitempty" tf:"policy,omitempty"`

	// Long polling wait time for message reception. Value range: 0-30 seconds. Default value: 0.
	// Long polling wait time for message reception. Value range: 0-30 seconds. Default value: 0.
	PollingWaitSeconds *float64 `json:"pollingWaitSeconds,omitempty" tf:"polling_wait_seconds,omitempty"`

	// Queue name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// Queue name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	QueueName *string `json:"queueName,omitempty" tf:"queue_name,omitempty"`

	// Queue storage space configured for message rewind. Value range: 10,240-512,000 MB (if message rewind is enabled). The value 0 indicates that message rewind is not enabled.
	// Queue storage space configured for message rewind. Value range: 10,240-512,000 MB (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.
	RetentionSizeInMb *float64 `json:"retentionSizeInMb,omitempty" tf:"retention_size_in_mb,omitempty"`

	// Rewindable time of messages in the queue. Value range: 0-1,296,000s (if message rewind is enabled). The value 0 indicates that message rewind is not enabled.
	// Rewindable time of messages in the queue. Value range: 0-1,296,000s (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.
	RewindSeconds *float64 `json:"rewindSeconds,omitempty" tf:"rewind_seconds,omitempty"`

	// Whether to enable message trace. true: yes; false: no. If this field is not configured, the feature will not be enabled.
	// Whether to enable message trace. true: yes; false: no. If this field is not configured, the feature will not be enabled.
	Trace *bool `json:"trace,omitempty" tf:"trace,omitempty"`

	// 1: transaction queue; 0: general queue.
	// 1: transaction queue; 0: general queue.
	Transaction *float64 `json:"transaction,omitempty" tf:"transaction,omitempty"`

	// Message visibility timeout period. Value range: 1-43200 seconds (i.e., 12 hours). Default value: 30.
	// Message visibility timeout period. Value range: 1-43200 seconds (i.e., 12 hours). Default value: 30.
	VisibilityTimeout *float64 `json:"visibilityTimeout,omitempty" tf:"visibility_timeout,omitempty"`
}

func (*QueueInitParameters) DeepCopy 

func (in *QueueInitParameters) DeepCopy() *QueueInitParameters

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

func (*QueueInitParameters) DeepCopyInto 

func (in *QueueInitParameters) DeepCopyInto(out *QueueInitParameters)

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

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 {

	// Dead letter queue name.
	// Dead letter queue name.
	DeadLetterQueueName *string `json:"deadLetterQueueName,omitempty" tf:"dead_letter_queue_name,omitempty"`

	// First lookback interval.
	// First lookback interval.
	FirstQueryInterval *float64 `json:"firstQueryInterval,omitempty" tf:"first_query_interval,omitempty"`

	// ID of the resource.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// Maximum number of heaped messages. The value range is 1,000,000-10,000,000 during the beta test and can be 1,000,000-1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	// Maximum number of heaped messages. The value range is 1,000,000-10,000,000 during the beta test and can be 1,000,000-1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	MaxMsgHeapNum *float64 `json:"maxMsgHeapNum,omitempty" tf:"max_msg_heap_num,omitempty"`

	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize *float64 `json:"maxMsgSize,omitempty" tf:"max_msg_size,omitempty"`

	// Maximum number of lookbacks.
	// Maximum number of lookbacks.
	MaxQueryCount *float64 `json:"maxQueryCount,omitempty" tf:"max_query_count,omitempty"`

	// Maximum receipt times. Value range: 1-1000.
	// Maximum receipt times. Value range: 1-1000.
	MaxReceiveCount *float64 `json:"maxReceiveCount,omitempty" tf:"max_receive_count,omitempty"`

	// Maximum period in seconds before an unconsumed message expires, which is required if policy is 1. Value range: 300-43200. This value should be smaller than msgRetentionSeconds (maximum message retention period).
	// Maximum period in seconds before an unconsumed message expires, which is required if `policy` is 1. Value range: 300-43200. This value should be smaller than `msgRetentionSeconds` (maximum message retention period).
	MaxTimeToLive *float64 `json:"maxTimeToLive,omitempty" tf:"max_time_to_live,omitempty"`

	// The max period during which a message is retained before it is automatically acknowledged. Value range: 30-43,200 seconds (30 seconds to 12 hours). Default value: 3600 seconds (1 hour).
	// The max period during which a message is retained before it is automatically acknowledged. Value range: 30-43,200 seconds (30 seconds to 12 hours). Default value: 3600 seconds (1 hour).
	MsgRetentionSeconds *float64 `json:"msgRetentionSeconds,omitempty" tf:"msg_retention_seconds,omitempty"`

	// Dead letter policy. 0: message has been consumed multiple times but not deleted; 1: Time-To-Live has elapsed.
	// Dead letter policy. 0: message has been consumed multiple times but not deleted; 1: `Time-To-Live` has elapsed.
	Policy *float64 `json:"policy,omitempty" tf:"policy,omitempty"`

	// Long polling wait time for message reception. Value range: 0-30 seconds. Default value: 0.
	// Long polling wait time for message reception. Value range: 0-30 seconds. Default value: 0.
	PollingWaitSeconds *float64 `json:"pollingWaitSeconds,omitempty" tf:"polling_wait_seconds,omitempty"`

	// Queue name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// Queue name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	QueueName *string `json:"queueName,omitempty" tf:"queue_name,omitempty"`

	// Queue storage space configured for message rewind. Value range: 10,240-512,000 MB (if message rewind is enabled). The value 0 indicates that message rewind is not enabled.
	// Queue storage space configured for message rewind. Value range: 10,240-512,000 MB (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.
	RetentionSizeInMb *float64 `json:"retentionSizeInMb,omitempty" tf:"retention_size_in_mb,omitempty"`

	// Rewindable time of messages in the queue. Value range: 0-1,296,000s (if message rewind is enabled). The value 0 indicates that message rewind is not enabled.
	// Rewindable time of messages in the queue. Value range: 0-1,296,000s (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.
	RewindSeconds *float64 `json:"rewindSeconds,omitempty" tf:"rewind_seconds,omitempty"`

	// Whether to enable message trace. true: yes; false: no. If this field is not configured, the feature will not be enabled.
	// Whether to enable message trace. true: yes; false: no. If this field is not configured, the feature will not be enabled.
	Trace *bool `json:"trace,omitempty" tf:"trace,omitempty"`

	// 1: transaction queue; 0: general queue.
	// 1: transaction queue; 0: general queue.
	Transaction *float64 `json:"transaction,omitempty" tf:"transaction,omitempty"`

	// Message visibility timeout period. Value range: 1-43200 seconds (i.e., 12 hours). Default value: 30.
	// Message visibility timeout period. Value range: 1-43200 seconds (i.e., 12 hours). Default value: 30.
	VisibilityTimeout *float64 `json:"visibilityTimeout,omitempty" tf:"visibility_timeout,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 {

	// Dead letter queue name.
	// Dead letter queue name.
	// +kubebuilder:validation:Optional
	DeadLetterQueueName *string `json:"deadLetterQueueName,omitempty" tf:"dead_letter_queue_name,omitempty"`

	// First lookback interval.
	// First lookback interval.
	// +kubebuilder:validation:Optional
	FirstQueryInterval *float64 `json:"firstQueryInterval,omitempty" tf:"first_query_interval,omitempty"`

	// Maximum number of heaped messages. The value range is 1,000,000-10,000,000 during the beta test and can be 1,000,000-1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	// Maximum number of heaped messages. The value range is 1,000,000-10,000,000 during the beta test and can be 1,000,000-1,000,000,000 after the product is officially released. The default value is 10,000,000 during the beta test and will be 100,000,000 after the product is officially released.
	// +kubebuilder:validation:Optional
	MaxMsgHeapNum *float64 `json:"maxMsgHeapNum,omitempty" tf:"max_msg_heap_num,omitempty"`

	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	// +kubebuilder:validation:Optional
	MaxMsgSize *float64 `json:"maxMsgSize,omitempty" tf:"max_msg_size,omitempty"`

	// Maximum number of lookbacks.
	// Maximum number of lookbacks.
	// +kubebuilder:validation:Optional
	MaxQueryCount *float64 `json:"maxQueryCount,omitempty" tf:"max_query_count,omitempty"`

	// Maximum receipt times. Value range: 1-1000.
	// Maximum receipt times. Value range: 1-1000.
	// +kubebuilder:validation:Optional
	MaxReceiveCount *float64 `json:"maxReceiveCount,omitempty" tf:"max_receive_count,omitempty"`

	// Maximum period in seconds before an unconsumed message expires, which is required if policy is 1. Value range: 300-43200. This value should be smaller than msgRetentionSeconds (maximum message retention period).
	// Maximum period in seconds before an unconsumed message expires, which is required if `policy` is 1. Value range: 300-43200. This value should be smaller than `msgRetentionSeconds` (maximum message retention period).
	// +kubebuilder:validation:Optional
	MaxTimeToLive *float64 `json:"maxTimeToLive,omitempty" tf:"max_time_to_live,omitempty"`

	// The max period during which a message is retained before it is automatically acknowledged. Value range: 30-43,200 seconds (30 seconds to 12 hours). Default value: 3600 seconds (1 hour).
	// The max period during which a message is retained before it is automatically acknowledged. Value range: 30-43,200 seconds (30 seconds to 12 hours). Default value: 3600 seconds (1 hour).
	// +kubebuilder:validation:Optional
	MsgRetentionSeconds *float64 `json:"msgRetentionSeconds,omitempty" tf:"msg_retention_seconds,omitempty"`

	// Dead letter policy. 0: message has been consumed multiple times but not deleted; 1: Time-To-Live has elapsed.
	// Dead letter policy. 0: message has been consumed multiple times but not deleted; 1: `Time-To-Live` has elapsed.
	// +kubebuilder:validation:Optional
	Policy *float64 `json:"policy,omitempty" tf:"policy,omitempty"`

	// Long polling wait time for message reception. Value range: 0-30 seconds. Default value: 0.
	// Long polling wait time for message reception. Value range: 0-30 seconds. Default value: 0.
	// +kubebuilder:validation:Optional
	PollingWaitSeconds *float64 `json:"pollingWaitSeconds,omitempty" tf:"polling_wait_seconds,omitempty"`

	// Queue name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// Queue name, which must be unique under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// +kubebuilder:validation:Optional
	QueueName *string `json:"queueName,omitempty" tf:"queue_name,omitempty"`

	// Queue storage space configured for message rewind. Value range: 10,240-512,000 MB (if message rewind is enabled). The value 0 indicates that message rewind is not enabled.
	// Queue storage space configured for message rewind. Value range: 10,240-512,000 MB (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.
	// +kubebuilder:validation:Optional
	RetentionSizeInMb *float64 `json:"retentionSizeInMb,omitempty" tf:"retention_size_in_mb,omitempty"`

	// Rewindable time of messages in the queue. Value range: 0-1,296,000s (if message rewind is enabled). The value 0 indicates that message rewind is not enabled.
	// Rewindable time of messages in the queue. Value range: 0-1,296,000s (if message rewind is enabled). The value `0` indicates that message rewind is not enabled.
	// +kubebuilder:validation:Optional
	RewindSeconds *float64 `json:"rewindSeconds,omitempty" tf:"rewind_seconds,omitempty"`

	// Whether to enable message trace. true: yes; false: no. If this field is not configured, the feature will not be enabled.
	// Whether to enable message trace. true: yes; false: no. If this field is not configured, the feature will not be enabled.
	// +kubebuilder:validation:Optional
	Trace *bool `json:"trace,omitempty" tf:"trace,omitempty"`

	// 1: transaction queue; 0: general queue.
	// 1: transaction queue; 0: general queue.
	// +kubebuilder:validation:Optional
	Transaction *float64 `json:"transaction,omitempty" tf:"transaction,omitempty"`

	// Message visibility timeout period. Value range: 1-43200 seconds (i.e., 12 hours). Default value: 30.
	// Message visibility timeout period. Value range: 1-43200 seconds (i.e., 12 hours). Default value: 30.
	// +kubebuilder:validation:Optional
	VisibilityTimeout *float64 `json:"visibilityTimeout,omitempty" tf:"visibility_timeout,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 QueueSpec 

type QueueSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     QueueParameters `json:"forProvider"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider QueueInitParameters `json:"initProvider,omitempty"`
}

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.

type Subscribe 

type Subscribe struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.protocol) || (has(self.initProvider) && has(self.initProvider.protocol))",message="spec.forProvider.protocol is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.subscriptionName) || (has(self.initProvider) && has(self.initProvider.subscriptionName))",message="spec.forProvider.subscriptionName is a required parameter"
	Spec   SubscribeSpec   `json:"spec"`
	Status SubscribeStatus `json:"status,omitempty"`
}

Subscribe is the Schema for the Subscribes API. Provides a resource to create a tcmq subscribe +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:resource:scope=Cluster,categories={crossplane,managed,tencentcloud}

func (*Subscribe) DeepCopy 

func (in *Subscribe) DeepCopy() *Subscribe

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

func (*Subscribe) DeepCopyInto 

func (in *Subscribe) DeepCopyInto(out *Subscribe)

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

func (*Subscribe) DeepCopyObject 

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

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

func (*Subscribe) GetCondition 

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

GetCondition of this Subscribe.

func (*Subscribe) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this Subscribe

func (*Subscribe) GetDeletionPolicy 

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

GetDeletionPolicy of this Subscribe.

func (*Subscribe) GetID 

func (tr *Subscribe) GetID() string

GetID returns ID of underlying Terraform resource of this Subscribe

func (*Subscribe) GetInitParameters 

func (tr *Subscribe) GetInitParameters() (map[string]any, error)

GetInitParameters of this Subscribe

func (*Subscribe) GetManagementPolicies 

func (mg *Subscribe) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this Subscribe.

func (*Subscribe) GetMergedParameters 

func (tr *Subscribe) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

GetInitParameters of this Subscribe

func (*Subscribe) GetObservation 

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

GetObservation of this Subscribe

func (*Subscribe) GetParameters 

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

GetParameters of this Subscribe

func (*Subscribe) GetProviderConfigReference 

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

GetProviderConfigReference of this Subscribe.

func (*Subscribe) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this Subscribe.

func (*Subscribe) GetTerraformResourceType 

func (mg *Subscribe) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Subscribe

func (*Subscribe) GetTerraformSchemaVersion 

func (tr *Subscribe) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Subscribe) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this Subscribe.

func (*Subscribe) Hub 

func (tr *Subscribe) Hub()

Hub marks this type as a conversion hub.

func (*Subscribe) LateInitialize 

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

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

func (*Subscribe) ResolveReferences 

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

ResolveReferences of this Subscribe.

func (*Subscribe) SetConditions 

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

SetConditions of this Subscribe.

func (*Subscribe) SetDeletionPolicy 

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

SetDeletionPolicy of this Subscribe.

func (*Subscribe) SetManagementPolicies 

func (mg *Subscribe) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this Subscribe.

func (*Subscribe) SetObservation 

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

SetObservation for this Subscribe

func (*Subscribe) SetParameters 

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

SetParameters for this Subscribe

func (*Subscribe) SetProviderConfigReference 

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

SetProviderConfigReference of this Subscribe.

func (*Subscribe) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this Subscribe.

func (*Subscribe) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this Subscribe.

type SubscribeInitParameters 

type SubscribeInitParameters struct {

	// The number of BindingKey cannot exceed 5, and the length of each BindingKey cannot exceed 64 bytes. This field indicates the filtering policy for subscribing to and receiving messages. Each BindingKey includes up to 15 dots (namely up to 16 segments).
	// The number of `BindingKey` cannot exceed 5, and the length of each `BindingKey` cannot exceed 64 bytes. This field indicates the filtering policy for subscribing to and receiving messages. Each `BindingKey` includes up to 15 dots (namely up to 16 segments).
	// +listType=set
	BindingKey []*string `json:"bindingKey,omitempty" tf:"binding_key,omitempty"`

	// Endpoint for notification receipt, which is distinguished by Protocol. For http, Endpoint must begin with http:// and host can be a domain name or IP. For Queue, enter QueueName. Note that currently the push service cannot push messages to a VPC; therefore, if a VPC domain name or address is entered for Endpoint, pushed messages will not be received. Currently, messages can be pushed only to the public network and classic network.
	// `Endpoint` for notification receipt, which is distinguished by `Protocol`. For `http`, `Endpoint` must begin with `http://` and `host` can be a domain name or IP. For `Queue`, enter `QueueName`. Note that currently the push service cannot push messages to a VPC; therefore, if a VPC domain name or address is entered for `Endpoint`, pushed messages will not be received. Currently, messages can be pushed only to the public network and classic network.
	// +crossplane:generate:reference:type=Queue
	Endpoint *string `json:"endpoint,omitempty" tf:"endpoint,omitempty"`

	// Reference to a Queue to populate endpoint.
	// +kubebuilder:validation:Optional
	EndpointRef *v1.Reference `json:"endpointRef,omitempty" tf:"-"`

	// Selector for a Queue to populate endpoint.
	// +kubebuilder:validation:Optional
	EndpointSelector *v1.Selector `json:"endpointSelector,omitempty" tf:"-"`

	// Message body tag (used for message filtering). The number of tags cannot exceed 5, and each tag can contain up to 16 characters. It is used in conjunction with the MsgTag parameter of (Batch)PublishMessage. Rules: 1. If FilterTag is not configured, no matter whether MsgTag is configured, the subscription will receive all messages published to the topic; 2. If the array of FilterTag values has a value, only when at least one of the values in the array also exists in the array of MsgTag values (i.e., FilterTag and MsgTag have an intersection) can the subscription receive messages published to the topic; 3. If the array of FilterTag values has a value, but MsgTag is not configured, then no message published to the topic will be received, which can be considered as a special case of rule 2 as FilterTag and MsgTag do not intersect in this case. The overall design idea of rules is based on the intention of the subscriber.
	// Message body tag (used for message filtering). The number of tags cannot exceed 5, and each tag can contain up to 16 characters. It is used in conjunction with the `MsgTag` parameter of `(Batch)PublishMessage`. Rules: 1. If `FilterTag` is not configured, no matter whether `MsgTag` is configured, the subscription will receive all messages published to the topic; 2. If the array of `FilterTag` values has a value, only when at least one of the values in the array also exists in the array of `MsgTag` values (i.e., `FilterTag` and `MsgTag` have an intersection) can the subscription receive messages published to the topic; 3. If the array of `FilterTag` values has a value, but `MsgTag` is not configured, then no message published to the topic will be received, which can be considered as a special case of rule 2 as `FilterTag` and `MsgTag` do not intersect in this case. The overall design idea of rules is based on the intention of the subscriber.
	// +listType=set
	FilterTags []*string `json:"filterTags,omitempty" tf:"filter_tags,omitempty"`

	// Push content format. Valid values: 1. JSON; 2. SIMPLIFIED, i.e., the raw format. If Protocol is queue, this value must be SIMPLIFIED. If Protocol is http, both options are acceptable, and the default value is JSON.
	// Push content format. Valid values: 1. JSON; 2. SIMPLIFIED, i.e., the raw format. If `Protocol` is `queue`, this value must be `SIMPLIFIED`. If `Protocol` is `http`, both options are acceptable, and the default value is `JSON`.
	NotifyContentFormat *string `json:"notifyContentFormat,omitempty" tf:"notify_content_format,omitempty"`

	// CMQ push server retry policy in case an error occurs while pushing a message to Endpoint. Valid values: 1. BACKOFF_RETRY: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message; 2. EXPONENTIAL_DECAY_RETRY: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: EXPONENTIAL_DECAY_RETRY.
	// CMQ push server retry policy in case an error occurs while pushing a message to `Endpoint`. Valid values: 1. `BACKOFF_RETRY`: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message; 2. `EXPONENTIAL_DECAY_RETRY`: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: `EXPONENTIAL_DECAY_RETRY`.
	NotifyStrategy *string `json:"notifyStrategy,omitempty" tf:"notify_strategy,omitempty"`

	// ubscription protocol. Currently, two protocols are supported: http and queue. To use the http protocol, you need to build your own web server to receive messages. With the queue protocol, messages are automatically pushed to a CMQ queue and you can pull them concurrently.
	// ubscription protocol. Currently, two protocols are supported: `http` and `queue`. To use the `http` protocol, you need to build your own web server to receive messages. With the `queue` protocol, messages are automatically pushed to a CMQ queue and you can pull them concurrently.
	Protocol *string `json:"protocol,omitempty" tf:"protocol,omitempty"`

	// Subscription name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// Subscription name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	SubscriptionName *string `json:"subscriptionName,omitempty" tf:"subscription_name,omitempty"`

	// Tag description list.
	// Tag description list.
	// +mapType=granular
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`

	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// +crossplane:generate:reference:type=Topic
	TopicName *string `json:"topicName,omitempty" tf:"topic_name,omitempty"`

	// Reference to a Topic to populate topicName.
	// +kubebuilder:validation:Optional
	TopicNameRef *v1.Reference `json:"topicNameRef,omitempty" tf:"-"`

	// Selector for a Topic to populate topicName.
	// +kubebuilder:validation:Optional
	TopicNameSelector *v1.Selector `json:"topicNameSelector,omitempty" tf:"-"`
}

func (*SubscribeInitParameters) DeepCopy 

func (in *SubscribeInitParameters) DeepCopy() *SubscribeInitParameters

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

func (*SubscribeInitParameters) DeepCopyInto 

func (in *SubscribeInitParameters) DeepCopyInto(out *SubscribeInitParameters)

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

type SubscribeList 

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

SubscribeList contains a list of Subscribes

func (*SubscribeList) DeepCopy 

func (in *SubscribeList) DeepCopy() *SubscribeList

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

func (*SubscribeList) DeepCopyInto 

func (in *SubscribeList) DeepCopyInto(out *SubscribeList)

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

func (*SubscribeList) DeepCopyObject 

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

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

func (*SubscribeList) GetItems 

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

GetItems of this SubscribeList.

type SubscribeObservation 

type SubscribeObservation struct {

	// The number of BindingKey cannot exceed 5, and the length of each BindingKey cannot exceed 64 bytes. This field indicates the filtering policy for subscribing to and receiving messages. Each BindingKey includes up to 15 dots (namely up to 16 segments).
	// The number of `BindingKey` cannot exceed 5, and the length of each `BindingKey` cannot exceed 64 bytes. This field indicates the filtering policy for subscribing to and receiving messages. Each `BindingKey` includes up to 15 dots (namely up to 16 segments).
	// +listType=set
	BindingKey []*string `json:"bindingKey,omitempty" tf:"binding_key,omitempty"`

	// Endpoint for notification receipt, which is distinguished by Protocol. For http, Endpoint must begin with http:// and host can be a domain name or IP. For Queue, enter QueueName. Note that currently the push service cannot push messages to a VPC; therefore, if a VPC domain name or address is entered for Endpoint, pushed messages will not be received. Currently, messages can be pushed only to the public network and classic network.
	// `Endpoint` for notification receipt, which is distinguished by `Protocol`. For `http`, `Endpoint` must begin with `http://` and `host` can be a domain name or IP. For `Queue`, enter `QueueName`. Note that currently the push service cannot push messages to a VPC; therefore, if a VPC domain name or address is entered for `Endpoint`, pushed messages will not be received. Currently, messages can be pushed only to the public network and classic network.
	Endpoint *string `json:"endpoint,omitempty" tf:"endpoint,omitempty"`

	// Message body tag (used for message filtering). The number of tags cannot exceed 5, and each tag can contain up to 16 characters. It is used in conjunction with the MsgTag parameter of (Batch)PublishMessage. Rules: 1. If FilterTag is not configured, no matter whether MsgTag is configured, the subscription will receive all messages published to the topic; 2. If the array of FilterTag values has a value, only when at least one of the values in the array also exists in the array of MsgTag values (i.e., FilterTag and MsgTag have an intersection) can the subscription receive messages published to the topic; 3. If the array of FilterTag values has a value, but MsgTag is not configured, then no message published to the topic will be received, which can be considered as a special case of rule 2 as FilterTag and MsgTag do not intersect in this case. The overall design idea of rules is based on the intention of the subscriber.
	// Message body tag (used for message filtering). The number of tags cannot exceed 5, and each tag can contain up to 16 characters. It is used in conjunction with the `MsgTag` parameter of `(Batch)PublishMessage`. Rules: 1. If `FilterTag` is not configured, no matter whether `MsgTag` is configured, the subscription will receive all messages published to the topic; 2. If the array of `FilterTag` values has a value, only when at least one of the values in the array also exists in the array of `MsgTag` values (i.e., `FilterTag` and `MsgTag` have an intersection) can the subscription receive messages published to the topic; 3. If the array of `FilterTag` values has a value, but `MsgTag` is not configured, then no message published to the topic will be received, which can be considered as a special case of rule 2 as `FilterTag` and `MsgTag` do not intersect in this case. The overall design idea of rules is based on the intention of the subscriber.
	// +listType=set
	FilterTags []*string `json:"filterTags,omitempty" tf:"filter_tags,omitempty"`

	// ID of the resource.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// Push content format. Valid values: 1. JSON; 2. SIMPLIFIED, i.e., the raw format. If Protocol is queue, this value must be SIMPLIFIED. If Protocol is http, both options are acceptable, and the default value is JSON.
	// Push content format. Valid values: 1. JSON; 2. SIMPLIFIED, i.e., the raw format. If `Protocol` is `queue`, this value must be `SIMPLIFIED`. If `Protocol` is `http`, both options are acceptable, and the default value is `JSON`.
	NotifyContentFormat *string `json:"notifyContentFormat,omitempty" tf:"notify_content_format,omitempty"`

	// CMQ push server retry policy in case an error occurs while pushing a message to Endpoint. Valid values: 1. BACKOFF_RETRY: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message; 2. EXPONENTIAL_DECAY_RETRY: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: EXPONENTIAL_DECAY_RETRY.
	// CMQ push server retry policy in case an error occurs while pushing a message to `Endpoint`. Valid values: 1. `BACKOFF_RETRY`: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message; 2. `EXPONENTIAL_DECAY_RETRY`: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: `EXPONENTIAL_DECAY_RETRY`.
	NotifyStrategy *string `json:"notifyStrategy,omitempty" tf:"notify_strategy,omitempty"`

	// ubscription protocol. Currently, two protocols are supported: http and queue. To use the http protocol, you need to build your own web server to receive messages. With the queue protocol, messages are automatically pushed to a CMQ queue and you can pull them concurrently.
	// ubscription protocol. Currently, two protocols are supported: `http` and `queue`. To use the `http` protocol, you need to build your own web server to receive messages. With the `queue` protocol, messages are automatically pushed to a CMQ queue and you can pull them concurrently.
	Protocol *string `json:"protocol,omitempty" tf:"protocol,omitempty"`

	// Subscription name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// Subscription name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	SubscriptionName *string `json:"subscriptionName,omitempty" tf:"subscription_name,omitempty"`

	// Tag description list.
	// Tag description list.
	// +mapType=granular
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`

	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName *string `json:"topicName,omitempty" tf:"topic_name,omitempty"`
}

func (*SubscribeObservation) DeepCopy 

func (in *SubscribeObservation) DeepCopy() *SubscribeObservation

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

func (*SubscribeObservation) DeepCopyInto 

func (in *SubscribeObservation) DeepCopyInto(out *SubscribeObservation)

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

type SubscribeParameters 

type SubscribeParameters struct {

	// The number of BindingKey cannot exceed 5, and the length of each BindingKey cannot exceed 64 bytes. This field indicates the filtering policy for subscribing to and receiving messages. Each BindingKey includes up to 15 dots (namely up to 16 segments).
	// The number of `BindingKey` cannot exceed 5, and the length of each `BindingKey` cannot exceed 64 bytes. This field indicates the filtering policy for subscribing to and receiving messages. Each `BindingKey` includes up to 15 dots (namely up to 16 segments).
	// +kubebuilder:validation:Optional
	// +listType=set
	BindingKey []*string `json:"bindingKey,omitempty" tf:"binding_key,omitempty"`

	// Endpoint for notification receipt, which is distinguished by Protocol. For http, Endpoint must begin with http:// and host can be a domain name or IP. For Queue, enter QueueName. Note that currently the push service cannot push messages to a VPC; therefore, if a VPC domain name or address is entered for Endpoint, pushed messages will not be received. Currently, messages can be pushed only to the public network and classic network.
	// `Endpoint` for notification receipt, which is distinguished by `Protocol`. For `http`, `Endpoint` must begin with `http://` and `host` can be a domain name or IP. For `Queue`, enter `QueueName`. Note that currently the push service cannot push messages to a VPC; therefore, if a VPC domain name or address is entered for `Endpoint`, pushed messages will not be received. Currently, messages can be pushed only to the public network and classic network.
	// +crossplane:generate:reference:type=Queue
	// +kubebuilder:validation:Optional
	Endpoint *string `json:"endpoint,omitempty" tf:"endpoint,omitempty"`

	// Reference to a Queue to populate endpoint.
	// +kubebuilder:validation:Optional
	EndpointRef *v1.Reference `json:"endpointRef,omitempty" tf:"-"`

	// Selector for a Queue to populate endpoint.
	// +kubebuilder:validation:Optional
	EndpointSelector *v1.Selector `json:"endpointSelector,omitempty" tf:"-"`

	// Message body tag (used for message filtering). The number of tags cannot exceed 5, and each tag can contain up to 16 characters. It is used in conjunction with the MsgTag parameter of (Batch)PublishMessage. Rules: 1. If FilterTag is not configured, no matter whether MsgTag is configured, the subscription will receive all messages published to the topic; 2. If the array of FilterTag values has a value, only when at least one of the values in the array also exists in the array of MsgTag values (i.e., FilterTag and MsgTag have an intersection) can the subscription receive messages published to the topic; 3. If the array of FilterTag values has a value, but MsgTag is not configured, then no message published to the topic will be received, which can be considered as a special case of rule 2 as FilterTag and MsgTag do not intersect in this case. The overall design idea of rules is based on the intention of the subscriber.
	// Message body tag (used for message filtering). The number of tags cannot exceed 5, and each tag can contain up to 16 characters. It is used in conjunction with the `MsgTag` parameter of `(Batch)PublishMessage`. Rules: 1. If `FilterTag` is not configured, no matter whether `MsgTag` is configured, the subscription will receive all messages published to the topic; 2. If the array of `FilterTag` values has a value, only when at least one of the values in the array also exists in the array of `MsgTag` values (i.e., `FilterTag` and `MsgTag` have an intersection) can the subscription receive messages published to the topic; 3. If the array of `FilterTag` values has a value, but `MsgTag` is not configured, then no message published to the topic will be received, which can be considered as a special case of rule 2 as `FilterTag` and `MsgTag` do not intersect in this case. The overall design idea of rules is based on the intention of the subscriber.
	// +kubebuilder:validation:Optional
	// +listType=set
	FilterTags []*string `json:"filterTags,omitempty" tf:"filter_tags,omitempty"`

	// Push content format. Valid values: 1. JSON; 2. SIMPLIFIED, i.e., the raw format. If Protocol is queue, this value must be SIMPLIFIED. If Protocol is http, both options are acceptable, and the default value is JSON.
	// Push content format. Valid values: 1. JSON; 2. SIMPLIFIED, i.e., the raw format. If `Protocol` is `queue`, this value must be `SIMPLIFIED`. If `Protocol` is `http`, both options are acceptable, and the default value is `JSON`.
	// +kubebuilder:validation:Optional
	NotifyContentFormat *string `json:"notifyContentFormat,omitempty" tf:"notify_content_format,omitempty"`

	// CMQ push server retry policy in case an error occurs while pushing a message to Endpoint. Valid values: 1. BACKOFF_RETRY: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message; 2. EXPONENTIAL_DECAY_RETRY: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: EXPONENTIAL_DECAY_RETRY.
	// CMQ push server retry policy in case an error occurs while pushing a message to `Endpoint`. Valid values: 1. `BACKOFF_RETRY`: backoff retry, which is to retry at a fixed interval, discard the message after a certain number of retries, and continue to push the next message; 2. `EXPONENTIAL_DECAY_RETRY`: exponential decay retry, which is to retry at an exponentially increasing interval, such as 1s, 2s, 4s, 8s, and so on. As a message can be retained in a topic for one day, failed messages will be discarded at most after one day of retry. Default value: `EXPONENTIAL_DECAY_RETRY`.
	// +kubebuilder:validation:Optional
	NotifyStrategy *string `json:"notifyStrategy,omitempty" tf:"notify_strategy,omitempty"`

	// ubscription protocol. Currently, two protocols are supported: http and queue. To use the http protocol, you need to build your own web server to receive messages. With the queue protocol, messages are automatically pushed to a CMQ queue and you can pull them concurrently.
	// ubscription protocol. Currently, two protocols are supported: `http` and `queue`. To use the `http` protocol, you need to build your own web server to receive messages. With the `queue` protocol, messages are automatically pushed to a CMQ queue and you can pull them concurrently.
	// +kubebuilder:validation:Optional
	Protocol *string `json:"protocol,omitempty" tf:"protocol,omitempty"`

	// Subscription name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// Subscription name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// +kubebuilder:validation:Optional
	SubscriptionName *string `json:"subscriptionName,omitempty" tf:"subscription_name,omitempty"`

	// Tag description list.
	// Tag description list.
	// +kubebuilder:validation:Optional
	// +mapType=granular
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`

	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// +crossplane:generate:reference:type=Topic
	// +kubebuilder:validation:Optional
	TopicName *string `json:"topicName,omitempty" tf:"topic_name,omitempty"`

	// Reference to a Topic to populate topicName.
	// +kubebuilder:validation:Optional
	TopicNameRef *v1.Reference `json:"topicNameRef,omitempty" tf:"-"`

	// Selector for a Topic to populate topicName.
	// +kubebuilder:validation:Optional
	TopicNameSelector *v1.Selector `json:"topicNameSelector,omitempty" tf:"-"`
}

func (*SubscribeParameters) DeepCopy 

func (in *SubscribeParameters) DeepCopy() *SubscribeParameters

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

func (*SubscribeParameters) DeepCopyInto 

func (in *SubscribeParameters) DeepCopyInto(out *SubscribeParameters)

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

type SubscribeSpec 

type SubscribeSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     SubscribeParameters `json:"forProvider"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider SubscribeInitParameters `json:"initProvider,omitempty"`
}

SubscribeSpec defines the desired state of Subscribe

func (*SubscribeSpec) DeepCopy 

func (in *SubscribeSpec) DeepCopy() *SubscribeSpec

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

func (*SubscribeSpec) DeepCopyInto 

func (in *SubscribeSpec) DeepCopyInto(out *SubscribeSpec)

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

type SubscribeStatus 

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

SubscribeStatus defines the observed state of Subscribe.

func (*SubscribeStatus) DeepCopy 

func (in *SubscribeStatus) DeepCopy() *SubscribeStatus

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

func (*SubscribeStatus) DeepCopyInto 

func (in *SubscribeStatus) DeepCopyInto(out *SubscribeStatus)

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

type Topic 

type Topic struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.topicName) || (has(self.initProvider) && has(self.initProvider.topicName))",message="spec.forProvider.topicName is a required parameter"
	Spec   TopicSpec   `json:"spec"`
	Status TopicStatus `json:"status,omitempty"`
}

Topic is the Schema for the Topics API. Provides a resource to create a tcmq topic +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:resource:scope=Cluster,categories={crossplane,managed,tencentcloud}

func (*Topic) DeepCopy 

func (in *Topic) DeepCopy() *Topic

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

func (*Topic) DeepCopyInto 

func (in *Topic) DeepCopyInto(out *Topic)

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

func (*Topic) DeepCopyObject 

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

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

func (*Topic) GetCondition 

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

GetCondition of this Topic.

func (*Topic) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this Topic

func (*Topic) GetDeletionPolicy 

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

GetDeletionPolicy of this Topic.

func (*Topic) GetID 

func (tr *Topic) GetID() string

GetID returns ID of underlying Terraform resource of this Topic

func (*Topic) GetInitParameters 

func (tr *Topic) GetInitParameters() (map[string]any, error)

GetInitParameters of this Topic

func (*Topic) GetManagementPolicies 

func (mg *Topic) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this Topic.

func (*Topic) GetMergedParameters 

func (tr *Topic) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

GetInitParameters of this Topic

func (*Topic) GetObservation 

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

GetObservation of this Topic

func (*Topic) GetParameters 

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

GetParameters of this Topic

func (*Topic) GetProviderConfigReference 

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

GetProviderConfigReference of this Topic.

func (*Topic) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this Topic.

func (*Topic) GetTerraformResourceType 

func (mg *Topic) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Topic

func (*Topic) GetTerraformSchemaVersion 

func (tr *Topic) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Topic) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this Topic.

func (*Topic) Hub 

func (tr *Topic) Hub()

Hub marks this type as a conversion hub.

func (*Topic) LateInitialize 

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

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

func (*Topic) SetConditions 

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

SetConditions of this Topic.

func (*Topic) SetDeletionPolicy 

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

SetDeletionPolicy of this Topic.

func (*Topic) SetManagementPolicies 

func (mg *Topic) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this Topic.

func (*Topic) SetObservation 

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

SetObservation for this Topic

func (*Topic) SetParameters 

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

SetParameters for this Topic

func (*Topic) SetProviderConfigReference 

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

SetProviderConfigReference of this Topic.

func (*Topic) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this Topic.

func (*Topic) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this Topic.

type TopicInitParameters 

type TopicInitParameters struct {

	// Used to specify the message match policy for the topic. 1: tag match policy (default value); 2: routing match policy.
	// Used to specify the message match policy for the topic. `1`: tag match policy (default value); `2`: routing match policy.
	FilterType *float64 `json:"filterType,omitempty" tf:"filter_type,omitempty"`

	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize *float64 `json:"maxMsgSize,omitempty" tf:"max_msg_size,omitempty"`

	// Message retention period. Value range: 60-86400 seconds (i.e., 1 minute-1 day). Default value: 86400.
	// Message retention period. Value range: 60-86400 seconds (i.e., 1 minute-1 day). Default value: 86400.
	MsgRetentionSeconds *float64 `json:"msgRetentionSeconds,omitempty" tf:"msg_retention_seconds,omitempty"`

	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName *string `json:"topicName,omitempty" tf:"topic_name,omitempty"`

	// Whether to enable message trace. true: yes; false: no. If this field is left empty, the feature will not be enabled.
	// Whether to enable message trace. true: yes; false: no. If this field is left empty, the feature will not be enabled.
	Trace *bool `json:"trace,omitempty" tf:"trace,omitempty"`
}

func (*TopicInitParameters) DeepCopy 

func (in *TopicInitParameters) DeepCopy() *TopicInitParameters

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

func (*TopicInitParameters) DeepCopyInto 

func (in *TopicInitParameters) DeepCopyInto(out *TopicInitParameters)

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

type TopicList 

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

TopicList contains a list of Topics

func (*TopicList) DeepCopy 

func (in *TopicList) DeepCopy() *TopicList

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

func (*TopicList) DeepCopyInto 

func (in *TopicList) DeepCopyInto(out *TopicList)

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

func (*TopicList) DeepCopyObject 

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

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

func (*TopicList) GetItems 

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

GetItems of this TopicList.

type TopicObservation 

type TopicObservation struct {

	// Used to specify the message match policy for the topic. 1: tag match policy (default value); 2: routing match policy.
	// Used to specify the message match policy for the topic. `1`: tag match policy (default value); `2`: routing match policy.
	FilterType *float64 `json:"filterType,omitempty" tf:"filter_type,omitempty"`

	// ID of the resource.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	MaxMsgSize *float64 `json:"maxMsgSize,omitempty" tf:"max_msg_size,omitempty"`

	// Message retention period. Value range: 60-86400 seconds (i.e., 1 minute-1 day). Default value: 86400.
	// Message retention period. Value range: 60-86400 seconds (i.e., 1 minute-1 day). Default value: 86400.
	MsgRetentionSeconds *float64 `json:"msgRetentionSeconds,omitempty" tf:"msg_retention_seconds,omitempty"`

	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	TopicName *string `json:"topicName,omitempty" tf:"topic_name,omitempty"`

	// Whether to enable message trace. true: yes; false: no. If this field is left empty, the feature will not be enabled.
	// Whether to enable message trace. true: yes; false: no. If this field is left empty, the feature will not be enabled.
	Trace *bool `json:"trace,omitempty" tf:"trace,omitempty"`
}

func (*TopicObservation) DeepCopy 

func (in *TopicObservation) DeepCopy() *TopicObservation

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

func (*TopicObservation) DeepCopyInto 

func (in *TopicObservation) DeepCopyInto(out *TopicObservation)

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

type TopicParameters 

type TopicParameters struct {

	// Used to specify the message match policy for the topic. 1: tag match policy (default value); 2: routing match policy.
	// Used to specify the message match policy for the topic. `1`: tag match policy (default value); `2`: routing match policy.
	// +kubebuilder:validation:Optional
	FilterType *float64 `json:"filterType,omitempty" tf:"filter_type,omitempty"`

	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	// Maximum message length. Value range: 1024-65536 bytes (i.e., 1-64 KB). Default value: 65536.
	// +kubebuilder:validation:Optional
	MaxMsgSize *float64 `json:"maxMsgSize,omitempty" tf:"max_msg_size,omitempty"`

	// Message retention period. Value range: 60-86400 seconds (i.e., 1 minute-1 day). Default value: 86400.
	// Message retention period. Value range: 60-86400 seconds (i.e., 1 minute-1 day). Default value: 86400.
	// +kubebuilder:validation:Optional
	MsgRetentionSeconds *float64 `json:"msgRetentionSeconds,omitempty" tf:"msg_retention_seconds,omitempty"`

	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// Topic name, which must be unique in the same topic under the same account in the same region. It can contain up to 64 letters, digits, and hyphens and must begin with a letter.
	// +kubebuilder:validation:Optional
	TopicName *string `json:"topicName,omitempty" tf:"topic_name,omitempty"`

	// Whether to enable message trace. true: yes; false: no. If this field is left empty, the feature will not be enabled.
	// Whether to enable message trace. true: yes; false: no. If this field is left empty, the feature will not be enabled.
	// +kubebuilder:validation:Optional
	Trace *bool `json:"trace,omitempty" tf:"trace,omitempty"`
}

func (*TopicParameters) DeepCopy 

func (in *TopicParameters) DeepCopy() *TopicParameters

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

func (*TopicParameters) DeepCopyInto 

func (in *TopicParameters) DeepCopyInto(out *TopicParameters)

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

type TopicSpec 

type TopicSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     TopicParameters `json:"forProvider"`
	// THIS IS A BETA FIELD. It will be honored
	// unless the Management Policies feature flag is disabled.
	// InitProvider holds the same fields as ForProvider, with the exception
	// of Identifier and other resource reference fields. The fields that are
	// in InitProvider are merged into ForProvider when the resource is created.
	// The same fields are also added to the terraform ignore_changes hook, to
	// avoid updating them after creation. This is useful for fields that are
	// required on creation, but we do not desire to update them after creation,
	// for example because of an external controller is managing them, like an
	// autoscaler.
	InitProvider TopicInitParameters `json:"initProvider,omitempty"`
}

TopicSpec defines the desired state of Topic

func (*TopicSpec) DeepCopy 

func (in *TopicSpec) DeepCopy() *TopicSpec

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

func (*TopicSpec) DeepCopyInto 

func (in *TopicSpec) DeepCopyInto(out *TopicSpec)

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

type TopicStatus 

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

TopicStatus defines the observed state of Topic.

func (*TopicStatus) DeepCopy 

func (in *TopicStatus) DeepCopy() *TopicStatus

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

func (*TopicStatus) DeepCopyInto 

func (in *TopicStatus) DeepCopyInto(out *TopicStatus)

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.