v1beta1

package
v0.4.2 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

+kubebuilder:object:generate=true +groupName=dms.flexibleengine.upbound.io +versionName=v1beta1

Index

Constants

View Source 
const (
	CRDGroup   = "dms.flexibleengine.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 (
	KafkaInstance_Kind             = "KafkaInstance"
	KafkaInstance_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: KafkaInstance_Kind}.String()
	KafkaInstance_KindAPIVersion   = KafkaInstance_Kind + "." + CRDGroupVersion.String()
	KafkaInstance_GroupVersionKind = CRDGroupVersion.WithKind(KafkaInstance_Kind)
)

Repository type metadata.

View Source 
var (
	KafkaTopic_Kind             = "KafkaTopic"
	KafkaTopic_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: KafkaTopic_Kind}.String()
	KafkaTopic_KindAPIVersion   = KafkaTopic_Kind + "." + CRDGroupVersion.String()
	KafkaTopic_GroupVersionKind = CRDGroupVersion.WithKind(KafkaTopic_Kind)
)

Repository type metadata.

View Source 
var (
	KafkaUser_Kind             = "KafkaUser"
	KafkaUser_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: KafkaUser_Kind}.String()
	KafkaUser_KindAPIVersion   = KafkaUser_Kind + "." + CRDGroupVersion.String()
	KafkaUser_GroupVersionKind = CRDGroupVersion.WithKind(KafkaUser_Kind)
)

Repository type metadata.

View Source 
var (
	RocketMQConsumerGroup_Kind             = "RocketMQConsumerGroup"
	RocketMQConsumerGroup_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: RocketMQConsumerGroup_Kind}.String()
	RocketMQConsumerGroup_KindAPIVersion   = RocketMQConsumerGroup_Kind + "." + CRDGroupVersion.String()
	RocketMQConsumerGroup_GroupVersionKind = CRDGroupVersion.WithKind(RocketMQConsumerGroup_Kind)
)

Repository type metadata.

View Source 
var (
	RocketMQInstance_Kind             = "RocketMQInstance"
	RocketMQInstance_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: RocketMQInstance_Kind}.String()
	RocketMQInstance_KindAPIVersion   = RocketMQInstance_Kind + "." + CRDGroupVersion.String()
	RocketMQInstance_GroupVersionKind = CRDGroupVersion.WithKind(RocketMQInstance_Kind)
)

Repository type metadata.

View Source 
var (
	RocketMQTopic_Kind             = "RocketMQTopic"
	RocketMQTopic_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: RocketMQTopic_Kind}.String()
	RocketMQTopic_KindAPIVersion   = RocketMQTopic_Kind + "." + CRDGroupVersion.String()
	RocketMQTopic_GroupVersionKind = CRDGroupVersion.WithKind(RocketMQTopic_Kind)
)

Repository type metadata.

View Source 
var (
	RocketMQUser_Kind             = "RocketMQUser"
	RocketMQUser_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: RocketMQUser_Kind}.String()
	RocketMQUser_KindAPIVersion   = RocketMQUser_Kind + "." + CRDGroupVersion.String()
	RocketMQUser_GroupVersionKind = CRDGroupVersion.WithKind(RocketMQUser_Kind)
)

Repository type metadata.

Functions

This section is empty.

Types

type BrokersObservation 

type BrokersObservation struct {

	// Indicates the read queues number of the broker. It's useless when create a topic.
	// Indicates the read queues number of the broker.
	ReadQueueNum *float64 `json:"readQueueNum,omitempty" tf:"read_queue_num,omitempty"`

	// Indicates the read queues number of the broker. It's useless when create a topic.
	// Indicates the read queues number of the broker.
	WriteQueueNum *float64 `json:"writeQueueNum,omitempty" tf:"write_queue_num,omitempty"`
}

func (*BrokersObservation) DeepCopy 

func (in *BrokersObservation) DeepCopy() *BrokersObservation

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

func (*BrokersObservation) DeepCopyInto 

func (in *BrokersObservation) DeepCopyInto(out *BrokersObservation)

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

type BrokersParameters 

type BrokersParameters struct {

	// Specifies the name of the topic.
	// Indicates the name of the broker.
	// +kubebuilder:validation:Optional
	Name *string `json:"name,omitempty" tf:"name,omitempty"`
}

func (*BrokersParameters) DeepCopy 

func (in *BrokersParameters) DeepCopy() *BrokersParameters

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

func (*BrokersParameters) DeepCopyInto 

func (in *BrokersParameters) DeepCopyInto(out *BrokersParameters)

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

type CrossVPCAccessesObservation 

type CrossVPCAccessesObservation struct {
	LisenterIP *string `json:"lisenterIp,omitempty" tf:"lisenter_ip,omitempty"`

	Port *float64 `json:"port,omitempty" tf:"port,omitempty"`

	PortID *string `json:"portId,omitempty" tf:"port_id,omitempty"`
}

func (*CrossVPCAccessesObservation) DeepCopy 

func (in *CrossVPCAccessesObservation) DeepCopy() *CrossVPCAccessesObservation

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

func (*CrossVPCAccessesObservation) DeepCopyInto 

func (in *CrossVPCAccessesObservation) DeepCopyInto(out *CrossVPCAccessesObservation)

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

type CrossVPCAccessesParameters 

type CrossVPCAccessesParameters struct {

	// +kubebuilder:validation:Optional
	AdvertisedIP *string `json:"advertisedIp,omitempty" tf:"advertised_ip,omitempty"`
}

func (*CrossVPCAccessesParameters) DeepCopy 

func (in *CrossVPCAccessesParameters) DeepCopy() *CrossVPCAccessesParameters

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

func (*CrossVPCAccessesParameters) DeepCopyInto 

func (in *CrossVPCAccessesParameters) DeepCopyInto(out *CrossVPCAccessesParameters)

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

type GroupPermsObservation 

type GroupPermsObservation struct {
}

func (*GroupPermsObservation) DeepCopy 

func (in *GroupPermsObservation) DeepCopy() *GroupPermsObservation

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

func (*GroupPermsObservation) DeepCopyInto 

func (in *GroupPermsObservation) DeepCopyInto(out *GroupPermsObservation)

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

type GroupPermsParameters 

type GroupPermsParameters struct {

	// Indicates the name of a topic or consumer group.
	// Indicates the name of a topic or consumer group.
	// +crossplane:generate:reference:type=RocketMQConsumerGroup
	// +kubebuilder:validation:Optional
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// Reference to a RocketMQConsumerGroup to populate name.
	// +kubebuilder:validation:Optional
	NameRef *v1.Reference `json:"nameRef,omitempty" tf:"-"`

	// Selector for a RocketMQConsumerGroup to populate name.
	// +kubebuilder:validation:Optional
	NameSelector *v1.Selector `json:"nameSelector,omitempty" tf:"-"`

	// Indicates the permissions of the topic or consumer group.
	// Value options: PUB|SUB, PUB, SUB, DENY.
	// Indicates the permissions of the topic or consumer group.
	// Value options: **PUB|SUB**, **PUB**, **SUB**, **DENY**.
	// +kubebuilder:validation:Optional
	Perm *string `json:"perm,omitempty" tf:"perm,omitempty"`
}

func (*GroupPermsParameters) DeepCopy 

func (in *GroupPermsParameters) DeepCopy() *GroupPermsParameters

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

func (*GroupPermsParameters) DeepCopyInto 

func (in *GroupPermsParameters) DeepCopyInto(out *GroupPermsParameters)

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

type KafkaInstance 

type KafkaInstance struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              KafkaInstanceSpec   `json:"spec"`
	Status            KafkaInstanceStatus `json:"status,omitempty"`
}

KafkaInstance is the Schema for the KafkaInstances API. ""page_title: "flexibleengine_dms_kafka_instance" +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,flexibleengine}

func (*KafkaInstance) DeepCopy 

func (in *KafkaInstance) DeepCopy() *KafkaInstance

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

func (*KafkaInstance) DeepCopyInto 

func (in *KafkaInstance) DeepCopyInto(out *KafkaInstance)

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

func (*KafkaInstance) DeepCopyObject 

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

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

func (*KafkaInstance) GetCondition 

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

GetCondition of this KafkaInstance.

func (*KafkaInstance) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this KafkaInstance

func (*KafkaInstance) GetDeletionPolicy 

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

GetDeletionPolicy of this KafkaInstance.

func (*KafkaInstance) GetID 

func (tr *KafkaInstance) GetID() string

GetID returns ID of underlying Terraform resource of this KafkaInstance

func (*KafkaInstance) GetObservation 

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

GetObservation of this KafkaInstance

func (*KafkaInstance) GetParameters 

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

GetParameters of this KafkaInstance

func (*KafkaInstance) GetProviderConfigReference 

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

GetProviderConfigReference of this KafkaInstance.

func (*KafkaInstance) GetProviderReference 

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

GetProviderReference of this KafkaInstance. Deprecated: Use GetProviderConfigReference.

func (*KafkaInstance) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this KafkaInstance.

func (*KafkaInstance) GetTerraformResourceType 

func (mg *KafkaInstance) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this KafkaInstance

func (*KafkaInstance) GetTerraformSchemaVersion 

func (tr *KafkaInstance) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*KafkaInstance) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this KafkaInstance.

func (*KafkaInstance) LateInitialize 

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

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

func (*KafkaInstance) ResolveReferences 

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

ResolveReferences of this KafkaInstance.

func (*KafkaInstance) SetConditions 

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

SetConditions of this KafkaInstance.

func (*KafkaInstance) SetDeletionPolicy 

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

SetDeletionPolicy of this KafkaInstance.

func (*KafkaInstance) SetObservation 

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

SetObservation for this KafkaInstance

func (*KafkaInstance) SetParameters 

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

SetParameters for this KafkaInstance

func (*KafkaInstance) SetProviderConfigReference 

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

SetProviderConfigReference of this KafkaInstance.

func (*KafkaInstance) SetProviderReference 

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

SetProviderReference of this KafkaInstance. Deprecated: Use SetProviderConfigReference.

func (*KafkaInstance) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this KafkaInstance.

func (*KafkaInstance) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this KafkaInstance.

type KafkaInstanceList 

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

KafkaInstanceList contains a list of KafkaInstances

func (*KafkaInstanceList) DeepCopy 

func (in *KafkaInstanceList) DeepCopy() *KafkaInstanceList

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

func (*KafkaInstanceList) DeepCopyInto 

func (in *KafkaInstanceList) DeepCopyInto(out *KafkaInstanceList)

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

func (*KafkaInstanceList) DeepCopyObject 

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

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

func (*KafkaInstanceList) GetItems 

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

GetItems of this KafkaInstanceList.

type KafkaInstanceObservation 

type KafkaInstanceObservation struct {

	// Indicates the IP addresses of the DMS Kafka instance.
	ConnectAddress *string `json:"connectAddress,omitempty" tf:"connect_address,omitempty"`

	// Indicates the creation time of the DMS Kafka instance.
	CreatedAt *string `json:"createdAt,omitempty" tf:"created_at,omitempty"`

	// Indicates the message engine, the value is "kafka".
	Engine *string `json:"engine,omitempty" tf:"engine,omitempty"`

	// Indicates the DMS Kafka instance type, the value is "cluster".
	EngineType *string `json:"engineType,omitempty" tf:"engine_type,omitempty"`

	// Specifies a resource ID in UUID format.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// Indicates the connection address of the Kafka Manager of a Kafka instance.
	ManegementConnectAddress *string `json:"manegementConnectAddress,omitempty" tf:"manegement_connect_address,omitempty"`

	// Indicates the count of ECS instances.
	NodeNum *float64 `json:"nodeNum,omitempty" tf:"node_num,omitempty"`

	// Indicates the maximum number of topics in the DMS Kafka instance.
	PartitionNum *float64 `json:"partitionNum,omitempty" tf:"partition_num,omitempty"`

	// Indicates the port number of the DMS Kafka instance.
	Port *float64 `json:"port,omitempty" tf:"port,omitempty"`

	// Indicates the DMS Kafka instance specification.
	ProductSpecCode *string `json:"productSpecCode,omitempty" tf:"product_spec_code,omitempty"`

	// Indicates whether the Kafka SASL_SSL is enabled.
	SSLEnable *bool `json:"sslEnable,omitempty" tf:"ssl_enable,omitempty"`

	// Indicates the name of a security group.
	SecurityGroupName *string `json:"securityGroupName,omitempty" tf:"security_group_name,omitempty"`

	// Indicates the status of the DMS Kafka instance.
	Status *string `json:"status,omitempty" tf:"status,omitempty"`

	// Indicates the name of a subnet.
	SubnetName *string `json:"subnetName,omitempty" tf:"subnet_name,omitempty"`

	// Indicates the used message storage space. Unit: GB
	UsedStorageSpace *float64 `json:"usedStorageSpace,omitempty" tf:"used_storage_space,omitempty"`

	// Indicates the name of a vpc.
	VPCName *string `json:"vpcName,omitempty" tf:"vpc_name,omitempty"`
}

func (*KafkaInstanceObservation) DeepCopy 

func (in *KafkaInstanceObservation) DeepCopy() *KafkaInstanceObservation

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

func (*KafkaInstanceObservation) DeepCopyInto 

func (in *KafkaInstanceObservation) DeepCopyInto(out *KafkaInstanceObservation)

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

type KafkaInstanceParameters 

type KafkaInstanceParameters struct {

	// Specifies a username who can accesse the instance with
	// SASL authentication. A username consists of 4 to 64 characters and supports only letters, digits, and hyphens (-).
	// Changing this creates a new instance resource.
	// +kubebuilder:validation:Optional
	AccessUser *string `json:"accessUser,omitempty" tf:"access_user,omitempty"`

	// The names of the AZ where the Kafka instance resides.
	// Changing this creates a new instance resource.
	// +kubebuilder:validation:Required
	AvailabilityZones []*string `json:"availabilityZones" tf:"availability_zones,omitempty"`

	// The baseline bandwidth of a Kafka instance, that is, the maximum amount of
	// data transferred per unit time. The valid values are 100MB, 300MB, 600MB and 1200MB.
	// Changing this creates a new instance resource.
	// +kubebuilder:validation:Required
	Bandwidth *string `json:"bandwidth" tf:"bandwidth,omitempty"`

	// Specifies the description of the DMS Kafka instance.
	// It is a character string containing not more than 1,024 characters.
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// Specifies whether to enable automatic topic creation. If automatic
	// topic creation is enabled, a topic will be automatically created with 3 partitions and 3 replicas when a message is
	// produced to or consumed from a topic that does not exist. Changing this creates a new instance resource.
	// +kubebuilder:validation:Optional
	EnableAutoTopic *bool `json:"enableAutoTopic,omitempty" tf:"enable_auto_topic,omitempty"`

	// Specifies the version of the Kafka engine. Valid values are "1.1.0"
	// and "2.3.0". Defaults to 2.3.0. Changing this creates a new instance resource.
	// +kubebuilder:validation:Optional
	EngineVersion *string `json:"engineVersion,omitempty" tf:"engine_version,omitempty"`

	// Specifies the time at which a maintenance time window starts. Format: HH:mm:ss.
	// The start time must be set to 22:00:00, 02:00:00, 06:00:00, 10:00:00, 14:00:00, or 18:00:00.
	// The system automatically allocates the default start time 02:00:00.
	// +kubebuilder:validation:Optional
	MaintainBegin *string `json:"maintainBegin,omitempty" tf:"maintain_begin,omitempty"`

	// Specifies the time at which a maintenance time window ends. Format: HH:mm:ss.
	// The end time is four hours later than the start time. For example, if the start time is 22:00:00, the end time is
	// 02:00:00. The system automatically allocates the default end time 06:00:00.
	// +kubebuilder:validation:Optional
	MaintainEnd *string `json:"maintainEnd,omitempty" tf:"maintain_end,omitempty"`

	// Specifies the password for logging in to the Kafka Manager. The
	// password must meet the following complexity requirements: Must be 8 to 32 characters long. Must contain at least 2 of
	// the following character types: lowercase letters, uppercase letters, digits, and special characters (`~!@#$%^&*()-_
	// =+\|[{}]:'",<.>/?). Changing this creates a new instance resource.
	// +kubebuilder:validation:Optional
	ManagerPasswordSecretRef *v1.SecretKeySelector `json:"managerPasswordSecretRef,omitempty" tf:"-"`

	// Specifies the username for logging in to the Kafka Manager.
	// The username consists of 4 to 64 characters and can contain letters, digits, hyphens (-), and underscores (_).
	// Changing this creates a new instance resource.
	// +kubebuilder:validation:Optional
	ManagerUser *string `json:"managerUser,omitempty" tf:"manager_user,omitempty"`

	// Specifies the name of the DMS Kafka instance. An instance name starts with a letter,
	// consists of 4 to 64 characters, and supports only letters, digits, hyphens (-) and underscores (_).
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// Specifies the ID of a VPC subnet.
	// Changing this creates a new instance resource.
	// +crossplane:generate:reference:type=github.com/FlexibleEngineCloud/provider-flexibleengine/apis/vpc/v1beta1.VPCSubnet
	// +crossplane:generate:reference:extractor=github.com/FlexibleEngineCloud/provider-flexibleengine/pkg/tools.ExtractorParamPathfunc(true, "id")
	// +crossplane:generate:reference:refFieldName=NetworkIDRef
	// +crossplane:generate:reference:selectorFieldName=NetworkIDSelector
	// +kubebuilder:validation:Optional
	NetworkID *string `json:"networkId,omitempty" tf:"network_id,omitempty"`

	// Reference to a VPCSubnet in vpc to populate networkId.
	// +kubebuilder:validation:Optional
	NetworkIDRef *v1.Reference `json:"networkIdRef,omitempty" tf:"-"`

	// Selector for a VPCSubnet in vpc to populate networkId.
	// +kubebuilder:validation:Optional
	NetworkIDSelector *v1.Selector `json:"networkIdSelector,omitempty" tf:"-"`

	// Specifies the password of the access user. A password must meet the
	// following complexity requirements: Must be 8 to 32 characters long. Must contain at least 2 of the following character
	// types: lowercase letters, uppercase letters, digits, and special characters (`~!@#$%^&*()-_=+\|[{}]:'",<.>/?).
	// Changing this creates a new instance resource.
	// +kubebuilder:validation:Optional
	PasswordSecretRef *v1.SecretKeySelector `json:"passwordSecretRef,omitempty" tf:"-"`

	// Specifies a product ID. You can get the value from id of
	// flexibleengine_dms_product
	// data source. Changing this creates a new instance resource.
	// +kubebuilder:validation:Required
	ProductID *string `json:"productId" tf:"product_id,omitempty"`

	// Specifies the region in which to create the DMS Kafka instance resource.
	// If omitted, the provider-level region will be used. Changing this creates a new instance resource.
	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// Specifies the ID of a security group.
	// +crossplane:generate:reference:type=github.com/FlexibleEngineCloud/provider-flexibleengine/apis/vpc/v1beta1.SecurityGroup
	// +crossplane:generate:reference:refFieldName=SecurityGroupIDRef
	// +crossplane:generate:reference:selectorFieldName=SecurityGroupIDSelector
	// +kubebuilder:validation:Optional
	SecurityGroupID *string `json:"securityGroupId,omitempty" tf:"security_group_id,omitempty"`

	// Reference to a SecurityGroup in vpc to populate securityGroupId.
	// +kubebuilder:validation:Optional
	SecurityGroupIDRef *v1.Reference `json:"securityGroupIdRef,omitempty" tf:"-"`

	// Selector for a SecurityGroup in vpc to populate securityGroupId.
	// +kubebuilder:validation:Optional
	SecurityGroupIDSelector *v1.Selector `json:"securityGroupIdSelector,omitempty" tf:"-"`

	// Specifies the message storage capacity, the unit is GB. Value range:
	// +kubebuilder:validation:Required
	StorageSpace *float64 `json:"storageSpace" tf:"storage_space,omitempty"`

	// Specifies the storage I/O specification. Value range:
	// +kubebuilder:validation:Optional
	StorageSpecCode *string `json:"storageSpecCode,omitempty" tf:"storage_spec_code,omitempty"`

	// Specifies the ID of a VPC.
	// Changing this creates a new instance resource.
	// +crossplane:generate:reference:type=github.com/FlexibleEngineCloud/provider-flexibleengine/apis/vpc/v1beta1.VPC
	// +kubebuilder:validation:Optional
	VPCID *string `json:"vpcId,omitempty" tf:"vpc_id,omitempty"`

	// Reference to a VPC in vpc to populate vpcId.
	// +kubebuilder:validation:Optional
	VPCIDRef *v1.Reference `json:"vpcIdRef,omitempty" tf:"-"`

	// Selector for a VPC in vpc to populate vpcId.
	// +kubebuilder:validation:Optional
	VPCIDSelector *v1.Selector `json:"vpcIdSelector,omitempty" tf:"-"`
}

func (*KafkaInstanceParameters) DeepCopy 

func (in *KafkaInstanceParameters) DeepCopy() *KafkaInstanceParameters

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

func (*KafkaInstanceParameters) DeepCopyInto 

func (in *KafkaInstanceParameters) DeepCopyInto(out *KafkaInstanceParameters)

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

type KafkaInstanceSpec 

type KafkaInstanceSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     KafkaInstanceParameters `json:"forProvider"`
}

KafkaInstanceSpec defines the desired state of KafkaInstance

func (*KafkaInstanceSpec) DeepCopy 

func (in *KafkaInstanceSpec) DeepCopy() *KafkaInstanceSpec

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

func (*KafkaInstanceSpec) DeepCopyInto 

func (in *KafkaInstanceSpec) DeepCopyInto(out *KafkaInstanceSpec)

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

type KafkaInstanceStatus 

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

KafkaInstanceStatus defines the observed state of KafkaInstance.

func (*KafkaInstanceStatus) DeepCopy 

func (in *KafkaInstanceStatus) DeepCopy() *KafkaInstanceStatus

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

func (*KafkaInstanceStatus) DeepCopyInto 

func (in *KafkaInstanceStatus) DeepCopyInto(out *KafkaInstanceStatus)

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

type KafkaTopic 

type KafkaTopic struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              KafkaTopicSpec   `json:"spec"`
	Status            KafkaTopicStatus `json:"status,omitempty"`
}

KafkaTopic is the Schema for the KafkaTopics API. ""page_title: "flexibleengine_dms_kafka_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:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,flexibleengine}

func (*KafkaTopic) DeepCopy 

func (in *KafkaTopic) DeepCopy() *KafkaTopic

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

func (*KafkaTopic) DeepCopyInto 

func (in *KafkaTopic) DeepCopyInto(out *KafkaTopic)

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

func (*KafkaTopic) DeepCopyObject 

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

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

func (*KafkaTopic) GetCondition 

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

GetCondition of this KafkaTopic.

func (*KafkaTopic) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this KafkaTopic

func (*KafkaTopic) GetDeletionPolicy 

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

GetDeletionPolicy of this KafkaTopic.

func (*KafkaTopic) GetID 

func (tr *KafkaTopic) GetID() string

GetID returns ID of underlying Terraform resource of this KafkaTopic

func (*KafkaTopic) GetObservation 

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

GetObservation of this KafkaTopic

func (*KafkaTopic) GetParameters 

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

GetParameters of this KafkaTopic

func (*KafkaTopic) GetProviderConfigReference 

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

GetProviderConfigReference of this KafkaTopic.

func (*KafkaTopic) GetProviderReference 

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

GetProviderReference of this KafkaTopic. Deprecated: Use GetProviderConfigReference.

func (*KafkaTopic) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this KafkaTopic.

func (*KafkaTopic) GetTerraformResourceType 

func (mg *KafkaTopic) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this KafkaTopic

func (*KafkaTopic) GetTerraformSchemaVersion 

func (tr *KafkaTopic) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*KafkaTopic) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this KafkaTopic.

func (*KafkaTopic) LateInitialize 

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

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

func (*KafkaTopic) ResolveReferences 

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

ResolveReferences of this KafkaTopic.

func (*KafkaTopic) SetConditions 

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

SetConditions of this KafkaTopic.

func (*KafkaTopic) SetDeletionPolicy 

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

SetDeletionPolicy of this KafkaTopic.

func (*KafkaTopic) SetObservation 

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

SetObservation for this KafkaTopic

func (*KafkaTopic) SetParameters 

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

SetParameters for this KafkaTopic

func (*KafkaTopic) SetProviderConfigReference 

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

SetProviderConfigReference of this KafkaTopic.

func (*KafkaTopic) SetProviderReference 

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

SetProviderReference of this KafkaTopic. Deprecated: Use SetProviderConfigReference.

func (*KafkaTopic) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this KafkaTopic.

func (*KafkaTopic) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this KafkaTopic.

type KafkaTopicList 

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

KafkaTopicList contains a list of KafkaTopics

func (*KafkaTopicList) DeepCopy 

func (in *KafkaTopicList) DeepCopy() *KafkaTopicList

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

func (*KafkaTopicList) DeepCopyInto 

func (in *KafkaTopicList) DeepCopyInto(out *KafkaTopicList)

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

func (*KafkaTopicList) DeepCopyObject 

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

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

func (*KafkaTopicList) GetItems 

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

GetItems of this KafkaTopicList.

type KafkaTopicObservation 

type KafkaTopicObservation struct {

	// The resource ID which equals to the topic name.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`
}

func (*KafkaTopicObservation) DeepCopy 

func (in *KafkaTopicObservation) DeepCopy() *KafkaTopicObservation

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

func (*KafkaTopicObservation) DeepCopyInto 

func (in *KafkaTopicObservation) DeepCopyInto(out *KafkaTopicObservation)

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

type KafkaTopicParameters 

type KafkaTopicParameters struct {

	// Specifies the aging time in hours.
	// The value ranges from 1 to 720 and defaults to 72. Changing this creates a new resource.
	// +kubebuilder:validation:Optional
	AgingTime *float64 `json:"agingTime,omitempty" tf:"aging_time,omitempty"`

	// Specifies the ID of the DMS Kafka instance to which the topic belongs.
	// Changing this creates a new resource.
	// +crossplane:generate:reference:type=github.com/FlexibleEngineCloud/provider-flexibleengine/apis/dms/v1beta1.KafkaInstance
	// +kubebuilder:validation:Optional
	InstanceID *string `json:"instanceId,omitempty" tf:"instance_id,omitempty"`

	// Reference to a KafkaInstance in dms to populate instanceId.
	// +kubebuilder:validation:Optional
	InstanceIDRef *v1.Reference `json:"instanceIdRef,omitempty" tf:"-"`

	// Selector for a KafkaInstance in dms to populate instanceId.
	// +kubebuilder:validation:Optional
	InstanceIDSelector *v1.Selector `json:"instanceIdSelector,omitempty" tf:"-"`

	// Specifies the name of the topic. The name starts with a letter,
	// consists of 4 to 64 characters, and supports only letters, digits, hyphens (-) and underscores (_).
	// Changing this creates a new resource.
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// Specifies the partition number.
	// The value ranges from 1 to 50 and defaults to 3. Changing this creates a new resource.
	// +kubebuilder:validation:Optional
	Partitions *float64 `json:"partitions,omitempty" tf:"partitions,omitempty"`

	// The region in which to create the DMS Kafka topic resource.
	// If omitted, the provider-level region will be used. Changing this creates a new resource.
	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// Specifies the replica number. The value ranges from 1 to 3 and defaults to 3.
	// Changing this creates a new resource.
	// +kubebuilder:validation:Optional
	Replicas *float64 `json:"replicas,omitempty" tf:"replicas,omitempty"`

	// Whether or not to enable synchronous flushing.
	// Changing this creates a new resource.
	// +kubebuilder:validation:Optional
	SyncFlushing *bool `json:"syncFlushing,omitempty" tf:"sync_flushing,omitempty"`

	// Whether or not to enable synchronous replication.
	// Changing this creates a new resource.
	// +kubebuilder:validation:Optional
	SyncReplication *bool `json:"syncReplication,omitempty" tf:"sync_replication,omitempty"`
}

func (*KafkaTopicParameters) DeepCopy 

func (in *KafkaTopicParameters) DeepCopy() *KafkaTopicParameters

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

func (*KafkaTopicParameters) DeepCopyInto 

func (in *KafkaTopicParameters) DeepCopyInto(out *KafkaTopicParameters)

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

type KafkaTopicSpec 

type KafkaTopicSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     KafkaTopicParameters `json:"forProvider"`
}

KafkaTopicSpec defines the desired state of KafkaTopic

func (*KafkaTopicSpec) DeepCopy 

func (in *KafkaTopicSpec) DeepCopy() *KafkaTopicSpec

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

func (*KafkaTopicSpec) DeepCopyInto 

func (in *KafkaTopicSpec) DeepCopyInto(out *KafkaTopicSpec)

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

type KafkaTopicStatus 

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

KafkaTopicStatus defines the observed state of KafkaTopic.

func (*KafkaTopicStatus) DeepCopy 

func (in *KafkaTopicStatus) DeepCopy() *KafkaTopicStatus

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

func (*KafkaTopicStatus) DeepCopyInto 

func (in *KafkaTopicStatus) DeepCopyInto(out *KafkaTopicStatus)

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

type KafkaUser 

type KafkaUser struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              KafkaUserSpec   `json:"spec"`
	Status            KafkaUserStatus `json:"status,omitempty"`
}

KafkaUser is the Schema for the KafkaUsers API. ""page_title: "flexibleengine_dms_kafka_user" +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,flexibleengine}

func (*KafkaUser) DeepCopy 

func (in *KafkaUser) DeepCopy() *KafkaUser

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

func (*KafkaUser) DeepCopyInto 

func (in *KafkaUser) DeepCopyInto(out *KafkaUser)

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

func (*KafkaUser) DeepCopyObject 

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

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

func (*KafkaUser) GetCondition 

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

GetCondition of this KafkaUser.

func (*KafkaUser) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this KafkaUser

func (*KafkaUser) GetDeletionPolicy 

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

GetDeletionPolicy of this KafkaUser.

func (*KafkaUser) GetID 

func (tr *KafkaUser) GetID() string

GetID returns ID of underlying Terraform resource of this KafkaUser

func (*KafkaUser) GetObservation 

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

GetObservation of this KafkaUser

func (*KafkaUser) GetParameters 

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

GetParameters of this KafkaUser

func (*KafkaUser) GetProviderConfigReference 

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

GetProviderConfigReference of this KafkaUser.

func (*KafkaUser) GetProviderReference 

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

GetProviderReference of this KafkaUser. Deprecated: Use GetProviderConfigReference.

func (*KafkaUser) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this KafkaUser.

func (*KafkaUser) GetTerraformResourceType 

func (mg *KafkaUser) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this KafkaUser

func (*KafkaUser) GetTerraformSchemaVersion 

func (tr *KafkaUser) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*KafkaUser) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this KafkaUser.

func (*KafkaUser) LateInitialize 

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

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

func (*KafkaUser) ResolveReferences 

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

ResolveReferences of this KafkaUser.

func (*KafkaUser) SetConditions 

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

SetConditions of this KafkaUser.

func (*KafkaUser) SetDeletionPolicy 

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

SetDeletionPolicy of this KafkaUser.

func (*KafkaUser) SetObservation 

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

SetObservation for this KafkaUser

func (*KafkaUser) SetParameters 

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

SetParameters for this KafkaUser

func (*KafkaUser) SetProviderConfigReference 

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

SetProviderConfigReference of this KafkaUser.

func (*KafkaUser) SetProviderReference 

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

SetProviderReference of this KafkaUser. Deprecated: Use SetProviderConfigReference.

func (*KafkaUser) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this KafkaUser.

func (*KafkaUser) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this KafkaUser.

type KafkaUserList 

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

KafkaUserList contains a list of KafkaUsers

func (*KafkaUserList) DeepCopy 

func (in *KafkaUserList) DeepCopy() *KafkaUserList

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

func (*KafkaUserList) DeepCopyInto 

func (in *KafkaUserList) DeepCopyInto(out *KafkaUserList)

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

func (*KafkaUserList) DeepCopyObject 

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

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

func (*KafkaUserList) GetItems 

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

GetItems of this KafkaUserList.

type KafkaUserObservation 

type KafkaUserObservation struct {

	// The resource ID which is formatted <instance_id>/<user_name>.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`
}

func (*KafkaUserObservation) DeepCopy 

func (in *KafkaUserObservation) DeepCopy() *KafkaUserObservation

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

func (*KafkaUserObservation) DeepCopyInto 

func (in *KafkaUserObservation) DeepCopyInto(out *KafkaUserObservation)

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

type KafkaUserParameters 

type KafkaUserParameters struct {

	// Specifies the ID of the DMS kafka instance to which the user belongs.
	// Changing this creates a new resource.
	// +crossplane:generate:reference:type=github.com/FlexibleEngineCloud/provider-flexibleengine/apis/dms/v1beta1.KafkaInstance
	// +kubebuilder:validation:Optional
	InstanceID *string `json:"instanceId,omitempty" tf:"instance_id,omitempty"`

	// Reference to a KafkaInstance in dms to populate instanceId.
	// +kubebuilder:validation:Optional
	InstanceIDRef *v1.Reference `json:"instanceIdRef,omitempty" tf:"-"`

	// Selector for a KafkaInstance in dms to populate instanceId.
	// +kubebuilder:validation:Optional
	InstanceIDSelector *v1.Selector `json:"instanceIdSelector,omitempty" tf:"-"`

	// Specifies the name of the user. Changing this creates a new resource.
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// Specifies the password of the user. The parameter must be 8 to 32 characters
	// long and contain only letters(case-sensitive), digits, and special characters(`~!@#$%^&*()-_=+|[{}]:'",<.>/?).
	// The value must be different from name.
	// +kubebuilder:validation:Required
	PasswordSecretRef v1.SecretKeySelector `json:"passwordSecretRef" tf:"-"`

	// The region in which to create the DMS kafka user resource. If omitted, the
	// provider-level region will be used. Changing this creates a new resource.
	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`
}

func (*KafkaUserParameters) DeepCopy 

func (in *KafkaUserParameters) DeepCopy() *KafkaUserParameters

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

func (*KafkaUserParameters) DeepCopyInto 

func (in *KafkaUserParameters) DeepCopyInto(out *KafkaUserParameters)

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

type KafkaUserSpec 

type KafkaUserSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     KafkaUserParameters `json:"forProvider"`
}

KafkaUserSpec defines the desired state of KafkaUser

func (*KafkaUserSpec) DeepCopy 

func (in *KafkaUserSpec) DeepCopy() *KafkaUserSpec

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

func (*KafkaUserSpec) DeepCopyInto 

func (in *KafkaUserSpec) DeepCopyInto(out *KafkaUserSpec)

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

type KafkaUserStatus 

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

KafkaUserStatus defines the observed state of KafkaUser.

func (*KafkaUserStatus) DeepCopy 

func (in *KafkaUserStatus) DeepCopy() *KafkaUserStatus

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

func (*KafkaUserStatus) DeepCopyInto 

func (in *KafkaUserStatus) DeepCopyInto(out *KafkaUserStatus)

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

type RocketMQConsumerGroup 

type RocketMQConsumerGroup struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              RocketMQConsumerGroupSpec   `json:"spec"`
	Status            RocketMQConsumerGroupStatus `json:"status,omitempty"`
}

RocketMQConsumerGroup is the Schema for the RocketMQConsumerGroups API. +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,flexibleengine}

func (*RocketMQConsumerGroup) DeepCopy 

func (in *RocketMQConsumerGroup) DeepCopy() *RocketMQConsumerGroup

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

func (*RocketMQConsumerGroup) DeepCopyInto 

func (in *RocketMQConsumerGroup) DeepCopyInto(out *RocketMQConsumerGroup)

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

func (*RocketMQConsumerGroup) DeepCopyObject 

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

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

func (*RocketMQConsumerGroup) GetCondition 

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

GetCondition of this RocketMQConsumerGroup.

func (*RocketMQConsumerGroup) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this RocketMQConsumerGroup

func (*RocketMQConsumerGroup) GetDeletionPolicy 

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

GetDeletionPolicy of this RocketMQConsumerGroup.

func (*RocketMQConsumerGroup) GetID 

func (tr *RocketMQConsumerGroup) GetID() string

GetID returns ID of underlying Terraform resource of this RocketMQConsumerGroup

func (*RocketMQConsumerGroup) GetObservation 

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

GetObservation of this RocketMQConsumerGroup

func (*RocketMQConsumerGroup) GetParameters 

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

GetParameters of this RocketMQConsumerGroup

func (*RocketMQConsumerGroup) GetProviderConfigReference 

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

GetProviderConfigReference of this RocketMQConsumerGroup.

func (*RocketMQConsumerGroup) GetProviderReference 

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

GetProviderReference of this RocketMQConsumerGroup. Deprecated: Use GetProviderConfigReference.

func (*RocketMQConsumerGroup) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this RocketMQConsumerGroup.

func (*RocketMQConsumerGroup) GetTerraformResourceType 

func (mg *RocketMQConsumerGroup) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this RocketMQConsumerGroup

func (*RocketMQConsumerGroup) GetTerraformSchemaVersion 

func (tr *RocketMQConsumerGroup) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*RocketMQConsumerGroup) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this RocketMQConsumerGroup.

func (*RocketMQConsumerGroup) LateInitialize 

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

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

func (*RocketMQConsumerGroup) ResolveReferences 

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

ResolveReferences of this RocketMQConsumerGroup.

func (*RocketMQConsumerGroup) SetConditions 

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

SetConditions of this RocketMQConsumerGroup.

func (*RocketMQConsumerGroup) SetDeletionPolicy 

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

SetDeletionPolicy of this RocketMQConsumerGroup.

func (*RocketMQConsumerGroup) SetObservation 

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

SetObservation for this RocketMQConsumerGroup

func (*RocketMQConsumerGroup) SetParameters 

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

SetParameters for this RocketMQConsumerGroup

func (*RocketMQConsumerGroup) SetProviderConfigReference 

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

SetProviderConfigReference of this RocketMQConsumerGroup.

func (*RocketMQConsumerGroup) SetProviderReference 

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

SetProviderReference of this RocketMQConsumerGroup. Deprecated: Use SetProviderConfigReference.

func (*RocketMQConsumerGroup) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this RocketMQConsumerGroup.

func (*RocketMQConsumerGroup) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this RocketMQConsumerGroup.

type RocketMQConsumerGroupList 

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

RocketMQConsumerGroupList contains a list of RocketMQConsumerGroups

func (*RocketMQConsumerGroupList) DeepCopy 

func (in *RocketMQConsumerGroupList) DeepCopy() *RocketMQConsumerGroupList

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

func (*RocketMQConsumerGroupList) DeepCopyInto 

func (in *RocketMQConsumerGroupList) DeepCopyInto(out *RocketMQConsumerGroupList)

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

func (*RocketMQConsumerGroupList) DeepCopyObject 

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

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

func (*RocketMQConsumerGroupList) GetItems 

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

GetItems of this RocketMQConsumerGroupList.

type RocketMQConsumerGroupObservation 

type RocketMQConsumerGroupObservation struct {

	// The resource ID.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`
}

func (*RocketMQConsumerGroupObservation) DeepCopy 

func (in *RocketMQConsumerGroupObservation) DeepCopy() *RocketMQConsumerGroupObservation

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

func (*RocketMQConsumerGroupObservation) DeepCopyInto 

func (in *RocketMQConsumerGroupObservation) DeepCopyInto(out *RocketMQConsumerGroupObservation)

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

type RocketMQConsumerGroupParameters 

type RocketMQConsumerGroupParameters struct {

	// Specifies whether to broadcast of the consumer group.
	// Specifies whether to broadcast of the consumer group.
	// +kubebuilder:validation:Optional
	Broadcast *bool `json:"broadcast,omitempty" tf:"broadcast,omitempty"`

	// Specifies the list of associated brokers of the consumer group.
	// Specifies the list of associated brokers of the consumer group.
	// +kubebuilder:validation:Required
	Brokers []*string `json:"brokers" tf:"brokers,omitempty"`

	// Specifies the consumer group is enabled or not. Default to true.
	// Specifies the consumer group is enabled or not. Default to true.
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"`

	// Specifies the ID of the rocketMQ instance.
	// Specifies the ID of the rocketMQ instance.
	// +crossplane:generate:reference:type=github.com/FlexibleEngineCloud/provider-flexibleengine/apis/dms/v1beta1.RocketMQInstance
	// +kubebuilder:validation:Optional
	InstanceID *string `json:"instanceId,omitempty" tf:"instance_id,omitempty"`

	// Reference to a RocketMQInstance in dms to populate instanceId.
	// +kubebuilder:validation:Optional
	InstanceIDRef *v1.Reference `json:"instanceIdRef,omitempty" tf:"-"`

	// Selector for a RocketMQInstance in dms to populate instanceId.
	// +kubebuilder:validation:Optional
	InstanceIDSelector *v1.Selector `json:"instanceIdSelector,omitempty" tf:"-"`

	// Specifies the name of the consumer group.
	// Specifies the name of the consumer group.
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// Specifies the region in which to create the resource.
	// If omitted, the provider-level region will be used. Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// Specifies the maximum number of retry times.
	// Specifies the maximum number of retry times.
	// +kubebuilder:validation:Required
	RetryMaxTimes *float64 `json:"retryMaxTimes" tf:"retry_max_times,omitempty"`
}

func (*RocketMQConsumerGroupParameters) DeepCopy 

func (in *RocketMQConsumerGroupParameters) DeepCopy() *RocketMQConsumerGroupParameters

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

func (*RocketMQConsumerGroupParameters) DeepCopyInto 

func (in *RocketMQConsumerGroupParameters) DeepCopyInto(out *RocketMQConsumerGroupParameters)

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

type RocketMQConsumerGroupSpec 

type RocketMQConsumerGroupSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     RocketMQConsumerGroupParameters `json:"forProvider"`
}

RocketMQConsumerGroupSpec defines the desired state of RocketMQConsumerGroup

func (*RocketMQConsumerGroupSpec) DeepCopy 

func (in *RocketMQConsumerGroupSpec) DeepCopy() *RocketMQConsumerGroupSpec

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

func (*RocketMQConsumerGroupSpec) DeepCopyInto 

func (in *RocketMQConsumerGroupSpec) DeepCopyInto(out *RocketMQConsumerGroupSpec)

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

type RocketMQConsumerGroupStatus 

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

RocketMQConsumerGroupStatus defines the observed state of RocketMQConsumerGroup.

func (*RocketMQConsumerGroupStatus) DeepCopy 

func (in *RocketMQConsumerGroupStatus) DeepCopy() *RocketMQConsumerGroupStatus

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

func (*RocketMQConsumerGroupStatus) DeepCopyInto 

func (in *RocketMQConsumerGroupStatus) DeepCopyInto(out *RocketMQConsumerGroupStatus)

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

type RocketMQInstance 

type RocketMQInstance struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              RocketMQInstanceSpec   `json:"spec"`
	Status            RocketMQInstanceStatus `json:"status,omitempty"`
}

RocketMQInstance is the Schema for the RocketMQInstances API. <no value> +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,flexibleengine}

func (*RocketMQInstance) DeepCopy 

func (in *RocketMQInstance) DeepCopy() *RocketMQInstance

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

func (*RocketMQInstance) DeepCopyInto 

func (in *RocketMQInstance) DeepCopyInto(out *RocketMQInstance)

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

func (*RocketMQInstance) DeepCopyObject 

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

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

func (*RocketMQInstance) GetCondition 

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

GetCondition of this RocketMQInstance.

func (*RocketMQInstance) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this RocketMQInstance

func (*RocketMQInstance) GetDeletionPolicy 

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

GetDeletionPolicy of this RocketMQInstance.

func (*RocketMQInstance) GetID 

func (tr *RocketMQInstance) GetID() string

GetID returns ID of underlying Terraform resource of this RocketMQInstance

func (*RocketMQInstance) GetObservation 

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

GetObservation of this RocketMQInstance

func (*RocketMQInstance) GetParameters 

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

GetParameters of this RocketMQInstance

func (*RocketMQInstance) GetProviderConfigReference 

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

GetProviderConfigReference of this RocketMQInstance.

func (*RocketMQInstance) GetProviderReference 

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

GetProviderReference of this RocketMQInstance. Deprecated: Use GetProviderConfigReference.

func (*RocketMQInstance) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this RocketMQInstance.

func (*RocketMQInstance) GetTerraformResourceType 

func (mg *RocketMQInstance) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this RocketMQInstance

func (*RocketMQInstance) GetTerraformSchemaVersion 

func (tr *RocketMQInstance) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*RocketMQInstance) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this RocketMQInstance.

func (*RocketMQInstance) LateInitialize 

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

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

func (*RocketMQInstance) ResolveReferences 

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

ResolveReferences of this RocketMQInstance.

func (*RocketMQInstance) SetConditions 

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

SetConditions of this RocketMQInstance.

func (*RocketMQInstance) SetDeletionPolicy 

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

SetDeletionPolicy of this RocketMQInstance.

func (*RocketMQInstance) SetObservation 

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

SetObservation for this RocketMQInstance

func (*RocketMQInstance) SetParameters 

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

SetParameters for this RocketMQInstance

func (*RocketMQInstance) SetProviderConfigReference 

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

SetProviderConfigReference of this RocketMQInstance.

func (*RocketMQInstance) SetProviderReference 

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

SetProviderReference of this RocketMQInstance. Deprecated: Use SetProviderConfigReference.

func (*RocketMQInstance) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this RocketMQInstance.

func (*RocketMQInstance) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this RocketMQInstance.

type RocketMQInstanceList 

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

RocketMQInstanceList contains a list of RocketMQInstances

func (*RocketMQInstanceList) DeepCopy 

func (in *RocketMQInstanceList) DeepCopy() *RocketMQInstanceList

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

func (*RocketMQInstanceList) DeepCopyInto 

func (in *RocketMQInstanceList) DeepCopyInto(out *RocketMQInstanceList)

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

func (*RocketMQInstanceList) DeepCopyObject 

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

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

func (*RocketMQInstanceList) GetItems 

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

GetItems of this RocketMQInstanceList.

type RocketMQInstanceObservation 

type RocketMQInstanceObservation struct {

	// Indicates the service data address.
	BrokerAddress *string `json:"brokerAddress,omitempty" tf:"broker_address,omitempty"`

	// +kubebuilder:validation:Optional
	CrossVPCAccesses []CrossVPCAccessesObservation `json:"crossVpcAccesses,omitempty" tf:"cross_vpc_accesses,omitempty"`

	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// Indicates the time at which the maintenance window starts. The format is HH:mm:ss.
	MaintainBegin *string `json:"maintainBegin,omitempty" tf:"maintain_begin,omitempty"`

	// Indicates the time at which the maintenance window ends. The format is HH:mm:ss.
	MaintainEnd *string `json:"maintainEnd,omitempty" tf:"maintain_end,omitempty"`

	// Indicates the metadata address.
	NamesrvAddress *string `json:"namesrvAddress,omitempty" tf:"namesrv_address,omitempty"`

	// Indicates whether billing based on new specifications is enabled.
	NewSpecBillingEnable *bool `json:"newSpecBillingEnable,omitempty" tf:"new_spec_billing_enable,omitempty"`

	// Indicates the node quantity.
	NodeNum *float64 `json:"nodeNum,omitempty" tf:"node_num,omitempty"`

	// Indicates the public network service data address.
	PublicBrokerAddress *string `json:"publicBrokerAddress,omitempty" tf:"public_broker_address,omitempty"`

	// Indicates the public network metadata address.
	PublicNamesrvAddress *string `json:"publicNamesrvAddress,omitempty" tf:"public_namesrv_address,omitempty"`

	// Indicates the public IP address.
	PublicipAddress *string `json:"publicipAddress,omitempty" tf:"publicip_address,omitempty"`

	// Indicates the resource specifications.
	ResourceSpecCode *string `json:"resourceSpecCode,omitempty" tf:"resource_spec_code,omitempty"`

	// Indicates the instance specification. For a cluster DMS RocketMQ instance, VM specifications
	// and the number of nodes are returned.
	Specification *string `json:"specification,omitempty" tf:"specification,omitempty"`

	// Indicates the status of the DMS RocketMQ instance.
	Status *string `json:"status,omitempty" tf:"status,omitempty"`

	// Indicates the DMS RocketMQ instance type. Value: cluster.
	Type *string `json:"type,omitempty" tf:"type,omitempty"`

	// Indicates the used message storage space. Unit: GB.
	UsedStorageSpace *float64 `json:"usedStorageSpace,omitempty" tf:"used_storage_space,omitempty"`
}

func (*RocketMQInstanceObservation) DeepCopy 

func (in *RocketMQInstanceObservation) DeepCopy() *RocketMQInstanceObservation

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

func (*RocketMQInstanceObservation) DeepCopyInto 

func (in *RocketMQInstanceObservation) DeepCopyInto(out *RocketMQInstanceObservation)

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

type RocketMQInstanceParameters 

type RocketMQInstanceParameters struct {

	// Specifies the list of availability zone names
	// +kubebuilder:validation:Required
	AvailabilityZones []*string `json:"availabilityZones" tf:"availability_zones,omitempty"`

	// Specifies the broker numbers.
	// +kubebuilder:validation:Optional
	BrokerNum *float64 `json:"brokerNum,omitempty" tf:"broker_num,omitempty"`

	// +kubebuilder:validation:Optional
	CrossVPCAccesses []CrossVPCAccessesParameters `json:"crossVpcAccesses,omitempty" tf:"cross_vpc_accesses,omitempty"`

	// Specifies the description of the DMS RocketMQ instance.
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// Specifies whether access control is enabled.
	// +kubebuilder:validation:Optional
	EnableACL *bool `json:"enableAcl,omitempty" tf:"enable_acl,omitempty"`

	// Specifies whether to enable public access.
	// +kubebuilder:validation:Optional
	EnablePublicip *bool `json:"enablePublicip,omitempty" tf:"enable_publicip,omitempty"`

	// Specifies the version of the RocketMQ engine.
	// +kubebuilder:validation:Required
	EngineVersion *string `json:"engineVersion" tf:"engine_version,omitempty"`

	// Specifies the enterprise project id of the instance.
	// +kubebuilder:validation:Optional
	EnterpriseProjectID *string `json:"enterpriseProjectId,omitempty" tf:"enterprise_project_id,omitempty"`

	// Specifies a product ID
	// +kubebuilder:validation:Required
	FlavorID *string `json:"flavorId" tf:"flavor_id,omitempty"`

	// Specifies whether to support IPv6
	// +kubebuilder:validation:Optional
	IPv6Enable *bool `json:"ipv6Enable,omitempty" tf:"ipv6_enable,omitempty"`

	// Specifies the name of the DMS RocketMQ instance
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// Specifies the ID of the EIP bound to the instance.
	// +crossplane:generate:reference:type=github.com/FlexibleEngineCloud/provider-flexibleengine/apis/eip/v1beta1.EIP
	// +kubebuilder:validation:Optional
	PublicipID *string `json:"publicipId,omitempty" tf:"publicip_id,omitempty"`

	// Reference to a EIP in eip to populate publicipId.
	// +kubebuilder:validation:Optional
	PublicipIDRef *v1.Reference `json:"publicipIdRef,omitempty" tf:"-"`

	// Selector for a EIP in eip to populate publicipId.
	// +kubebuilder:validation:Optional
	PublicipIDSelector *v1.Selector `json:"publicipIdSelector,omitempty" tf:"-"`

	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// Specifies whether access control is enabled.
	// +kubebuilder:validation:Optional
	RetentionPolicy *bool `json:"retentionPolicy,omitempty" tf:"retention_policy,omitempty"`

	// Specifies whether the RocketMQ SASL_SSL is enabled.
	// +kubebuilder:validation:Optional
	SSLEnable *bool `json:"sslEnable,omitempty" tf:"ssl_enable,omitempty"`

	// Specifies the ID of a security group
	// +crossplane:generate:reference:type=github.com/FlexibleEngineCloud/provider-flexibleengine/apis/vpc/v1beta1.SecurityGroup
	// +crossplane:generate:reference:refFieldName=SecurityGroupIDRef
	// +crossplane:generate:reference:selectorFieldName=SecurityGroupIDSelector
	// +kubebuilder:validation:Optional
	SecurityGroupID *string `json:"securityGroupId,omitempty" tf:"security_group_id,omitempty"`

	// Reference to a SecurityGroup in vpc to populate securityGroupId.
	// +kubebuilder:validation:Optional
	SecurityGroupIDRef *v1.Reference `json:"securityGroupIdRef,omitempty" tf:"-"`

	// Selector for a SecurityGroup in vpc to populate securityGroupId.
	// +kubebuilder:validation:Optional
	SecurityGroupIDSelector *v1.Selector `json:"securityGroupIdSelector,omitempty" tf:"-"`

	// Specifies the message storage capacity, Unit: GB.
	// +kubebuilder:validation:Required
	StorageSpace *float64 `json:"storageSpace" tf:"storage_space,omitempty"`

	// Specifies the storage I/O specification
	// +kubebuilder:validation:Required
	StorageSpecCode *string `json:"storageSpecCode" tf:"storage_spec_code,omitempty"`

	// Specifies the ID of a subnet
	// +crossplane:generate:reference:type=github.com/FlexibleEngineCloud/provider-flexibleengine/apis/vpc/v1beta1.VPCSubnet
	// +crossplane:generate:reference:extractor=github.com/FlexibleEngineCloud/provider-flexibleengine/pkg/tools.ExtractorParamPathfunc(true, "id")
	// +crossplane:generate:reference:refFieldName=SubnetIDRef
	// +crossplane:generate:reference:selectorFieldName=SubnetIDSelector
	// +kubebuilder:validation:Optional
	SubnetID *string `json:"subnetId,omitempty" tf:"subnet_id,omitempty"`

	// Reference to a VPCSubnet in vpc to populate subnetId.
	// +kubebuilder:validation:Optional
	SubnetIDRef *v1.Reference `json:"subnetIdRef,omitempty" tf:"-"`

	// Selector for a VPCSubnet in vpc to populate subnetId.
	// +kubebuilder:validation:Optional
	SubnetIDSelector *v1.Selector `json:"subnetIdSelector,omitempty" tf:"-"`

	// Specifies the ID of a VPC
	// +crossplane:generate:reference:type=github.com/FlexibleEngineCloud/provider-flexibleengine/apis/vpc/v1beta1.VPC
	// +kubebuilder:validation:Optional
	VPCID *string `json:"vpcId,omitempty" tf:"vpc_id,omitempty"`

	// Reference to a VPC in vpc to populate vpcId.
	// +kubebuilder:validation:Optional
	VPCIDRef *v1.Reference `json:"vpcIdRef,omitempty" tf:"-"`

	// Selector for a VPC in vpc to populate vpcId.
	// +kubebuilder:validation:Optional
	VPCIDSelector *v1.Selector `json:"vpcIdSelector,omitempty" tf:"-"`
}

func (*RocketMQInstanceParameters) DeepCopy 

func (in *RocketMQInstanceParameters) DeepCopy() *RocketMQInstanceParameters

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

func (*RocketMQInstanceParameters) DeepCopyInto 

func (in *RocketMQInstanceParameters) DeepCopyInto(out *RocketMQInstanceParameters)

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

type RocketMQInstanceSpec 

type RocketMQInstanceSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     RocketMQInstanceParameters `json:"forProvider"`
}

RocketMQInstanceSpec defines the desired state of RocketMQInstance

func (*RocketMQInstanceSpec) DeepCopy 

func (in *RocketMQInstanceSpec) DeepCopy() *RocketMQInstanceSpec

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

func (*RocketMQInstanceSpec) DeepCopyInto 

func (in *RocketMQInstanceSpec) DeepCopyInto(out *RocketMQInstanceSpec)

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

type RocketMQInstanceStatus 

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

RocketMQInstanceStatus defines the observed state of RocketMQInstance.

func (*RocketMQInstanceStatus) DeepCopy 

func (in *RocketMQInstanceStatus) DeepCopy() *RocketMQInstanceStatus

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

func (*RocketMQInstanceStatus) DeepCopyInto 

func (in *RocketMQInstanceStatus) DeepCopyInto(out *RocketMQInstanceStatus)

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

type RocketMQTopic 

type RocketMQTopic struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              RocketMQTopicSpec   `json:"spec"`
	Status            RocketMQTopicStatus `json:"status,omitempty"`
}

RocketMQTopic is the Schema for the RocketMQTopics API. +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,flexibleengine}

func (*RocketMQTopic) DeepCopy 

func (in *RocketMQTopic) DeepCopy() *RocketMQTopic

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

func (*RocketMQTopic) DeepCopyInto 

func (in *RocketMQTopic) DeepCopyInto(out *RocketMQTopic)

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

func (*RocketMQTopic) DeepCopyObject 

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

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

func (*RocketMQTopic) GetCondition 

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

GetCondition of this RocketMQTopic.

func (*RocketMQTopic) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this RocketMQTopic

func (*RocketMQTopic) GetDeletionPolicy 

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

GetDeletionPolicy of this RocketMQTopic.

func (*RocketMQTopic) GetID 

func (tr *RocketMQTopic) GetID() string

GetID returns ID of underlying Terraform resource of this RocketMQTopic

func (*RocketMQTopic) GetObservation 

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

GetObservation of this RocketMQTopic

func (*RocketMQTopic) GetParameters 

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

GetParameters of this RocketMQTopic

func (*RocketMQTopic) GetProviderConfigReference 

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

GetProviderConfigReference of this RocketMQTopic.

func (*RocketMQTopic) GetProviderReference 

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

GetProviderReference of this RocketMQTopic. Deprecated: Use GetProviderConfigReference.

func (*RocketMQTopic) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this RocketMQTopic.

func (*RocketMQTopic) GetTerraformResourceType 

func (mg *RocketMQTopic) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this RocketMQTopic

func (*RocketMQTopic) GetTerraformSchemaVersion 

func (tr *RocketMQTopic) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*RocketMQTopic) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this RocketMQTopic.

func (*RocketMQTopic) LateInitialize 

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

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

func (*RocketMQTopic) ResolveReferences 

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

ResolveReferences of this RocketMQTopic.

func (*RocketMQTopic) SetConditions 

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

SetConditions of this RocketMQTopic.

func (*RocketMQTopic) SetDeletionPolicy 

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

SetDeletionPolicy of this RocketMQTopic.

func (*RocketMQTopic) SetObservation 

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

SetObservation for this RocketMQTopic

func (*RocketMQTopic) SetParameters 

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

SetParameters for this RocketMQTopic

func (*RocketMQTopic) SetProviderConfigReference 

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

SetProviderConfigReference of this RocketMQTopic.

func (*RocketMQTopic) SetProviderReference 

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

SetProviderReference of this RocketMQTopic. Deprecated: Use SetProviderConfigReference.

func (*RocketMQTopic) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this RocketMQTopic.

func (*RocketMQTopic) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this RocketMQTopic.

type RocketMQTopicList 

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

RocketMQTopicList contains a list of RocketMQTopics

func (*RocketMQTopicList) DeepCopy 

func (in *RocketMQTopicList) DeepCopy() *RocketMQTopicList

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

func (*RocketMQTopicList) DeepCopyInto 

func (in *RocketMQTopicList) DeepCopyInto(out *RocketMQTopicList)

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

func (*RocketMQTopicList) DeepCopyObject 

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

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

func (*RocketMQTopicList) GetItems 

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

GetItems of this RocketMQTopicList.

type RocketMQTopicObservation 

type RocketMQTopicObservation struct {

	// Specifies the list of associated brokers of the topic.
	// Specifies the list of associated brokers of the topic.
	// +kubebuilder:validation:Optional
	Brokers []BrokersObservation `json:"brokers,omitempty" tf:"brokers,omitempty"`

	// The resource ID.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`
}

func (*RocketMQTopicObservation) DeepCopy 

func (in *RocketMQTopicObservation) DeepCopy() *RocketMQTopicObservation

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

func (*RocketMQTopicObservation) DeepCopyInto 

func (in *RocketMQTopicObservation) DeepCopyInto(out *RocketMQTopicObservation)

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

type RocketMQTopicParameters 

type RocketMQTopicParameters struct {

	// Specifies the list of associated brokers of the topic.
	// Specifies the list of associated brokers of the topic.
	// +kubebuilder:validation:Optional
	Brokers []BrokersParameters `json:"brokers,omitempty" tf:"brokers,omitempty"`

	// Specifies the ID of the rocketMQ instance.
	// +crossplane:generate:reference:type=github.com/FlexibleEngineCloud/provider-flexibleengine/apis/dms/v1beta1.RocketMQInstance
	// +kubebuilder:validation:Optional
	InstanceID *string `json:"instanceId,omitempty" tf:"instance_id,omitempty"`

	// Reference to a RocketMQInstance in dms to populate instanceId.
	// +kubebuilder:validation:Optional
	InstanceIDRef *v1.Reference `json:"instanceIdRef,omitempty" tf:"-"`

	// Selector for a RocketMQInstance in dms to populate instanceId.
	// +kubebuilder:validation:Optional
	InstanceIDSelector *v1.Selector `json:"instanceIdSelector,omitempty" tf:"-"`

	// Specifies the name of the topic.
	// Specifies the name of the topic.
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// Specifies the permissions of the topic.
	// Value options: all, sub, pub. Default to all.
	// Specifies the permissions of the topic.
	// +kubebuilder:validation:Optional
	Permission *string `json:"permission,omitempty" tf:"permission,omitempty"`

	// Specifies the number of queues. Default to 3.
	// Specifies the number of queues.
	// +kubebuilder:validation:Optional
	QueueNum *float64 `json:"queueNum,omitempty" tf:"queue_num,omitempty"`

	// Specifies the region in which to create the resource.
	// If omitted, the provider-level region will be used. Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// Specifies the total number of read queues.
	// Specifies the total number of read queues.
	// +kubebuilder:validation:Optional
	TotalReadQueueNum *float64 `json:"totalReadQueueNum,omitempty" tf:"total_read_queue_num,omitempty"`

	// Specifies the total number of write queues.
	// Specifies the total number of write queues.
	// +kubebuilder:validation:Optional
	TotalWriteQueueNum *float64 `json:"totalWriteQueueNum,omitempty" tf:"total_write_queue_num,omitempty"`
}

func (*RocketMQTopicParameters) DeepCopy 

func (in *RocketMQTopicParameters) DeepCopy() *RocketMQTopicParameters

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

func (*RocketMQTopicParameters) DeepCopyInto 

func (in *RocketMQTopicParameters) DeepCopyInto(out *RocketMQTopicParameters)

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

type RocketMQTopicSpec 

type RocketMQTopicSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     RocketMQTopicParameters `json:"forProvider"`
}

RocketMQTopicSpec defines the desired state of RocketMQTopic

func (*RocketMQTopicSpec) DeepCopy 

func (in *RocketMQTopicSpec) DeepCopy() *RocketMQTopicSpec

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

func (*RocketMQTopicSpec) DeepCopyInto 

func (in *RocketMQTopicSpec) DeepCopyInto(out *RocketMQTopicSpec)

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

type RocketMQTopicStatus 

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

RocketMQTopicStatus defines the observed state of RocketMQTopic.

func (*RocketMQTopicStatus) DeepCopy 

func (in *RocketMQTopicStatus) DeepCopy() *RocketMQTopicStatus

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

func (*RocketMQTopicStatus) DeepCopyInto 

func (in *RocketMQTopicStatus) DeepCopyInto(out *RocketMQTopicStatus)

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

type RocketMQUser 

type RocketMQUser struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              RocketMQUserSpec   `json:"spec"`
	Status            RocketMQUserStatus `json:"status,omitempty"`
}

RocketMQUser is the Schema for the RocketMQUsers API. +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,flexibleengine}

func (*RocketMQUser) DeepCopy 

func (in *RocketMQUser) DeepCopy() *RocketMQUser

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

func (*RocketMQUser) DeepCopyInto 

func (in *RocketMQUser) DeepCopyInto(out *RocketMQUser)

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

func (*RocketMQUser) DeepCopyObject 

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

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

func (*RocketMQUser) GetCondition 

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

GetCondition of this RocketMQUser.

func (*RocketMQUser) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this RocketMQUser

func (*RocketMQUser) GetDeletionPolicy 

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

GetDeletionPolicy of this RocketMQUser.

func (*RocketMQUser) GetID 

func (tr *RocketMQUser) GetID() string

GetID returns ID of underlying Terraform resource of this RocketMQUser

func (*RocketMQUser) GetObservation 

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

GetObservation of this RocketMQUser

func (*RocketMQUser) GetParameters 

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

GetParameters of this RocketMQUser

func (*RocketMQUser) GetProviderConfigReference 

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

GetProviderConfigReference of this RocketMQUser.

func (*RocketMQUser) GetProviderReference 

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

GetProviderReference of this RocketMQUser. Deprecated: Use GetProviderConfigReference.

func (*RocketMQUser) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this RocketMQUser.

func (*RocketMQUser) GetTerraformResourceType 

func (mg *RocketMQUser) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this RocketMQUser

func (*RocketMQUser) GetTerraformSchemaVersion 

func (tr *RocketMQUser) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*RocketMQUser) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this RocketMQUser.

func (*RocketMQUser) LateInitialize 

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

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

func (*RocketMQUser) ResolveReferences 

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

ResolveReferences of this RocketMQUser.

func (*RocketMQUser) SetConditions 

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

SetConditions of this RocketMQUser.

func (*RocketMQUser) SetDeletionPolicy 

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

SetDeletionPolicy of this RocketMQUser.

func (*RocketMQUser) SetObservation 

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

SetObservation for this RocketMQUser

func (*RocketMQUser) SetParameters 

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

SetParameters for this RocketMQUser

func (*RocketMQUser) SetProviderConfigReference 

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

SetProviderConfigReference of this RocketMQUser.

func (*RocketMQUser) SetProviderReference 

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

SetProviderReference of this RocketMQUser. Deprecated: Use SetProviderConfigReference.

func (*RocketMQUser) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this RocketMQUser.

func (*RocketMQUser) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this RocketMQUser.

type RocketMQUserList 

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

RocketMQUserList contains a list of RocketMQUsers

func (*RocketMQUserList) DeepCopy 

func (in *RocketMQUserList) DeepCopy() *RocketMQUserList

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

func (*RocketMQUserList) DeepCopyInto 

func (in *RocketMQUserList) DeepCopyInto(out *RocketMQUserList)

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

func (*RocketMQUserList) DeepCopyObject 

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

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

func (*RocketMQUserList) GetItems 

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

GetItems of this RocketMQUserList.

type RocketMQUserObservation 

type RocketMQUserObservation struct {

	// The resource ID.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`
}

func (*RocketMQUserObservation) DeepCopy 

func (in *RocketMQUserObservation) DeepCopy() *RocketMQUserObservation

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

func (*RocketMQUserObservation) DeepCopyInto 

func (in *RocketMQUserObservation) DeepCopyInto(out *RocketMQUserObservation)

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

type RocketMQUserParameters 

type RocketMQUserParameters struct {

	// Specifies the access key of the user.
	// Changing this parameter will create a new resource.
	// Specifies the access key of the user.
	// +kubebuilder:validation:Required
	AccessKey *string `json:"accessKey" tf:"access_key,omitempty"`

	// Specifies whether the user is an administrator.
	// Specifies whether the user is an administrator.
	// +kubebuilder:validation:Optional
	Admin *bool `json:"admin,omitempty" tf:"admin,omitempty"`

	// Specifies the default consumer group permissions.
	// Value options: PUB|SUB, PUB, SUB, DENY.
	// Specifies the default consumer group permissions.
	// Value options: **PUB|SUB**, **PUB**, **SUB**, **DENY**.
	// +kubebuilder:validation:Optional
	DefaultGroupPerm *string `json:"defaultGroupPerm,omitempty" tf:"default_group_perm,omitempty"`

	// Specifies the default topic permissions.
	// Value options: PUB|SUB, PUB, SUB, DENY.
	// Specifies the default topic permissions.
	// Value options: **PUB|SUB**, **PUB**, **SUB**, **DENY**.
	// +kubebuilder:validation:Optional
	DefaultTopicPerm *string `json:"defaultTopicPerm,omitempty" tf:"default_topic_perm,omitempty"`

	// Specifies the special consumer group permissions.
	// The permission structure is documented below.
	// Specifies the special consumer group permissions.
	// +kubebuilder:validation:Optional
	GroupPerms []GroupPermsParameters `json:"groupPerms,omitempty" tf:"group_perms,omitempty"`

	// Specifies the ID of the rocketMQ instance.
	// Changing this parameter will create a new resource.
	// Specifies the ID of the rocketMQ instance.
	// +crossplane:generate:reference:type=github.com/FlexibleEngineCloud/provider-flexibleengine/apis/dms/v1beta1.RocketMQInstance
	// +kubebuilder:validation:Optional
	InstanceID *string `json:"instanceId,omitempty" tf:"instance_id,omitempty"`

	// Reference to a RocketMQInstance in dms to populate instanceId.
	// +kubebuilder:validation:Optional
	InstanceIDRef *v1.Reference `json:"instanceIdRef,omitempty" tf:"-"`

	// Selector for a RocketMQInstance in dms to populate instanceId.
	// +kubebuilder:validation:Optional
	InstanceIDSelector *v1.Selector `json:"instanceIdSelector,omitempty" tf:"-"`

	// Specifies the region in which to create the resource.
	// If omitted, the provider-level region will be used. Changing this parameter will create a new resource.
	// +kubebuilder:validation:Optional
	Region *string `json:"region,omitempty" tf:"region,omitempty"`

	// Specifies the secret key of the user.
	// Changing this parameter will create a new resource.
	// Specifies the secret key of the user.
	// +kubebuilder:validation:Required
	SecretKey *string `json:"secretKey" tf:"secret_key,omitempty"`

	// Specifies the special topic permissions.
	// The permission structure is documented below.
	// Specifies the special topic permissions.
	// +kubebuilder:validation:Optional
	TopicPerms []TopicPermsParameters `json:"topicPerms,omitempty" tf:"topic_perms,omitempty"`

	// Specifies the IP address whitelist.
	// Specifies the IP address whitelist.
	// +kubebuilder:validation:Optional
	WhiteRemoteAddress *string `json:"whiteRemoteAddress,omitempty" tf:"white_remote_address,omitempty"`
}

func (*RocketMQUserParameters) DeepCopy 

func (in *RocketMQUserParameters) DeepCopy() *RocketMQUserParameters

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

func (*RocketMQUserParameters) DeepCopyInto 

func (in *RocketMQUserParameters) DeepCopyInto(out *RocketMQUserParameters)

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

type RocketMQUserSpec 

type RocketMQUserSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     RocketMQUserParameters `json:"forProvider"`
}

RocketMQUserSpec defines the desired state of RocketMQUser

func (*RocketMQUserSpec) DeepCopy 

func (in *RocketMQUserSpec) DeepCopy() *RocketMQUserSpec

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

func (*RocketMQUserSpec) DeepCopyInto 

func (in *RocketMQUserSpec) DeepCopyInto(out *RocketMQUserSpec)

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

type RocketMQUserStatus 

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

RocketMQUserStatus defines the observed state of RocketMQUser.

func (*RocketMQUserStatus) DeepCopy 

func (in *RocketMQUserStatus) DeepCopy() *RocketMQUserStatus

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

func (*RocketMQUserStatus) DeepCopyInto 

func (in *RocketMQUserStatus) DeepCopyInto(out *RocketMQUserStatus)

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

type TopicPermsObservation 

type TopicPermsObservation struct {
}

func (*TopicPermsObservation) DeepCopy 

func (in *TopicPermsObservation) DeepCopy() *TopicPermsObservation

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

func (*TopicPermsObservation) DeepCopyInto 

func (in *TopicPermsObservation) DeepCopyInto(out *TopicPermsObservation)

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

type TopicPermsParameters 

type TopicPermsParameters struct {

	// Indicates the name of a topic or consumer group.
	// Indicates the name of a topic or consumer group.
	// +crossplane:generate:reference:type=RocketMQTopic
	// +kubebuilder:validation:Optional
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// Reference to a RocketMQTopic to populate name.
	// +kubebuilder:validation:Optional
	NameRef *v1.Reference `json:"nameRef,omitempty" tf:"-"`

	// Selector for a RocketMQTopic to populate name.
	// +kubebuilder:validation:Optional
	NameSelector *v1.Selector `json:"nameSelector,omitempty" tf:"-"`

	// Indicates the permissions of the topic or consumer group.
	// Value options: PUB|SUB, PUB, SUB, DENY.
	// Indicates the permissions of the topic or consumer group.
	// Value options: **PUB|SUB**, **PUB**, **SUB**, **DENY**.
	// +kubebuilder:validation:Optional
	Perm *string `json:"perm,omitempty" tf:"perm,omitempty"`
}

func (*TopicPermsParameters) DeepCopy 

func (in *TopicPermsParameters) DeepCopy() *TopicPermsParameters

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

func (*TopicPermsParameters) DeepCopyInto 

func (in *TopicPermsParameters) DeepCopyInto(out *TopicPermsParameters)

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.