Documentation ¶
Overview ¶
+kubebuilder:object:generate=true +groupName=kafka.tencentcloud.crossplane.io +versionName=v1alpha1
Index ¶
- Constants
- Variables
- type Acl
- func (in *Acl) DeepCopy() *Acl
- func (in *Acl) DeepCopyInto(out *Acl)
- func (in *Acl) DeepCopyObject() runtime.Object
- func (mg *Acl) GetCondition(ct xpv1.ConditionType) xpv1.Condition
- func (tr *Acl) GetConnectionDetailsMapping() map[string]string
- func (mg *Acl) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *Acl) GetID() string
- func (tr *Acl) GetObservation() (map[string]interface{}, error)
- func (tr *Acl) GetParameters() (map[string]interface{}, error)
- func (mg *Acl) GetProviderConfigReference() *xpv1.Reference
- func (mg *Acl) GetProviderReference() *xpv1.Reference
- func (mg *Acl) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *Acl) GetTerraformResourceType() string
- func (tr *Acl) GetTerraformSchemaVersion() int
- func (mg *Acl) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *Acl) LateInitialize(attrs []byte) (bool, error)
- func (mg *Acl) ResolveReferences(ctx context.Context, c client.Reader) error
- func (mg *Acl) SetConditions(c ...xpv1.Condition)
- func (mg *Acl) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (tr *Acl) SetObservation(obs map[string]interface{}) error
- func (tr *Acl) SetParameters(params map[string]interface{}) error
- func (mg *Acl) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *Acl) SetProviderReference(r *xpv1.Reference)
- func (mg *Acl) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *Acl) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type AclList
- type AclObservation
- type AclParameters
- type AclSpec
- type AclStatus
- type ConfigObservation
- type ConfigParameters
- type DynamicRetentionConfigObservation
- type DynamicRetentionConfigParameters
- type Instance
- func (in *Instance) DeepCopy() *Instance
- func (in *Instance) DeepCopyInto(out *Instance)
- func (in *Instance) DeepCopyObject() runtime.Object
- func (mg *Instance) GetCondition(ct xpv1.ConditionType) xpv1.Condition
- func (tr *Instance) GetConnectionDetailsMapping() map[string]string
- func (mg *Instance) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *Instance) GetID() string
- func (tr *Instance) GetObservation() (map[string]interface{}, error)
- func (tr *Instance) GetParameters() (map[string]interface{}, error)
- func (mg *Instance) GetProviderConfigReference() *xpv1.Reference
- func (mg *Instance) GetProviderReference() *xpv1.Reference
- func (mg *Instance) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *Instance) GetTerraformResourceType() string
- func (tr *Instance) GetTerraformSchemaVersion() int
- func (mg *Instance) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *Instance) LateInitialize(attrs []byte) (bool, error)
- func (mg *Instance) ResolveReferences(ctx context.Context, c client.Reader) error
- func (mg *Instance) SetConditions(c ...xpv1.Condition)
- func (mg *Instance) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (tr *Instance) SetObservation(obs map[string]interface{}) error
- func (tr *Instance) SetParameters(params map[string]interface{}) error
- func (mg *Instance) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *Instance) SetProviderReference(r *xpv1.Reference)
- func (mg *Instance) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *Instance) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type InstanceList
- type InstanceObservation
- type InstanceParameters
- type InstanceSpec
- type InstanceStatus
- type TagsObservation
- type TagsParameters
- type Topic
- func (in *Topic) DeepCopy() *Topic
- func (in *Topic) DeepCopyInto(out *Topic)
- func (in *Topic) DeepCopyObject() runtime.Object
- func (mg *Topic) GetCondition(ct xpv1.ConditionType) xpv1.Condition
- func (tr *Topic) GetConnectionDetailsMapping() map[string]string
- func (mg *Topic) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *Topic) GetID() string
- func (tr *Topic) GetObservation() (map[string]interface{}, error)
- func (tr *Topic) GetParameters() (map[string]interface{}, error)
- func (mg *Topic) GetProviderConfigReference() *xpv1.Reference
- func (mg *Topic) GetProviderReference() *xpv1.Reference
- func (mg *Topic) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *Topic) GetTerraformResourceType() string
- func (tr *Topic) GetTerraformSchemaVersion() int
- func (mg *Topic) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *Topic) LateInitialize(attrs []byte) (bool, error)
- func (mg *Topic) ResolveReferences(ctx context.Context, c client.Reader) error
- func (mg *Topic) SetConditions(c ...xpv1.Condition)
- func (mg *Topic) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (tr *Topic) SetObservation(obs map[string]interface{}) error
- func (tr *Topic) SetParameters(params map[string]interface{}) error
- func (mg *Topic) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *Topic) SetProviderReference(r *xpv1.Reference)
- func (mg *Topic) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *Topic) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type TopicList
- type TopicObservation
- type TopicParameters
- type TopicSpec
- type TopicStatus
- type User
- func (in *User) DeepCopy() *User
- func (in *User) DeepCopyInto(out *User)
- func (in *User) DeepCopyObject() runtime.Object
- func (mg *User) GetCondition(ct xpv1.ConditionType) xpv1.Condition
- func (tr *User) GetConnectionDetailsMapping() map[string]string
- func (mg *User) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *User) GetID() string
- func (tr *User) GetObservation() (map[string]interface{}, error)
- func (tr *User) GetParameters() (map[string]interface{}, error)
- func (mg *User) GetProviderConfigReference() *xpv1.Reference
- func (mg *User) GetProviderReference() *xpv1.Reference
- func (mg *User) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *User) GetTerraformResourceType() string
- func (tr *User) GetTerraformSchemaVersion() int
- func (mg *User) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *User) LateInitialize(attrs []byte) (bool, error)
- func (mg *User) ResolveReferences(ctx context.Context, c client.Reader) error
- func (mg *User) SetConditions(c ...xpv1.Condition)
- func (mg *User) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (tr *User) SetObservation(obs map[string]interface{}) error
- func (tr *User) SetParameters(params map[string]interface{}) error
- func (mg *User) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *User) SetProviderReference(r *xpv1.Reference)
- func (mg *User) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *User) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type UserList
- type UserObservation
- type UserParameters
- type UserSpec
- type UserStatus
Constants ¶
const ( CRDGroup = "kafka.tencentcloud.crossplane.io" CRDVersion = "v1alpha1" )
Package type metadata.
Variables ¶
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.
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 )
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.
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.
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"` Spec AclSpec `json:"spec"` Status AclStatus `json:"status,omitempty"` }
Acl is the Schema for the Acls API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,tencentcloudjet}
func (*Acl) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Acl.
func (*Acl) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Acl) DeepCopyObject ¶
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 ¶
GetConnectionDetailsMapping for this Acl
func (*Acl) GetDeletionPolicy ¶
func (mg *Acl) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this Acl.
func (*Acl) GetObservation ¶
GetObservation of this Acl
func (*Acl) GetParameters ¶
GetParameters of this Acl
func (*Acl) GetProviderConfigReference ¶
GetProviderConfigReference of this Acl.
func (*Acl) GetProviderReference ¶
GetProviderReference of this Acl. Deprecated: Use GetProviderConfigReference.
func (*Acl) GetPublishConnectionDetailsTo ¶
func (mg *Acl) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this Acl.
func (*Acl) GetTerraformResourceType ¶
GetTerraformResourceType returns Terraform resource type for this Acl
func (*Acl) GetTerraformSchemaVersion ¶
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*Acl) GetWriteConnectionSecretToReference ¶
func (mg *Acl) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this Acl.
func (*Acl) LateInitialize ¶
LateInitialize this Acl using its observed tfState. returns True if there are any spec changes for the resource.
func (*Acl) ResolveReferences ¶
ResolveReferences of this Acl.
func (*Acl) SetConditions ¶
SetConditions of this Acl.
func (*Acl) SetDeletionPolicy ¶
func (mg *Acl) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this Acl.
func (*Acl) SetObservation ¶
SetObservation for this Acl
func (*Acl) SetParameters ¶
SetParameters for this Acl
func (*Acl) SetProviderConfigReference ¶
SetProviderConfigReference of this Acl.
func (*Acl) SetProviderReference ¶
SetProviderReference of this Acl. Deprecated: Use SetProviderConfigReference.
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 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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AclList.
func (*AclList) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AclList) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type AclObservation ¶
type AclObservation struct {
ID *string `json:"id,omitempty" tf:"id,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. // +kubebuilder:validation:Optional Host *string `json:"host,omitempty" tf:"host,omitempty"` // ID of the ckafka instance. // +crossplane:generate:reference:type=Instance // +kubebuilder:validation:Optional InstanceID *string `json:"instanceId,omitempty" tf:"instance_id,omitempty"` // +kubebuilder:validation:Optional InstanceIDRef *v1.Reference `json:"instanceIdRef,omitempty" tf:"-"` // +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`. // +kubebuilder:validation:Required OperationType *string `json:"operationType" 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. // +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. // +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. // +kubebuilder:validation:Required ResourceName *string `json:"resourceName" 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. // +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"` }
AclSpec defines the desired state of Acl
func (*AclSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AclSpec.
func (*AclSpec) DeepCopyInto ¶
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AclStatus.
func (*AclStatus) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigObservation ¶
type ConfigObservation struct { }
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. // +kubebuilder:validation:Required 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. // +kubebuilder:validation:Required 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. // +kubebuilder:validation:Required 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 DynamicRetentionConfigObservation ¶
type DynamicRetentionConfigObservation struct { }
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. // +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. // +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. // +kubebuilder:validation:Optional Enable *float64 `json:"enable,omitempty" tf:"enable,omitempty"` // 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"` Spec InstanceSpec `json:"spec"` Status InstanceStatus `json:"status,omitempty"` }
Instance is the Schema for the Instances API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,tencentcloudjet}
func (*Instance) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Instance.
func (*Instance) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Instance) DeepCopyObject ¶
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 ¶
GetConnectionDetailsMapping for this Instance
func (*Instance) GetDeletionPolicy ¶
func (mg *Instance) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this Instance.
func (*Instance) GetObservation ¶
GetObservation of this Instance
func (*Instance) GetParameters ¶
GetParameters of this Instance
func (*Instance) GetProviderConfigReference ¶
GetProviderConfigReference of this Instance.
func (*Instance) GetProviderReference ¶
GetProviderReference of this Instance. Deprecated: Use GetProviderConfigReference.
func (*Instance) GetPublishConnectionDetailsTo ¶
func (mg *Instance) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this Instance.
func (*Instance) GetTerraformResourceType ¶
GetTerraformResourceType returns Terraform resource type for this Instance
func (*Instance) GetTerraformSchemaVersion ¶
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*Instance) GetWriteConnectionSecretToReference ¶
func (mg *Instance) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this Instance.
func (*Instance) LateInitialize ¶
LateInitialize this Instance using its observed tfState. returns True if there are any spec changes for the resource.
func (*Instance) ResolveReferences ¶
ResolveReferences of this Instance.
func (*Instance) SetConditions ¶
SetConditions of this Instance.
func (*Instance) SetDeletionPolicy ¶
func (mg *Instance) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this Instance.
func (*Instance) SetObservation ¶
SetObservation for this Instance
func (*Instance) SetParameters ¶
SetParameters for this Instance
func (*Instance) SetProviderConfigReference ¶
SetProviderConfigReference of this Instance.
func (*Instance) SetProviderReference ¶
SetProviderReference of this Instance. Deprecated: Use SetProviderConfigReference.
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 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 { ID *string `json:"id,omitempty" tf:"id,omitempty"` Vip *string `json:"vip,omitempty" tf:"vip,omitempty"` Vport *string `json:"vport,omitempty" tf:"vport,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. // +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`. // +kubebuilder:validation:Optional ChargeType *string `json:"chargeType,omitempty" tf:"charge_type,omitempty"` // 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. // +kubebuilder:validation:Optional DiskSize *float64 `json:"diskSize,omitempty" tf:"disk_size,omitempty"` // Type of disk. // +kubebuilder:validation:Optional DiskType *string `json:"diskType,omitempty" tf:"disk_type,omitempty"` // Dynamic message retention policy configuration. // +kubebuilder:validation:Optional DynamicRetentionConfig []DynamicRetentionConfigParameters `json:"dynamicRetentionConfig,omitempty" tf:"dynamic_retention_config,omitempty"` // Instance name. // +kubebuilder:validation:Required InstanceName *string `json:"instanceName" 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). // +kubebuilder:validation:Optional InstanceType *float64 `json:"instanceType,omitempty" tf:"instance_type,omitempty"` // 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 - 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. // +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. // +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. // +kubebuilder:validation:Optional Partition *float64 `json:"partition,omitempty" tf:"partition,omitempty"` // 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. // +kubebuilder:validation:Optional PublicNetwork *float64 `json:"publicNetwork,omitempty" tf:"public_network,omitempty"` // 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). // +kubebuilder:validation:Optional RenewFlag *float64 `json:"renewFlag,omitempty" tf:"renew_flag,omitempty"` // 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. // +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"` // +kubebuilder:validation:Optional SubnetIDRef *v1.Reference `json:"subnetIdRef,omitempty" tf:"-"` // +kubebuilder:validation:Optional SubnetIDSelector *v1.Selector `json:"subnetIdSelector,omitempty" tf:"-"` // Tag set of instance. // +kubebuilder:validation:Optional TagSet map[string]*string `json:"tagSet,omitempty" tf:"tag_set,omitempty"` // 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 // - 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. // +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"` // +kubebuilder:validation:Optional VPCIDRef *v1.Reference `json:"vpcidRef,omitempty" tf:"-"` // +kubebuilder:validation:Optional VPCIDSelector *v1.Selector `json:"vpcidSelector,omitempty" tf:"-"` // Available zone id. // +kubebuilder:validation:Required ZoneID *float64 `json:"zoneId" tf:"zone_id,omitempty"` // List of available zone id. NOTE: this argument must set together with `multi_zone_flag`. // +kubebuilder:validation:Optional 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"` }
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 TagsObservation ¶
type TagsObservation struct { }
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. // +kubebuilder:validation:Required Key *string `json:"key" tf:"key,omitempty"` // Tag value. // +kubebuilder:validation:Required 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"` Spec TopicSpec `json:"spec"` Status TopicStatus `json:"status,omitempty"` }
Topic is the Schema for the Topics API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,tencentcloudjet}
func (*Topic) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Topic.
func (*Topic) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Topic) DeepCopyObject ¶
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 ¶
GetConnectionDetailsMapping for this Topic
func (*Topic) GetDeletionPolicy ¶
func (mg *Topic) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this Topic.
func (*Topic) GetObservation ¶
GetObservation of this Topic
func (*Topic) GetParameters ¶
GetParameters of this Topic
func (*Topic) GetProviderConfigReference ¶
GetProviderConfigReference of this Topic.
func (*Topic) GetProviderReference ¶
GetProviderReference of this Topic. Deprecated: Use GetProviderConfigReference.
func (*Topic) GetPublishConnectionDetailsTo ¶
func (mg *Topic) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this Topic.
func (*Topic) GetTerraformResourceType ¶
GetTerraformResourceType returns Terraform resource type for this Topic
func (*Topic) GetTerraformSchemaVersion ¶
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*Topic) GetWriteConnectionSecretToReference ¶
func (mg *Topic) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this Topic.
func (*Topic) LateInitialize ¶
LateInitialize this Topic using its observed tfState. returns True if there are any spec changes for the resource.
func (*Topic) ResolveReferences ¶
ResolveReferences of this Topic.
func (*Topic) SetConditions ¶
SetConditions of this Topic.
func (*Topic) SetDeletionPolicy ¶
func (mg *Topic) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this Topic.
func (*Topic) SetObservation ¶
SetObservation for this Topic
func (*Topic) SetParameters ¶
SetParameters for this Topic
func (*Topic) SetProviderConfigReference ¶
SetProviderConfigReference of this Topic.
func (*Topic) SetProviderReference ¶
SetProviderReference of this Topic. Deprecated: Use SetProviderConfigReference.
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 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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicList.
func (*TopicList) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TopicList) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type TopicObservation ¶
type TopicObservation struct { CreateTime *string `json:"createTime,omitempty" tf:"create_time,omitempty"` ForwardCosBucket *string `json:"forwardCosBucket,omitempty" tf:"forward_cos_bucket,omitempty"` ForwardInterval *float64 `json:"forwardInterval,omitempty" tf:"forward_interval,omitempty"` ForwardStatus *float64 `json:"forwardStatus,omitempty" tf:"forward_status,omitempty"` ID *string `json:"id,omitempty" tf:"id,omitempty"` MessageStorageLocation *string `json:"messageStorageLocation,omitempty" tf:"message_storage_location,omitempty"` SegmentBytes *float64 `json:"segmentBytes,omitempty" tf:"segment_bytes,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. // +kubebuilder:validation:Optional CleanUpPolicy *string `json:"cleanUpPolicy,omitempty" tf:"clean_up_policy,omitempty"` // 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. // +kubebuilder:validation:Optional IPWhiteList []*string `json:"ipWhiteList,omitempty" tf:"ip_white_list,omitempty"` // Ckafka instance ID. // +crossplane:generate:reference:type=Instance // +kubebuilder:validation:Optional InstanceID *string `json:"instanceId,omitempty" tf:"instance_id,omitempty"` // +kubebuilder:validation:Optional InstanceIDRef *v1.Reference `json:"instanceIdRef,omitempty" tf:"-"` // +kubebuilder:validation:Optional InstanceIDSelector *v1.Selector `json:"instanceIdSelector,omitempty" tf:"-"` // 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 (-). // +kubebuilder:validation:Optional Note *string `json:"note,omitempty" tf:"note,omitempty"` // The number of partition. // +kubebuilder:validation:Required PartitionNum *float64 `json:"partitionNum" tf:"partition_num,omitempty"` // The number of replica. // +kubebuilder:validation:Required ReplicaNum *float64 `json:"replicaNum" tf:"replica_num,omitempty"` // 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. // +kubebuilder:validation:Optional Segment *float64 `json:"segment,omitempty" tf:"segment,omitempty"` // 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(-). // +kubebuilder:validation:Required TopicName *string `json:"topicName" tf:"topic_name,omitempty"` // 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"` }
TopicSpec defines the desired state of Topic
func (*TopicSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicSpec.
func (*TopicSpec) DeepCopyInto ¶
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"` Spec UserSpec `json:"spec"` Status UserStatus `json:"status,omitempty"` }
User is the Schema for the Users API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,tencentcloudjet}
func (*User) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new User.
func (*User) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*User) DeepCopyObject ¶
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 ¶
GetConnectionDetailsMapping for this User
func (*User) GetDeletionPolicy ¶
func (mg *User) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this User.
func (*User) GetObservation ¶
GetObservation of this User
func (*User) GetParameters ¶
GetParameters of this User
func (*User) GetProviderConfigReference ¶
GetProviderConfigReference of this User.
func (*User) GetProviderReference ¶
GetProviderReference of this User. Deprecated: Use GetProviderConfigReference.
func (*User) GetPublishConnectionDetailsTo ¶
func (mg *User) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this User.
func (*User) GetTerraformResourceType ¶
GetTerraformResourceType returns Terraform resource type for this User
func (*User) GetTerraformSchemaVersion ¶
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*User) GetWriteConnectionSecretToReference ¶
func (mg *User) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this User.
func (*User) LateInitialize ¶
LateInitialize this User using its observed tfState. returns True if there are any spec changes for the resource.
func (*User) ResolveReferences ¶
ResolveReferences of this User.
func (*User) SetConditions ¶
SetConditions of this User.
func (*User) SetDeletionPolicy ¶
func (mg *User) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this User.
func (*User) SetObservation ¶
SetObservation for this User
func (*User) SetParameters ¶
SetParameters for this User
func (*User) SetProviderConfigReference ¶
SetProviderConfigReference of this User.
func (*User) SetProviderReference ¶
SetProviderReference of this User. Deprecated: Use SetProviderConfigReference.
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 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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UserList.
func (*UserList) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*UserList) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type UserObservation ¶
type UserObservation struct { CreateTime *string `json:"createTime,omitempty" tf:"create_time,omitempty"` ID *string `json:"id,omitempty" tf:"id,omitempty"` 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. // +kubebuilder:validation:Required AccountName *string `json:"accountName" tf:"account_name,omitempty"` // ID of the ckafka instance. // +crossplane:generate:reference:type=Instance // +kubebuilder:validation:Optional InstanceID *string `json:"instanceId,omitempty" tf:"instance_id,omitempty"` // +kubebuilder:validation:Optional InstanceIDRef *v1.Reference `json:"instanceIdRef,omitempty" tf:"-"` // +kubebuilder:validation:Optional InstanceIDSelector *v1.Selector `json:"instanceIdSelector,omitempty" tf:"-"` // Password of the account. // +kubebuilder:validation:Required 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"` }
UserSpec defines the desired state of User
func (*UserSpec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UserSpec.
func (*UserSpec) DeepCopyInto ¶
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.