v1alpha1

package
v0.8.2 Latest Latest
Warning

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

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

Documentation

Overview

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

Index

Constants

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

Package type metadata.

Variables

View Source 
var (
	Acl_Kind             = "Acl"
	Acl_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Acl_Kind}.String()
	Acl_KindAPIVersion   = Acl_Kind + "." + CRDGroupVersion.String()
	Acl_GroupVersionKind = CRDGroupVersion.WithKind(Acl_Kind)
)

Repository type metadata.

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 (
	Instance_Kind             = "Instance"
	Instance_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Instance_Kind}.String()
	Instance_KindAPIVersion   = Instance_Kind + "." + CRDGroupVersion.String()
	Instance_GroupVersionKind = CRDGroupVersion.WithKind(Instance_Kind)
)

Repository type metadata.

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

Repository type metadata.

View Source 
var (
	User_Kind             = "User"
	User_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: User_Kind}.String()
	User_KindAPIVersion   = User_Kind + "." + CRDGroupVersion.String()
	User_GroupVersionKind = CRDGroupVersion.WithKind(User_Kind)
)

Repository type metadata.

Functions

This section is empty.

Types

type Acl 

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

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

func (*Acl) DeepCopy 

func (in *Acl) DeepCopy() *Acl

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

func (*Acl) DeepCopyInto 

func (in *Acl) DeepCopyInto(out *Acl)

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

func (*Acl) DeepCopyObject 

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

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

func (*Acl) GetCondition 

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

GetCondition of this Acl.

func (*Acl) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this Acl

func (*Acl) GetDeletionPolicy 

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

GetDeletionPolicy of this Acl.

func (*Acl) GetID 

func (tr *Acl) GetID() string

GetID returns ID of underlying Terraform resource of this Acl

func (*Acl) GetInitParameters added in v0.8.0 

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

GetInitParameters of this Acl

func (*Acl) GetManagementPolicies added in v0.8.0 

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

GetManagementPolicies of this Acl.

func (*Acl) GetMergedParameters added in v0.8.1 

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

GetInitParameters of this Acl

func (*Acl) GetObservation 

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

GetObservation of this Acl

func (*Acl) GetParameters 

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

GetParameters of this Acl

func (*Acl) GetProviderConfigReference 

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

GetProviderConfigReference of this Acl.

func (*Acl) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this Acl.

func (*Acl) GetTerraformResourceType 

func (mg *Acl) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Acl

func (*Acl) GetTerraformSchemaVersion 

func (tr *Acl) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Acl) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this Acl.

func (*Acl) Hub added in v0.8.1 

func (tr *Acl) Hub()

Hub marks this type as a conversion hub.

func (*Acl) LateInitialize 

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

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

func (*Acl) ResolveReferences 

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

ResolveReferences of this Acl.

func (*Acl) SetConditions 

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

SetConditions of this Acl.

func (*Acl) SetDeletionPolicy 

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

SetDeletionPolicy of this Acl.

func (*Acl) SetManagementPolicies added in v0.8.0 

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

SetManagementPolicies of this Acl.

func (*Acl) SetObservation 

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

SetObservation for this Acl

func (*Acl) SetParameters 

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

SetParameters for this Acl

func (*Acl) SetProviderConfigReference 

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

SetProviderConfigReference of this Acl.

func (*Acl) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this Acl.

func (*Acl) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this Acl.

type AclInitParameters added in v0.8.0 

type AclInitParameters struct {

	// The default is *, which means that any host can access it. Support filling in IP or network segment, and support ;separation.
	// The default is *, which means that any host can access it. Support filling in IP or network segment, and support `;`separation.
	Host *string `json:"host,omitempty" tf:"host,omitempty"`

	// ID of the ckafka instance.
	// ID of the ckafka instance.
	// +crossplane:generate:reference:type=Instance
	InstanceID *string `json:"instanceId,omitempty" tf:"instance_id,omitempty"`

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

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

	// ACL operation mode. Valid values: UNKNOWN, ANY, ALL, READ, WRITE, CREATE, DELETE, ALTER, DESCRIBE, CLUSTER_ACTION, DESCRIBE_CONFIGS and ALTER_CONFIGS.
	// ACL operation mode. Valid values: `UNKNOWN`, `ANY`, `ALL`, `READ`, `WRITE`, `CREATE`, `DELETE`, `ALTER`, `DESCRIBE`, `CLUSTER_ACTION`, `DESCRIBE_CONFIGS` and `ALTER_CONFIGS`.
	OperationType *string `json:"operationType,omitempty" tf:"operation_type,omitempty"`

	// ACL permission type. Valid values: UNKNOWN, ANY, DENY, ALLOW. and ALLOW by default. Currently, CKafka supports ALLOW (equivalent to allow list), and other fields will be used for future ACLs compatible with open-source Kafka.
	// ACL permission type. Valid values: `UNKNOWN`, `ANY`, `DENY`, `ALLOW`. and `ALLOW` by default. Currently, CKafka supports `ALLOW` (equivalent to allow list), and other fields will be used for future ACLs compatible with open-source Kafka.
	PermissionType *string `json:"permissionType,omitempty" tf:"permission_type,omitempty"`

	// User list. The default value is *, which means that any user can access. The current user can only be one included in the user list. For example: root meaning user root can access.
	// User list. The default value is `*`, which means that any user can access. The current user can only be one included in the user list. For example: `root` meaning user root can access.
	Principal *string `json:"principal,omitempty" tf:"principal,omitempty"`

	// ACL resource name, which is related to resource_type. For example, if resource_type is TOPIC, this field indicates the topic name; if resource_type is GROUP, this field indicates the group name.
	// ACL resource name, which is related to `resource_type`. For example, if `resource_type` is `TOPIC`, this field indicates the topic name; if `resource_type` is `GROUP`, this field indicates the group name.
	ResourceName *string `json:"resourceName,omitempty" tf:"resource_name,omitempty"`

	// ACL resource type. Valid values are UNKNOWN, ANY, TOPIC, GROUP, CLUSTER, TRANSACTIONAL_ID. and TOPIC by default. Currently, only TOPIC is available, and other fields will be used for future ACLs compatible with open-source Kafka.
	// ACL resource type. Valid values are `UNKNOWN`, `ANY`, `TOPIC`, `GROUP`, `CLUSTER`, `TRANSACTIONAL_ID`. and `TOPIC` by default. Currently, only `TOPIC` is available, and other fields will be used for future ACLs compatible with open-source Kafka.
	ResourceType *string `json:"resourceType,omitempty" tf:"resource_type,omitempty"`
}

func (*AclInitParameters) DeepCopy added in v0.8.0 

func (in *AclInitParameters) DeepCopy() *AclInitParameters

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

func (*AclInitParameters) DeepCopyInto added in v0.8.0 

func (in *AclInitParameters) DeepCopyInto(out *AclInitParameters)

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

type AclList 

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

AclList contains a list of Acls

func (*AclList) DeepCopy 

func (in *AclList) DeepCopy() *AclList

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

func (*AclList) DeepCopyInto 

func (in *AclList) DeepCopyInto(out *AclList)

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

func (*AclList) DeepCopyObject 

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

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

func (*AclList) GetItems 

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

GetItems of this AclList.

type AclObservation 

type AclObservation struct {

	// The default is *, which means that any host can access it. Support filling in IP or network segment, and support ;separation.
	// The default is *, which means that any host can access it. Support filling in IP or network segment, and support `;`separation.
	Host *string `json:"host,omitempty" tf:"host,omitempty"`

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

	// ID of the ckafka instance.
	// ID of the ckafka instance.
	InstanceID *string `json:"instanceId,omitempty" tf:"instance_id,omitempty"`

	// ACL operation mode. Valid values: UNKNOWN, ANY, ALL, READ, WRITE, CREATE, DELETE, ALTER, DESCRIBE, CLUSTER_ACTION, DESCRIBE_CONFIGS and ALTER_CONFIGS.
	// ACL operation mode. Valid values: `UNKNOWN`, `ANY`, `ALL`, `READ`, `WRITE`, `CREATE`, `DELETE`, `ALTER`, `DESCRIBE`, `CLUSTER_ACTION`, `DESCRIBE_CONFIGS` and `ALTER_CONFIGS`.
	OperationType *string `json:"operationType,omitempty" tf:"operation_type,omitempty"`

	// ACL permission type. Valid values: UNKNOWN, ANY, DENY, ALLOW. and ALLOW by default. Currently, CKafka supports ALLOW (equivalent to allow list), and other fields will be used for future ACLs compatible with open-source Kafka.
	// ACL permission type. Valid values: `UNKNOWN`, `ANY`, `DENY`, `ALLOW`. and `ALLOW` by default. Currently, CKafka supports `ALLOW` (equivalent to allow list), and other fields will be used for future ACLs compatible with open-source Kafka.
	PermissionType *string `json:"permissionType,omitempty" tf:"permission_type,omitempty"`

	// User list. The default value is *, which means that any user can access. The current user can only be one included in the user list. For example: root meaning user root can access.
	// User list. The default value is `*`, which means that any user can access. The current user can only be one included in the user list. For example: `root` meaning user root can access.
	Principal *string `json:"principal,omitempty" tf:"principal,omitempty"`

	// ACL resource name, which is related to resource_type. For example, if resource_type is TOPIC, this field indicates the topic name; if resource_type is GROUP, this field indicates the group name.
	// ACL resource name, which is related to `resource_type`. For example, if `resource_type` is `TOPIC`, this field indicates the topic name; if `resource_type` is `GROUP`, this field indicates the group name.
	ResourceName *string `json:"resourceName,omitempty" tf:"resource_name,omitempty"`

	// ACL resource type. Valid values are UNKNOWN, ANY, TOPIC, GROUP, CLUSTER, TRANSACTIONAL_ID. and TOPIC by default. Currently, only TOPIC is available, and other fields will be used for future ACLs compatible with open-source Kafka.
	// ACL resource type. Valid values are `UNKNOWN`, `ANY`, `TOPIC`, `GROUP`, `CLUSTER`, `TRANSACTIONAL_ID`. and `TOPIC` by default. Currently, only `TOPIC` is available, and other fields will be used for future ACLs compatible with open-source Kafka.
	ResourceType *string `json:"resourceType,omitempty" tf:"resource_type,omitempty"`
}

func (*AclObservation) DeepCopy 

func (in *AclObservation) DeepCopy() *AclObservation

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

func (*AclObservation) DeepCopyInto 

func (in *AclObservation) DeepCopyInto(out *AclObservation)

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

type AclParameters 

type AclParameters struct {

	// The default is *, which means that any host can access it. Support filling in IP or network segment, and support ;separation.
	// The default is *, which means that any host can access it. Support filling in IP or network segment, and support `;`separation.
	// +kubebuilder:validation:Optional
	Host *string `json:"host,omitempty" tf:"host,omitempty"`

	// ID of the ckafka instance.
	// ID of the ckafka instance.
	// +crossplane:generate:reference:type=Instance
	// +kubebuilder:validation:Optional
	InstanceID *string `json:"instanceId,omitempty" tf:"instance_id,omitempty"`

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

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

	// ACL operation mode. Valid values: UNKNOWN, ANY, ALL, READ, WRITE, CREATE, DELETE, ALTER, DESCRIBE, CLUSTER_ACTION, DESCRIBE_CONFIGS and ALTER_CONFIGS.
	// ACL operation mode. Valid values: `UNKNOWN`, `ANY`, `ALL`, `READ`, `WRITE`, `CREATE`, `DELETE`, `ALTER`, `DESCRIBE`, `CLUSTER_ACTION`, `DESCRIBE_CONFIGS` and `ALTER_CONFIGS`.
	// +kubebuilder:validation:Optional
	OperationType *string `json:"operationType,omitempty" tf:"operation_type,omitempty"`

	// ACL permission type. Valid values: UNKNOWN, ANY, DENY, ALLOW. and ALLOW by default. Currently, CKafka supports ALLOW (equivalent to allow list), and other fields will be used for future ACLs compatible with open-source Kafka.
	// ACL permission type. Valid values: `UNKNOWN`, `ANY`, `DENY`, `ALLOW`. and `ALLOW` by default. Currently, CKafka supports `ALLOW` (equivalent to allow list), and other fields will be used for future ACLs compatible with open-source Kafka.
	// +kubebuilder:validation:Optional
	PermissionType *string `json:"permissionType,omitempty" tf:"permission_type,omitempty"`

	// User list. The default value is *, which means that any user can access. The current user can only be one included in the user list. For example: root meaning user root can access.
	// User list. The default value is `*`, which means that any user can access. The current user can only be one included in the user list. For example: `root` meaning user root can access.
	// +kubebuilder:validation:Optional
	Principal *string `json:"principal,omitempty" tf:"principal,omitempty"`

	// ACL resource name, which is related to resource_type. For example, if resource_type is TOPIC, this field indicates the topic name; if resource_type is GROUP, this field indicates the group name.
	// ACL resource name, which is related to `resource_type`. For example, if `resource_type` is `TOPIC`, this field indicates the topic name; if `resource_type` is `GROUP`, this field indicates the group name.
	// +kubebuilder:validation:Optional
	ResourceName *string `json:"resourceName,omitempty" tf:"resource_name,omitempty"`

	// ACL resource type. Valid values are UNKNOWN, ANY, TOPIC, GROUP, CLUSTER, TRANSACTIONAL_ID. and TOPIC by default. Currently, only TOPIC is available, and other fields will be used for future ACLs compatible with open-source Kafka.
	// ACL resource type. Valid values are `UNKNOWN`, `ANY`, `TOPIC`, `GROUP`, `CLUSTER`, `TRANSACTIONAL_ID`. and `TOPIC` by default. Currently, only `TOPIC` is available, and other fields will be used for future ACLs compatible with open-source Kafka.
	// +kubebuilder:validation:Optional
	ResourceType *string `json:"resourceType,omitempty" tf:"resource_type,omitempty"`
}

func (*AclParameters) DeepCopy 

func (in *AclParameters) DeepCopy() *AclParameters

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

func (*AclParameters) DeepCopyInto 

func (in *AclParameters) DeepCopyInto(out *AclParameters)

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

type AclSpec 

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

AclSpec defines the desired state of Acl

func (*AclSpec) DeepCopy 

func (in *AclSpec) DeepCopy() *AclSpec

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

func (*AclSpec) DeepCopyInto 

func (in *AclSpec) DeepCopyInto(out *AclSpec)

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

type AclStatus 

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

AclStatus defines the observed state of Acl.

func (*AclStatus) DeepCopy 

func (in *AclStatus) DeepCopy() *AclStatus

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

func (*AclStatus) DeepCopyInto 

func (in *AclStatus) DeepCopyInto(out *AclStatus)

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

type ConfigInitParameters added in v0.8.0 

type ConfigInitParameters struct {

	// Automatic creation. true: enabled, false: not enabled.
	// Automatic creation. true: enabled, false: not enabled.
	AutoCreateTopicEnable *bool `json:"autoCreateTopicEnable,omitempty" tf:"auto_create_topic_enable,omitempty"`

	// If auto.create.topic.enable is set to true and this value is not set, 3 will be used by default.
	// If auto.create.topic.enable is set to true and this value is not set, 3 will be used by default.
	DefaultNumPartitions *float64 `json:"defaultNumPartitions,omitempty" tf:"default_num_partitions,omitempty"`

	// If auto.create.topic.enable is set to true but this value is not set, 2 will be used by default.
	// If auto.create.topic.enable is set to true but this value is not set, 2 will be used by default.
	DefaultReplicationFactor *float64 `json:"defaultReplicationFactor,omitempty" tf:"default_replication_factor,omitempty"`
}

func (*ConfigInitParameters) DeepCopy added in v0.8.0 

func (in *ConfigInitParameters) DeepCopy() *ConfigInitParameters

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

func (*ConfigInitParameters) DeepCopyInto added in v0.8.0 

func (in *ConfigInitParameters) DeepCopyInto(out *ConfigInitParameters)

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

type ConfigObservation 

type ConfigObservation struct {

	// Automatic creation. true: enabled, false: not enabled.
	// Automatic creation. true: enabled, false: not enabled.
	AutoCreateTopicEnable *bool `json:"autoCreateTopicEnable,omitempty" tf:"auto_create_topic_enable,omitempty"`

	// If auto.create.topic.enable is set to true and this value is not set, 3 will be used by default.
	// If auto.create.topic.enable is set to true and this value is not set, 3 will be used by default.
	DefaultNumPartitions *float64 `json:"defaultNumPartitions,omitempty" tf:"default_num_partitions,omitempty"`

	// If auto.create.topic.enable is set to true but this value is not set, 2 will be used by default.
	// If auto.create.topic.enable is set to true but this value is not set, 2 will be used by default.
	DefaultReplicationFactor *float64 `json:"defaultReplicationFactor,omitempty" tf:"default_replication_factor,omitempty"`
}

func (*ConfigObservation) DeepCopy 

func (in *ConfigObservation) DeepCopy() *ConfigObservation

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

func (*ConfigObservation) DeepCopyInto 

func (in *ConfigObservation) DeepCopyInto(out *ConfigObservation)

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

type ConfigParameters 

type ConfigParameters struct {

	// Automatic creation. true: enabled, false: not enabled.
	// Automatic creation. true: enabled, false: not enabled.
	// +kubebuilder:validation:Optional
	AutoCreateTopicEnable *bool `json:"autoCreateTopicEnable" tf:"auto_create_topic_enable,omitempty"`

	// If auto.create.topic.enable is set to true and this value is not set, 3 will be used by default.
	// If auto.create.topic.enable is set to true and this value is not set, 3 will be used by default.
	// +kubebuilder:validation:Optional
	DefaultNumPartitions *float64 `json:"defaultNumPartitions" tf:"default_num_partitions,omitempty"`

	// If auto.create.topic.enable is set to true but this value is not set, 2 will be used by default.
	// If auto.create.topic.enable is set to true but this value is not set, 2 will be used by default.
	// +kubebuilder:validation:Optional
	DefaultReplicationFactor *float64 `json:"defaultReplicationFactor" tf:"default_replication_factor,omitempty"`
}

func (*ConfigParameters) DeepCopy 

func (in *ConfigParameters) DeepCopy() *ConfigParameters

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

func (*ConfigParameters) DeepCopyInto 

func (in *ConfigParameters) DeepCopyInto(out *ConfigParameters)

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

type DynamicRetentionConfigInitParameters added in v0.8.0 

type DynamicRetentionConfigInitParameters struct {

	// Minimum retention time, in minutes.
	// Minimum retention time, in minutes.
	BottomRetention *float64 `json:"bottomRetention,omitempty" tf:"bottom_retention,omitempty"`

	// Disk quota threshold (in percentage) for triggering the message retention time change event.
	// Disk quota threshold (in percentage) for triggering the message retention time change event.
	DiskQuotaPercentage *float64 `json:"diskQuotaPercentage,omitempty" tf:"disk_quota_percentage,omitempty"`

	// Whether the dynamic message retention time configuration is enabled. 0: disabled; 1: enabled.
	// Whether the dynamic message retention time configuration is enabled. 0: disabled; 1: enabled.
	Enable *float64 `json:"enable,omitempty" tf:"enable,omitempty"`

	// Percentage by which the message retention time is shortened each time.
	// Percentage by which the message retention time is shortened each time.
	StepForwardPercentage *float64 `json:"stepForwardPercentage,omitempty" tf:"step_forward_percentage,omitempty"`
}

func (*DynamicRetentionConfigInitParameters) DeepCopy added in v0.8.0 

func (in *DynamicRetentionConfigInitParameters) DeepCopy() *DynamicRetentionConfigInitParameters

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

func (*DynamicRetentionConfigInitParameters) DeepCopyInto added in v0.8.0 

func (in *DynamicRetentionConfigInitParameters) DeepCopyInto(out *DynamicRetentionConfigInitParameters)

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

type DynamicRetentionConfigObservation 

type DynamicRetentionConfigObservation struct {

	// Minimum retention time, in minutes.
	// Minimum retention time, in minutes.
	BottomRetention *float64 `json:"bottomRetention,omitempty" tf:"bottom_retention,omitempty"`

	// Disk quota threshold (in percentage) for triggering the message retention time change event.
	// Disk quota threshold (in percentage) for triggering the message retention time change event.
	DiskQuotaPercentage *float64 `json:"diskQuotaPercentage,omitempty" tf:"disk_quota_percentage,omitempty"`

	// Whether the dynamic message retention time configuration is enabled. 0: disabled; 1: enabled.
	// Whether the dynamic message retention time configuration is enabled. 0: disabled; 1: enabled.
	Enable *float64 `json:"enable,omitempty" tf:"enable,omitempty"`

	// Percentage by which the message retention time is shortened each time.
	// Percentage by which the message retention time is shortened each time.
	StepForwardPercentage *float64 `json:"stepForwardPercentage,omitempty" tf:"step_forward_percentage,omitempty"`
}

func (*DynamicRetentionConfigObservation) DeepCopy 

func (in *DynamicRetentionConfigObservation) DeepCopy() *DynamicRetentionConfigObservation

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

func (*DynamicRetentionConfigObservation) DeepCopyInto 

func (in *DynamicRetentionConfigObservation) DeepCopyInto(out *DynamicRetentionConfigObservation)

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

type DynamicRetentionConfigParameters 

type DynamicRetentionConfigParameters struct {

	// Minimum retention time, in minutes.
	// Minimum retention time, in minutes.
	// +kubebuilder:validation:Optional
	BottomRetention *float64 `json:"bottomRetention,omitempty" tf:"bottom_retention,omitempty"`

	// Disk quota threshold (in percentage) for triggering the message retention time change event.
	// Disk quota threshold (in percentage) for triggering the message retention time change event.
	// +kubebuilder:validation:Optional
	DiskQuotaPercentage *float64 `json:"diskQuotaPercentage,omitempty" tf:"disk_quota_percentage,omitempty"`

	// Whether the dynamic message retention time configuration is enabled. 0: disabled; 1: enabled.
	// Whether the dynamic message retention time configuration is enabled. 0: disabled; 1: enabled.
	// +kubebuilder:validation:Optional
	Enable *float64 `json:"enable,omitempty" tf:"enable,omitempty"`

	// Percentage by which the message retention time is shortened each time.
	// Percentage by which the message retention time is shortened each time.
	// +kubebuilder:validation:Optional
	StepForwardPercentage *float64 `json:"stepForwardPercentage,omitempty" tf:"step_forward_percentage,omitempty"`
}

func (*DynamicRetentionConfigParameters) DeepCopy 

func (in *DynamicRetentionConfigParameters) DeepCopy() *DynamicRetentionConfigParameters

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

func (*DynamicRetentionConfigParameters) DeepCopyInto 

func (in *DynamicRetentionConfigParameters) DeepCopyInto(out *DynamicRetentionConfigParameters)

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

type Instance 

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

Instance is the Schema for the Instances API. Use this resource to create ckafka 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:resource:scope=Cluster,categories={crossplane,managed,tencentcloud}

func (*Instance) DeepCopy 

func (in *Instance) DeepCopy() *Instance

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

func (*Instance) DeepCopyInto 

func (in *Instance) DeepCopyInto(out *Instance)

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

func (*Instance) DeepCopyObject 

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

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

func (*Instance) GetCondition 

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

GetCondition of this Instance.

func (*Instance) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this Instance

func (*Instance) GetDeletionPolicy 

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

GetDeletionPolicy of this Instance.

func (*Instance) GetID 

func (tr *Instance) GetID() string

GetID returns ID of underlying Terraform resource of this Instance

func (*Instance) GetInitParameters added in v0.8.0 

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

GetInitParameters of this Instance

func (*Instance) GetManagementPolicies added in v0.8.0 

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

GetManagementPolicies of this Instance.

func (*Instance) GetMergedParameters added in v0.8.1 

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

GetInitParameters of this Instance

func (*Instance) GetObservation 

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

GetObservation of this Instance

func (*Instance) GetParameters 

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

GetParameters of this Instance

func (*Instance) GetProviderConfigReference 

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

GetProviderConfigReference of this Instance.

func (*Instance) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this Instance.

func (*Instance) GetTerraformResourceType 

func (mg *Instance) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Instance

func (*Instance) GetTerraformSchemaVersion 

func (tr *Instance) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Instance) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this Instance.

func (*Instance) Hub added in v0.8.1 

func (tr *Instance) Hub()

Hub marks this type as a conversion hub.

func (*Instance) LateInitialize 

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

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

func (*Instance) ResolveReferences 

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

ResolveReferences of this Instance.

func (*Instance) SetConditions 

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

SetConditions of this Instance.

func (*Instance) SetDeletionPolicy 

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

SetDeletionPolicy of this Instance.

func (*Instance) SetManagementPolicies added in v0.8.0 

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

SetManagementPolicies of this Instance.

func (*Instance) SetObservation 

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

SetObservation for this Instance

func (*Instance) SetParameters 

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

SetParameters for this Instance

func (*Instance) SetProviderConfigReference 

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

SetProviderConfigReference of this Instance.

func (*Instance) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this Instance.

func (*Instance) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this Instance.

type InstanceInitParameters added in v0.8.0 

type InstanceInitParameters struct {

	// Instance bandwidth in MBps.
	// Instance bandwidth in MBps.
	BandWidth *float64 `json:"bandWidth,omitempty" tf:"band_width,omitempty"`

	// The charge type of instance. Valid values are PREPAID and POSTPAID_BY_HOUR. Default value is PREPAID.
	// The charge type of instance. Valid values are `PREPAID` and `POSTPAID_BY_HOUR`. Default value is `PREPAID`.
	ChargeType *string `json:"chargeType,omitempty" tf:"charge_type,omitempty"`

	// Instance configuration.
	// Instance configuration.
	Config []ConfigInitParameters `json:"config,omitempty" tf:"config,omitempty"`

	// Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	// Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	DiskSize *float64 `json:"diskSize,omitempty" tf:"disk_size,omitempty"`

	// Type of disk.
	// Type of disk.
	DiskType *string `json:"diskType,omitempty" tf:"disk_type,omitempty"`

	// Dynamic message retention policy configuration.
	// Dynamic message retention policy configuration.
	DynamicRetentionConfig []DynamicRetentionConfigInitParameters `json:"dynamicRetentionConfig,omitempty" tf:"dynamic_retention_config,omitempty"`

	// Instance name.
	// Instance name.
	InstanceName *string `json:"instanceName,omitempty" tf:"instance_name,omitempty"`

	// Description of instance type. profession: 1, standard:  1(general), 2(standard), 3(advanced), 4(capacity), 5(specialized-1), 6(specialized-2), 7(specialized-3), 8(specialized-4), 9(exclusive).
	// Description of instance type. `profession`: 1, `standard`:  1(general), 2(standard), 3(advanced), 4(capacity), 5(specialized-1), 6(specialized-2), 7(specialized-3), 8(specialized-4), 9(exclusive).
	InstanceType *float64 `json:"instanceType,omitempty" tf:"instance_type,omitempty"`

	// Kafka version (0.10.2/1.1.1/2.4.1).
	// Kafka version (0.10.2/1.1.1/2.4.1).
	KafkaVersion *string `json:"kafkaVersion,omitempty" tf:"kafka_version,omitempty"`

	// The size of a single message in bytes at the instance level. Value range: `1024 - 1210241024 bytes (i.e., 1KB-12MB).
	// The size of a single message in bytes at the instance level. Value range: `1024 - 12*1024*1024 bytes (i.e., 1KB-12MB).
	MaxMessageByte *float64 `json:"maxMessageByte,omitempty" tf:"max_message_byte,omitempty"`

	// The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the default 0 is not filled, which means that the log retention time recovery policy is not enabled.
	// The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the default 0 is not filled, which means that the log retention time recovery policy is not enabled.
	MsgRetentionTime *float64 `json:"msgRetentionTime,omitempty" tf:"msg_retention_time,omitempty"`

	// Indicates whether the instance is multi zones. NOTE: if set to true, zone_ids must set together.
	// Indicates whether the instance is multi zones. NOTE: if set to `true`, `zone_ids` must set together.
	MultiZoneFlag *bool `json:"multiZoneFlag,omitempty" tf:"multi_zone_flag,omitempty"`

	// Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	// Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	Partition *float64 `json:"partition,omitempty" tf:"partition,omitempty"`

	// Prepaid purchase time, such as 1, is one month.
	// Prepaid purchase time, such as 1, is one month.
	Period *float64 `json:"period,omitempty" tf:"period,omitempty"`

	// Bandwidth of the public network.
	// Bandwidth of the public network.
	PublicNetwork *float64 `json:"publicNetwork,omitempty" tf:"public_network,omitempty"`

	// Modification of the rebalancing time after upgrade.
	// Modification of the rebalancing time after upgrade.
	RebalanceTime *float64 `json:"rebalanceTime,omitempty" tf:"rebalance_time,omitempty"`

	// Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear no automatic renewal (user setting).
	// Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear no automatic renewal (user setting).
	RenewFlag *float64 `json:"renewFlag,omitempty" tf:"renew_flag,omitempty"`

	// Specifications type of instance. Allowed values are standard, profession. Default is profession.
	// Specifications type of instance. Allowed values are `standard`, `profession`. Default is `profession`.
	SpecificationsType *string `json:"specificationsType,omitempty" tf:"specifications_type,omitempty"`

	// Subnet id, it will be basic network if not set.
	// Subnet id, it will be basic network if not set.
	// +crossplane:generate:reference:type=github.com/crossplane-contrib/provider-tencentcloud/apis/vpc/v1alpha1.Subnet
	SubnetID *string `json:"subnetId,omitempty" tf:"subnet_id,omitempty"`

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

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

	// Tag set of instance.
	// Tag set of instance.
	// +mapType=granular
	TagSet map[string]*string `json:"tagSet,omitempty" tf:"tag_set,omitempty"`

	// It has been deprecated from version 1.78.5, because it do not support change. Use tag_set instead. Tags of instance. Partition size, the professional version does not need tag.
	// Tags of instance. Partition size, the professional version does not need tag.
	Tags []TagsInitParameters `json:"tags,omitempty" tf:"tags,omitempty"`

	// POSTPAID_BY_HOUR scale-down mode
	// POSTPAID_BY_HOUR scale-down mode
	// - 1: stable transformation;
	// - 2: High-speed transformer.
	UpgradeStrategy *float64 `json:"upgradeStrategy,omitempty" tf:"upgrade_strategy,omitempty"`

	// Vpc id, it will be basic network if not set.
	// Vpc id, it will be basic network if not set.
	// +crossplane:generate:reference:type=github.com/crossplane-contrib/provider-tencentcloud/apis/vpc/v1alpha1.VPC
	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:"-"`

	// Available zone id.
	// Available zone id.
	ZoneID *float64 `json:"zoneId,omitempty" tf:"zone_id,omitempty"`

	// List of available zone id. NOTE: this argument must set together with multi_zone_flag.
	// List of available zone id. NOTE: this argument must set together with `multi_zone_flag`.
	// +listType=set
	ZoneIds []*float64 `json:"zoneIds,omitempty" tf:"zone_ids,omitempty"`
}

func (*InstanceInitParameters) DeepCopy added in v0.8.0 

func (in *InstanceInitParameters) DeepCopy() *InstanceInitParameters

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

func (*InstanceInitParameters) DeepCopyInto added in v0.8.0 

func (in *InstanceInitParameters) DeepCopyInto(out *InstanceInitParameters)

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

type InstanceList 

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

InstanceList contains a list of Instances

func (*InstanceList) DeepCopy 

func (in *InstanceList) DeepCopy() *InstanceList

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

func (*InstanceList) DeepCopyInto 

func (in *InstanceList) DeepCopyInto(out *InstanceList)

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

func (*InstanceList) DeepCopyObject 

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

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

func (*InstanceList) GetItems 

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

GetItems of this InstanceList.

type InstanceObservation 

type InstanceObservation struct {

	// Instance bandwidth in MBps.
	// Instance bandwidth in MBps.
	BandWidth *float64 `json:"bandWidth,omitempty" tf:"band_width,omitempty"`

	// The charge type of instance. Valid values are PREPAID and POSTPAID_BY_HOUR. Default value is PREPAID.
	// The charge type of instance. Valid values are `PREPAID` and `POSTPAID_BY_HOUR`. Default value is `PREPAID`.
	ChargeType *string `json:"chargeType,omitempty" tf:"charge_type,omitempty"`

	// Instance configuration.
	// Instance configuration.
	Config []ConfigObservation `json:"config,omitempty" tf:"config,omitempty"`

	// Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	// Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	DiskSize *float64 `json:"diskSize,omitempty" tf:"disk_size,omitempty"`

	// Type of disk.
	// Type of disk.
	DiskType *string `json:"diskType,omitempty" tf:"disk_type,omitempty"`

	// Dynamic message retention policy configuration.
	// Dynamic message retention policy configuration.
	DynamicRetentionConfig []DynamicRetentionConfigObservation `json:"dynamicRetentionConfig,omitempty" tf:"dynamic_retention_config,omitempty"`

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

	// Instance name.
	// Instance name.
	InstanceName *string `json:"instanceName,omitempty" tf:"instance_name,omitempty"`

	// Description of instance type. profession: 1, standard:  1(general), 2(standard), 3(advanced), 4(capacity), 5(specialized-1), 6(specialized-2), 7(specialized-3), 8(specialized-4), 9(exclusive).
	// Description of instance type. `profession`: 1, `standard`:  1(general), 2(standard), 3(advanced), 4(capacity), 5(specialized-1), 6(specialized-2), 7(specialized-3), 8(specialized-4), 9(exclusive).
	InstanceType *float64 `json:"instanceType,omitempty" tf:"instance_type,omitempty"`

	// Kafka version (0.10.2/1.1.1/2.4.1).
	// Kafka version (0.10.2/1.1.1/2.4.1).
	KafkaVersion *string `json:"kafkaVersion,omitempty" tf:"kafka_version,omitempty"`

	// The size of a single message in bytes at the instance level. Value range: `1024 - 1210241024 bytes (i.e., 1KB-12MB).
	// The size of a single message in bytes at the instance level. Value range: `1024 - 12*1024*1024 bytes (i.e., 1KB-12MB).
	MaxMessageByte *float64 `json:"maxMessageByte,omitempty" tf:"max_message_byte,omitempty"`

	// The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the default 0 is not filled, which means that the log retention time recovery policy is not enabled.
	// The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the default 0 is not filled, which means that the log retention time recovery policy is not enabled.
	MsgRetentionTime *float64 `json:"msgRetentionTime,omitempty" tf:"msg_retention_time,omitempty"`

	// Indicates whether the instance is multi zones. NOTE: if set to true, zone_ids must set together.
	// Indicates whether the instance is multi zones. NOTE: if set to `true`, `zone_ids` must set together.
	MultiZoneFlag *bool `json:"multiZoneFlag,omitempty" tf:"multi_zone_flag,omitempty"`

	// Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	// Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	Partition *float64 `json:"partition,omitempty" tf:"partition,omitempty"`

	// Prepaid purchase time, such as 1, is one month.
	// Prepaid purchase time, such as 1, is one month.
	Period *float64 `json:"period,omitempty" tf:"period,omitempty"`

	// Bandwidth of the public network.
	// Bandwidth of the public network.
	PublicNetwork *float64 `json:"publicNetwork,omitempty" tf:"public_network,omitempty"`

	// Modification of the rebalancing time after upgrade.
	// Modification of the rebalancing time after upgrade.
	RebalanceTime *float64 `json:"rebalanceTime,omitempty" tf:"rebalance_time,omitempty"`

	// Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear no automatic renewal (user setting).
	// Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear no automatic renewal (user setting).
	RenewFlag *float64 `json:"renewFlag,omitempty" tf:"renew_flag,omitempty"`

	// Specifications type of instance. Allowed values are standard, profession. Default is profession.
	// Specifications type of instance. Allowed values are `standard`, `profession`. Default is `profession`.
	SpecificationsType *string `json:"specificationsType,omitempty" tf:"specifications_type,omitempty"`

	// Subnet id, it will be basic network if not set.
	// Subnet id, it will be basic network if not set.
	SubnetID *string `json:"subnetId,omitempty" tf:"subnet_id,omitempty"`

	// Tag set of instance.
	// Tag set of instance.
	// +mapType=granular
	TagSet map[string]*string `json:"tagSet,omitempty" tf:"tag_set,omitempty"`

	// It has been deprecated from version 1.78.5, because it do not support change. Use tag_set instead. Tags of instance. Partition size, the professional version does not need tag.
	// Tags of instance. Partition size, the professional version does not need tag.
	Tags []TagsObservation `json:"tags,omitempty" tf:"tags,omitempty"`

	// POSTPAID_BY_HOUR scale-down mode
	// POSTPAID_BY_HOUR scale-down mode
	// - 1: stable transformation;
	// - 2: High-speed transformer.
	UpgradeStrategy *float64 `json:"upgradeStrategy,omitempty" tf:"upgrade_strategy,omitempty"`

	// Vpc id, it will be basic network if not set.
	// Vpc id, it will be basic network if not set.
	VPCID *string `json:"vpcId,omitempty" tf:"vpc_id,omitempty"`

	// Vip of instance.
	// Vip of instance.
	Vip *string `json:"vip,omitempty" tf:"vip,omitempty"`

	// Type of instance.
	// Type of instance.
	Vport *string `json:"vport,omitempty" tf:"vport,omitempty"`

	// Available zone id.
	// Available zone id.
	ZoneID *float64 `json:"zoneId,omitempty" tf:"zone_id,omitempty"`

	// List of available zone id. NOTE: this argument must set together with multi_zone_flag.
	// List of available zone id. NOTE: this argument must set together with `multi_zone_flag`.
	// +listType=set
	ZoneIds []*float64 `json:"zoneIds,omitempty" tf:"zone_ids,omitempty"`
}

func (*InstanceObservation) DeepCopy 

func (in *InstanceObservation) DeepCopy() *InstanceObservation

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

func (*InstanceObservation) DeepCopyInto 

func (in *InstanceObservation) DeepCopyInto(out *InstanceObservation)

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

type InstanceParameters 

type InstanceParameters struct {

	// Instance bandwidth in MBps.
	// Instance bandwidth in MBps.
	// +kubebuilder:validation:Optional
	BandWidth *float64 `json:"bandWidth,omitempty" tf:"band_width,omitempty"`

	// The charge type of instance. Valid values are PREPAID and POSTPAID_BY_HOUR. Default value is PREPAID.
	// The charge type of instance. Valid values are `PREPAID` and `POSTPAID_BY_HOUR`. Default value is `PREPAID`.
	// +kubebuilder:validation:Optional
	ChargeType *string `json:"chargeType,omitempty" tf:"charge_type,omitempty"`

	// Instance configuration.
	// Instance configuration.
	// +kubebuilder:validation:Optional
	Config []ConfigParameters `json:"config,omitempty" tf:"config,omitempty"`

	// Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	// Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	// +kubebuilder:validation:Optional
	DiskSize *float64 `json:"diskSize,omitempty" tf:"disk_size,omitempty"`

	// Type of disk.
	// Type of disk.
	// +kubebuilder:validation:Optional
	DiskType *string `json:"diskType,omitempty" tf:"disk_type,omitempty"`

	// Dynamic message retention policy configuration.
	// Dynamic message retention policy configuration.
	// +kubebuilder:validation:Optional
	DynamicRetentionConfig []DynamicRetentionConfigParameters `json:"dynamicRetentionConfig,omitempty" tf:"dynamic_retention_config,omitempty"`

	// Instance name.
	// Instance name.
	// +kubebuilder:validation:Optional
	InstanceName *string `json:"instanceName,omitempty" tf:"instance_name,omitempty"`

	// Description of instance type. profession: 1, standard:  1(general), 2(standard), 3(advanced), 4(capacity), 5(specialized-1), 6(specialized-2), 7(specialized-3), 8(specialized-4), 9(exclusive).
	// Description of instance type. `profession`: 1, `standard`:  1(general), 2(standard), 3(advanced), 4(capacity), 5(specialized-1), 6(specialized-2), 7(specialized-3), 8(specialized-4), 9(exclusive).
	// +kubebuilder:validation:Optional
	InstanceType *float64 `json:"instanceType,omitempty" tf:"instance_type,omitempty"`

	// Kafka version (0.10.2/1.1.1/2.4.1).
	// Kafka version (0.10.2/1.1.1/2.4.1).
	// +kubebuilder:validation:Optional
	KafkaVersion *string `json:"kafkaVersion,omitempty" tf:"kafka_version,omitempty"`

	// The size of a single message in bytes at the instance level. Value range: `1024 - 1210241024 bytes (i.e., 1KB-12MB).
	// The size of a single message in bytes at the instance level. Value range: `1024 - 12*1024*1024 bytes (i.e., 1KB-12MB).
	// +kubebuilder:validation:Optional
	MaxMessageByte *float64 `json:"maxMessageByte,omitempty" tf:"max_message_byte,omitempty"`

	// The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the default 0 is not filled, which means that the log retention time recovery policy is not enabled.
	// The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the default 0 is not filled, which means that the log retention time recovery policy is not enabled.
	// +kubebuilder:validation:Optional
	MsgRetentionTime *float64 `json:"msgRetentionTime,omitempty" tf:"msg_retention_time,omitempty"`

	// Indicates whether the instance is multi zones. NOTE: if set to true, zone_ids must set together.
	// Indicates whether the instance is multi zones. NOTE: if set to `true`, `zone_ids` must set together.
	// +kubebuilder:validation:Optional
	MultiZoneFlag *bool `json:"multiZoneFlag,omitempty" tf:"multi_zone_flag,omitempty"`

	// Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	// Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	// +kubebuilder:validation:Optional
	Partition *float64 `json:"partition,omitempty" tf:"partition,omitempty"`

	// Prepaid purchase time, such as 1, is one month.
	// Prepaid purchase time, such as 1, is one month.
	// +kubebuilder:validation:Optional
	Period *float64 `json:"period,omitempty" tf:"period,omitempty"`

	// Bandwidth of the public network.
	// Bandwidth of the public network.
	// +kubebuilder:validation:Optional
	PublicNetwork *float64 `json:"publicNetwork,omitempty" tf:"public_network,omitempty"`

	// Modification of the rebalancing time after upgrade.
	// Modification of the rebalancing time after upgrade.
	// +kubebuilder:validation:Optional
	RebalanceTime *float64 `json:"rebalanceTime,omitempty" tf:"rebalance_time,omitempty"`

	// Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear no automatic renewal (user setting).
	// Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear no automatic renewal (user setting).
	// +kubebuilder:validation:Optional
	RenewFlag *float64 `json:"renewFlag,omitempty" tf:"renew_flag,omitempty"`

	// Specifications type of instance. Allowed values are standard, profession. Default is profession.
	// Specifications type of instance. Allowed values are `standard`, `profession`. Default is `profession`.
	// +kubebuilder:validation:Optional
	SpecificationsType *string `json:"specificationsType,omitempty" tf:"specifications_type,omitempty"`

	// Subnet id, it will be basic network if not set.
	// Subnet id, it will be basic network if not set.
	// +crossplane:generate:reference:type=github.com/crossplane-contrib/provider-tencentcloud/apis/vpc/v1alpha1.Subnet
	// +kubebuilder:validation:Optional
	SubnetID *string `json:"subnetId,omitempty" tf:"subnet_id,omitempty"`

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

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

	// Tag set of instance.
	// Tag set of instance.
	// +kubebuilder:validation:Optional
	// +mapType=granular
	TagSet map[string]*string `json:"tagSet,omitempty" tf:"tag_set,omitempty"`

	// It has been deprecated from version 1.78.5, because it do not support change. Use tag_set instead. Tags of instance. Partition size, the professional version does not need tag.
	// Tags of instance. Partition size, the professional version does not need tag.
	// +kubebuilder:validation:Optional
	Tags []TagsParameters `json:"tags,omitempty" tf:"tags,omitempty"`

	// POSTPAID_BY_HOUR scale-down mode
	// POSTPAID_BY_HOUR scale-down mode
	// - 1: stable transformation;
	// - 2: High-speed transformer.
	// +kubebuilder:validation:Optional
	UpgradeStrategy *float64 `json:"upgradeStrategy,omitempty" tf:"upgrade_strategy,omitempty"`

	// Vpc id, it will be basic network if not set.
	// Vpc id, it will be basic network if not set.
	// +crossplane:generate:reference:type=github.com/crossplane-contrib/provider-tencentcloud/apis/vpc/v1alpha1.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:"-"`

	// Available zone id.
	// Available zone id.
	// +kubebuilder:validation:Optional
	ZoneID *float64 `json:"zoneId,omitempty" tf:"zone_id,omitempty"`

	// List of available zone id. NOTE: this argument must set together with multi_zone_flag.
	// List of available zone id. NOTE: this argument must set together with `multi_zone_flag`.
	// +kubebuilder:validation:Optional
	// +listType=set
	ZoneIds []*float64 `json:"zoneIds,omitempty" tf:"zone_ids,omitempty"`
}

func (*InstanceParameters) DeepCopy 

func (in *InstanceParameters) DeepCopy() *InstanceParameters

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

func (*InstanceParameters) DeepCopyInto 

func (in *InstanceParameters) DeepCopyInto(out *InstanceParameters)

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

type InstanceSpec 

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

InstanceSpec defines the desired state of Instance

func (*InstanceSpec) DeepCopy 

func (in *InstanceSpec) DeepCopy() *InstanceSpec

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

func (*InstanceSpec) DeepCopyInto 

func (in *InstanceSpec) DeepCopyInto(out *InstanceSpec)

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

type InstanceStatus 

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

InstanceStatus defines the observed state of Instance.

func (*InstanceStatus) DeepCopy 

func (in *InstanceStatus) DeepCopy() *InstanceStatus

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

func (*InstanceStatus) DeepCopyInto 

func (in *InstanceStatus) DeepCopyInto(out *InstanceStatus)

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

type TagsInitParameters added in v0.8.0 

type TagsInitParameters struct {

	// Tag key.
	// Tag key.
	Key *string `json:"key,omitempty" tf:"key,omitempty"`

	// Tag value.
	// Tag value.
	Value *string `json:"value,omitempty" tf:"value,omitempty"`
}

func (*TagsInitParameters) DeepCopy added in v0.8.0 

func (in *TagsInitParameters) DeepCopy() *TagsInitParameters

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

func (*TagsInitParameters) DeepCopyInto added in v0.8.0 

func (in *TagsInitParameters) DeepCopyInto(out *TagsInitParameters)

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

type TagsObservation 

type TagsObservation struct {

	// Tag key.
	// Tag key.
	Key *string `json:"key,omitempty" tf:"key,omitempty"`

	// Tag value.
	// Tag value.
	Value *string `json:"value,omitempty" tf:"value,omitempty"`
}

func (*TagsObservation) DeepCopy 

func (in *TagsObservation) DeepCopy() *TagsObservation

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

func (*TagsObservation) DeepCopyInto 

func (in *TagsObservation) DeepCopyInto(out *TagsObservation)

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

type TagsParameters 

type TagsParameters struct {

	// Tag key.
	// Tag key.
	// +kubebuilder:validation:Optional
	Key *string `json:"key" tf:"key,omitempty"`

	// Tag value.
	// Tag value.
	// +kubebuilder:validation:Optional
	Value *string `json:"value" tf:"value,omitempty"`
}

func (*TagsParameters) DeepCopy 

func (in *TagsParameters) DeepCopy() *TagsParameters

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

func (*TagsParameters) DeepCopyInto 

func (in *TagsParameters) DeepCopyInto(out *TagsParameters)

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

type Topic 

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

Topic is the Schema for the Topics API. Use this resource to create ckafka topic. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,tencentcloud}

func (*Topic) DeepCopy 

func (in *Topic) DeepCopy() *Topic

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

func (*Topic) DeepCopyInto 

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

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

func (*Topic) DeepCopyObject 

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

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

func (*Topic) GetCondition 

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

GetCondition of this Topic.

func (*Topic) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this Topic

func (*Topic) GetDeletionPolicy 

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

GetDeletionPolicy of this Topic.

func (*Topic) GetID 

func (tr *Topic) GetID() string

GetID returns ID of underlying Terraform resource of this Topic

func (*Topic) GetInitParameters added in v0.8.0 

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

GetInitParameters of this Topic

func (*Topic) GetManagementPolicies added in v0.8.0 

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

GetManagementPolicies of this Topic.

func (*Topic) GetMergedParameters added in v0.8.1 

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

GetInitParameters of this Topic

func (*Topic) GetObservation 

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

GetObservation of this Topic

func (*Topic) GetParameters 

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

GetParameters of this Topic

func (*Topic) GetProviderConfigReference 

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

GetProviderConfigReference of this Topic.

func (*Topic) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this Topic.

func (*Topic) GetTerraformResourceType 

func (mg *Topic) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Topic

func (*Topic) GetTerraformSchemaVersion 

func (tr *Topic) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Topic) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this Topic.

func (*Topic) Hub added in v0.8.1 

func (tr *Topic) Hub()

Hub marks this type as a conversion hub.

func (*Topic) LateInitialize 

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

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

func (*Topic) ResolveReferences 

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

ResolveReferences of this Topic.

func (*Topic) SetConditions 

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

SetConditions of this Topic.

func (*Topic) SetDeletionPolicy 

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

SetDeletionPolicy of this Topic.

func (*Topic) SetManagementPolicies added in v0.8.0 

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

SetManagementPolicies of this Topic.

func (*Topic) SetObservation 

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

SetObservation for this Topic

func (*Topic) SetParameters 

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

SetParameters for this Topic

func (*Topic) SetProviderConfigReference 

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

SetProviderConfigReference of this Topic.

func (*Topic) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this Topic.

func (*Topic) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this Topic.

type TopicInitParameters added in v0.8.0 

type TopicInitParameters struct {

	// Clear log policy, log clear mode, default is delete. delete: logs are deleted according to the storage time. compact: logs are compressed according to the key. compact, delete: logs are compressed according to the key and will be deleted according to the storage time.
	// Clear log policy, log clear mode, default is `delete`. `delete`: logs are deleted according to the storage time. `compact`: logs are compressed according to the key. `compact, delete`: logs are compressed according to the key and will be deleted according to the storage time.
	CleanUpPolicy *string `json:"cleanUpPolicy,omitempty" tf:"clean_up_policy,omitempty"`

	// Whether to open the ip whitelist, true: open, false: close.
	// Whether to open the ip whitelist, `true`: open, `false`: close.
	EnableWhiteList *bool `json:"enableWhiteList,omitempty" tf:"enable_white_list,omitempty"`

	// Ip whitelist, quota limit, required when enableWhileList=true.
	// Ip whitelist, quota limit, required when enableWhileList=true.
	IPWhiteList []*string `json:"ipWhiteList,omitempty" tf:"ip_white_list,omitempty"`

	// Ckafka instance ID.
	// Ckafka instance ID.
	// +crossplane:generate:reference:type=Instance
	InstanceID *string `json:"instanceId,omitempty" tf:"instance_id,omitempty"`

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

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

	// Max message bytes. min: 1024 Byte(1KB), max: 8388608 Byte(8MB).
	// Max message bytes. min: 1024 Byte(1KB), max: 8388608 Byte(8MB).
	MaxMessageBytes *float64 `json:"maxMessageBytes,omitempty" tf:"max_message_bytes,omitempty"`

	// The subject note. It must start with a letter, and the remaining part can contain letters, numbers and dashes (-).
	// The subject note. It must start with a letter, and the remaining part can contain letters, numbers and dashes (-).
	Note *string `json:"note,omitempty" tf:"note,omitempty"`

	// The number of partition.
	// The number of partition.
	PartitionNum *float64 `json:"partitionNum,omitempty" tf:"partition_num,omitempty"`

	// The number of replica.
	// The number of replica.
	ReplicaNum *float64 `json:"replicaNum,omitempty" tf:"replica_num,omitempty"`

	// Message can be selected. Retention time, unit is ms, the current minimum value is 60000ms.
	// Message can be selected. Retention time, unit is ms, the current minimum value is 60000ms.
	Retention *float64 `json:"retention,omitempty" tf:"retention,omitempty"`

	// Segment scrolling time, in ms, the current minimum is 3600000ms.
	// Segment scrolling time, in ms, the current minimum is 3600000ms.
	Segment *float64 `json:"segment,omitempty" tf:"segment,omitempty"`

	// Min number of sync replicas, Default is 1.
	// Min number of sync replicas, Default is `1`.
	SyncReplicaMinNum *float64 `json:"syncReplicaMinNum,omitempty" tf:"sync_replica_min_num,omitempty"`

	// Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-).
	// Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-).
	TopicName *string `json:"topicName,omitempty" tf:"topic_name,omitempty"`

	// Whether to allow unsynchronized replicas to be selected as leader, default is false, true: allowed, false: not allowed.
	// Whether to allow unsynchronized replicas to be selected as leader, default is `false`, `true: `allowed, `false`: not allowed.
	UncleanLeaderElectionEnable *bool `json:"uncleanLeaderElectionEnable,omitempty" tf:"unclean_leader_election_enable,omitempty"`
}

func (*TopicInitParameters) DeepCopy added in v0.8.0 

func (in *TopicInitParameters) DeepCopy() *TopicInitParameters

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

func (*TopicInitParameters) DeepCopyInto added in v0.8.0 

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

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

type TopicList 

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

TopicList contains a list of Topics

func (*TopicList) DeepCopy 

func (in *TopicList) DeepCopy() *TopicList

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

func (*TopicList) DeepCopyInto 

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

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

func (*TopicList) DeepCopyObject 

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

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

func (*TopicList) GetItems 

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

GetItems of this TopicList.

type TopicObservation 

type TopicObservation struct {

	// Clear log policy, log clear mode, default is delete. delete: logs are deleted according to the storage time. compact: logs are compressed according to the key. compact, delete: logs are compressed according to the key and will be deleted according to the storage time.
	// Clear log policy, log clear mode, default is `delete`. `delete`: logs are deleted according to the storage time. `compact`: logs are compressed according to the key. `compact, delete`: logs are compressed according to the key and will be deleted according to the storage time.
	CleanUpPolicy *string `json:"cleanUpPolicy,omitempty" tf:"clean_up_policy,omitempty"`

	// Create time of the CKafka topic.
	// Create time of the CKafka topic.
	CreateTime *string `json:"createTime,omitempty" tf:"create_time,omitempty"`

	// Whether to open the ip whitelist, true: open, false: close.
	// Whether to open the ip whitelist, `true`: open, `false`: close.
	EnableWhiteList *bool `json:"enableWhiteList,omitempty" tf:"enable_white_list,omitempty"`

	// Data backup cos bucket: the bucket address that is dumped to cos.
	// Data backup cos bucket: the bucket address that is dumped to cos.
	ForwardCosBucket *string `json:"forwardCosBucket,omitempty" tf:"forward_cos_bucket,omitempty"`

	// Periodic frequency of data backup to cos.
	// Periodic frequency of data backup to cos.
	ForwardInterval *float64 `json:"forwardInterval,omitempty" tf:"forward_interval,omitempty"`

	// Data backup cos status. Valid values: 0, 1. 1: do not open data backup, 0: open data backup.
	// Data backup cos status. Valid values: `0`, `1`. `1`: do not open data backup, `0`: open data backup.
	ForwardStatus *float64 `json:"forwardStatus,omitempty" tf:"forward_status,omitempty"`

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

	// Ip whitelist, quota limit, required when enableWhileList=true.
	// Ip whitelist, quota limit, required when enableWhileList=true.
	IPWhiteList []*string `json:"ipWhiteList,omitempty" tf:"ip_white_list,omitempty"`

	// Ckafka instance ID.
	// Ckafka instance ID.
	InstanceID *string `json:"instanceId,omitempty" tf:"instance_id,omitempty"`

	// Max message bytes. min: 1024 Byte(1KB), max: 8388608 Byte(8MB).
	// Max message bytes. min: 1024 Byte(1KB), max: 8388608 Byte(8MB).
	MaxMessageBytes *float64 `json:"maxMessageBytes,omitempty" tf:"max_message_bytes,omitempty"`

	// Message storage location.
	// Message storage location.
	MessageStorageLocation *string `json:"messageStorageLocation,omitempty" tf:"message_storage_location,omitempty"`

	// The subject note. It must start with a letter, and the remaining part can contain letters, numbers and dashes (-).
	// The subject note. It must start with a letter, and the remaining part can contain letters, numbers and dashes (-).
	Note *string `json:"note,omitempty" tf:"note,omitempty"`

	// The number of partition.
	// The number of partition.
	PartitionNum *float64 `json:"partitionNum,omitempty" tf:"partition_num,omitempty"`

	// The number of replica.
	// The number of replica.
	ReplicaNum *float64 `json:"replicaNum,omitempty" tf:"replica_num,omitempty"`

	// Message can be selected. Retention time, unit is ms, the current minimum value is 60000ms.
	// Message can be selected. Retention time, unit is ms, the current minimum value is 60000ms.
	Retention *float64 `json:"retention,omitempty" tf:"retention,omitempty"`

	// Segment scrolling time, in ms, the current minimum is 3600000ms.
	// Segment scrolling time, in ms, the current minimum is 3600000ms.
	Segment *float64 `json:"segment,omitempty" tf:"segment,omitempty"`

	// Number of bytes rolled by shard.
	// Number of bytes rolled by shard.
	SegmentBytes *float64 `json:"segmentBytes,omitempty" tf:"segment_bytes,omitempty"`

	// Min number of sync replicas, Default is 1.
	// Min number of sync replicas, Default is `1`.
	SyncReplicaMinNum *float64 `json:"syncReplicaMinNum,omitempty" tf:"sync_replica_min_num,omitempty"`

	// Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-).
	// Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-).
	TopicName *string `json:"topicName,omitempty" tf:"topic_name,omitempty"`

	// Whether to allow unsynchronized replicas to be selected as leader, default is false, true: allowed, false: not allowed.
	// Whether to allow unsynchronized replicas to be selected as leader, default is `false`, `true: `allowed, `false`: not allowed.
	UncleanLeaderElectionEnable *bool `json:"uncleanLeaderElectionEnable,omitempty" tf:"unclean_leader_election_enable,omitempty"`
}

func (*TopicObservation) DeepCopy 

func (in *TopicObservation) DeepCopy() *TopicObservation

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

func (*TopicObservation) DeepCopyInto 

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

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

type TopicParameters 

type TopicParameters struct {

	// Clear log policy, log clear mode, default is delete. delete: logs are deleted according to the storage time. compact: logs are compressed according to the key. compact, delete: logs are compressed according to the key and will be deleted according to the storage time.
	// Clear log policy, log clear mode, default is `delete`. `delete`: logs are deleted according to the storage time. `compact`: logs are compressed according to the key. `compact, delete`: logs are compressed according to the key and will be deleted according to the storage time.
	// +kubebuilder:validation:Optional
	CleanUpPolicy *string `json:"cleanUpPolicy,omitempty" tf:"clean_up_policy,omitempty"`

	// Whether to open the ip whitelist, true: open, false: close.
	// Whether to open the ip whitelist, `true`: open, `false`: close.
	// +kubebuilder:validation:Optional
	EnableWhiteList *bool `json:"enableWhiteList,omitempty" tf:"enable_white_list,omitempty"`

	// Ip whitelist, quota limit, required when enableWhileList=true.
	// Ip whitelist, quota limit, required when enableWhileList=true.
	// +kubebuilder:validation:Optional
	IPWhiteList []*string `json:"ipWhiteList,omitempty" tf:"ip_white_list,omitempty"`

	// Ckafka instance ID.
	// Ckafka instance ID.
	// +crossplane:generate:reference:type=Instance
	// +kubebuilder:validation:Optional
	InstanceID *string `json:"instanceId,omitempty" tf:"instance_id,omitempty"`

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

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

	// Max message bytes. min: 1024 Byte(1KB), max: 8388608 Byte(8MB).
	// Max message bytes. min: 1024 Byte(1KB), max: 8388608 Byte(8MB).
	// +kubebuilder:validation:Optional
	MaxMessageBytes *float64 `json:"maxMessageBytes,omitempty" tf:"max_message_bytes,omitempty"`

	// The subject note. It must start with a letter, and the remaining part can contain letters, numbers and dashes (-).
	// The subject note. It must start with a letter, and the remaining part can contain letters, numbers and dashes (-).
	// +kubebuilder:validation:Optional
	Note *string `json:"note,omitempty" tf:"note,omitempty"`

	// The number of partition.
	// The number of partition.
	// +kubebuilder:validation:Optional
	PartitionNum *float64 `json:"partitionNum,omitempty" tf:"partition_num,omitempty"`

	// The number of replica.
	// The number of replica.
	// +kubebuilder:validation:Optional
	ReplicaNum *float64 `json:"replicaNum,omitempty" tf:"replica_num,omitempty"`

	// Message can be selected. Retention time, unit is ms, the current minimum value is 60000ms.
	// Message can be selected. Retention time, unit is ms, the current minimum value is 60000ms.
	// +kubebuilder:validation:Optional
	Retention *float64 `json:"retention,omitempty" tf:"retention,omitempty"`

	// Segment scrolling time, in ms, the current minimum is 3600000ms.
	// Segment scrolling time, in ms, the current minimum is 3600000ms.
	// +kubebuilder:validation:Optional
	Segment *float64 `json:"segment,omitempty" tf:"segment,omitempty"`

	// Min number of sync replicas, Default is 1.
	// Min number of sync replicas, Default is `1`.
	// +kubebuilder:validation:Optional
	SyncReplicaMinNum *float64 `json:"syncReplicaMinNum,omitempty" tf:"sync_replica_min_num,omitempty"`

	// Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-).
	// Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-).
	// +kubebuilder:validation:Optional
	TopicName *string `json:"topicName,omitempty" tf:"topic_name,omitempty"`

	// Whether to allow unsynchronized replicas to be selected as leader, default is false, true: allowed, false: not allowed.
	// Whether to allow unsynchronized replicas to be selected as leader, default is `false`, `true: `allowed, `false`: not allowed.
	// +kubebuilder:validation:Optional
	UncleanLeaderElectionEnable *bool `json:"uncleanLeaderElectionEnable,omitempty" tf:"unclean_leader_election_enable,omitempty"`
}

func (*TopicParameters) DeepCopy 

func (in *TopicParameters) DeepCopy() *TopicParameters

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

func (*TopicParameters) DeepCopyInto 

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

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

type TopicSpec 

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

TopicSpec defines the desired state of Topic

func (*TopicSpec) DeepCopy 

func (in *TopicSpec) DeepCopy() *TopicSpec

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

func (*TopicSpec) DeepCopyInto 

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

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

type TopicStatus 

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

TopicStatus defines the observed state of Topic.

func (*TopicStatus) DeepCopy 

func (in *TopicStatus) DeepCopy() *TopicStatus

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

func (*TopicStatus) DeepCopyInto 

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

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

type User 

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

User is the Schema for the Users API. Provides a resource to create a Ckafka 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:resource:scope=Cluster,categories={crossplane,managed,tencentcloud}

func (*User) DeepCopy 

func (in *User) DeepCopy() *User

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

func (*User) DeepCopyInto 

func (in *User) DeepCopyInto(out *User)

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

func (*User) DeepCopyObject 

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

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

func (*User) GetCondition 

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

GetCondition of this User.

func (*User) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this User

func (*User) GetDeletionPolicy 

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

GetDeletionPolicy of this User.

func (*User) GetID 

func (tr *User) GetID() string

GetID returns ID of underlying Terraform resource of this User

func (*User) GetInitParameters added in v0.8.0 

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

GetInitParameters of this User

func (*User) GetManagementPolicies added in v0.8.0 

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

GetManagementPolicies of this User.

func (*User) GetMergedParameters added in v0.8.1 

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

GetInitParameters of this User

func (*User) GetObservation 

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

GetObservation of this User

func (*User) GetParameters 

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

GetParameters of this User

func (*User) GetProviderConfigReference 

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

GetProviderConfigReference of this User.

func (*User) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this User.

func (*User) GetTerraformResourceType 

func (mg *User) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this User

func (*User) GetTerraformSchemaVersion 

func (tr *User) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*User) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this User.

func (*User) Hub added in v0.8.1 

func (tr *User) Hub()

Hub marks this type as a conversion hub.

func (*User) LateInitialize 

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

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

func (*User) ResolveReferences 

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

ResolveReferences of this User.

func (*User) SetConditions 

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

SetConditions of this User.

func (*User) SetDeletionPolicy 

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

SetDeletionPolicy of this User.

func (*User) SetManagementPolicies added in v0.8.0 

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

SetManagementPolicies of this User.

func (*User) SetObservation 

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

SetObservation for this User

func (*User) SetParameters 

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

SetParameters for this User

func (*User) SetProviderConfigReference 

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

SetProviderConfigReference of this User.

func (*User) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this User.

func (*User) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this User.

type UserInitParameters added in v0.8.0 

type UserInitParameters struct {

	// Account name used to access to ckafka instance.
	// Account name used to access to ckafka instance.
	AccountName *string `json:"accountName,omitempty" tf:"account_name,omitempty"`

	// ID of the ckafka instance.
	// ID of the ckafka instance.
	// +crossplane:generate:reference:type=Instance
	InstanceID *string `json:"instanceId,omitempty" tf:"instance_id,omitempty"`

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

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

func (*UserInitParameters) DeepCopy added in v0.8.0 

func (in *UserInitParameters) DeepCopy() *UserInitParameters

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

func (*UserInitParameters) DeepCopyInto added in v0.8.0 

func (in *UserInitParameters) DeepCopyInto(out *UserInitParameters)

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

type UserList 

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

UserList contains a list of Users

func (*UserList) DeepCopy 

func (in *UserList) DeepCopy() *UserList

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

func (*UserList) DeepCopyInto 

func (in *UserList) DeepCopyInto(out *UserList)

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

func (*UserList) DeepCopyObject 

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

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

func (*UserList) GetItems 

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

GetItems of this UserList.

type UserObservation 

type UserObservation struct {

	// Account name used to access to ckafka instance.
	// Account name used to access to ckafka instance.
	AccountName *string `json:"accountName,omitempty" tf:"account_name,omitempty"`

	// Creation time of the account.
	// Creation time of the account.
	CreateTime *string `json:"createTime,omitempty" tf:"create_time,omitempty"`

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

	// ID of the ckafka instance.
	// ID of the ckafka instance.
	InstanceID *string `json:"instanceId,omitempty" tf:"instance_id,omitempty"`

	// The last update time of the account.
	// The last update time of the account.
	UpdateTime *string `json:"updateTime,omitempty" tf:"update_time,omitempty"`
}

func (*UserObservation) DeepCopy 

func (in *UserObservation) DeepCopy() *UserObservation

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

func (*UserObservation) DeepCopyInto 

func (in *UserObservation) DeepCopyInto(out *UserObservation)

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

type UserParameters 

type UserParameters struct {

	// Account name used to access to ckafka instance.
	// Account name used to access to ckafka instance.
	// +kubebuilder:validation:Optional
	AccountName *string `json:"accountName,omitempty" tf:"account_name,omitempty"`

	// ID of the ckafka instance.
	// ID of the ckafka instance.
	// +crossplane:generate:reference:type=Instance
	// +kubebuilder:validation:Optional
	InstanceID *string `json:"instanceId,omitempty" tf:"instance_id,omitempty"`

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

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

	// Password of the account.
	// Password of the account.
	// +kubebuilder:validation:Optional
	PasswordSecretRef v1.SecretKeySelector `json:"passwordSecretRef" tf:"-"`
}

func (*UserParameters) DeepCopy 

func (in *UserParameters) DeepCopy() *UserParameters

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

func (*UserParameters) DeepCopyInto 

func (in *UserParameters) DeepCopyInto(out *UserParameters)

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

type UserSpec 

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

UserSpec defines the desired state of User

func (*UserSpec) DeepCopy 

func (in *UserSpec) DeepCopy() *UserSpec

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

func (*UserSpec) DeepCopyInto 

func (in *UserSpec) DeepCopyInto(out *UserSpec)

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

type UserStatus 

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

UserStatus defines the observed state of User.

func (*UserStatus) DeepCopy 

func (in *UserStatus) DeepCopy() *UserStatus

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

func (*UserStatus) DeepCopyInto 

func (in *UserStatus) DeepCopyInto(out *UserStatus)

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.