Versions in this module Expand all Collapse all v0 v0.4.2 Apr 26, 2023 Changes in this version + const CRDGroup + const CRDVersion + var AddToScheme = SchemeBuilder.AddToScheme + var CRDGroupVersion = schema.GroupVersion + var KafkaInstance_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: KafkaInstance_Kind}.String() + var KafkaInstance_GroupVersionKind = CRDGroupVersion.WithKind(KafkaInstance_Kind) + var KafkaInstance_Kind = "KafkaInstance" + var KafkaInstance_KindAPIVersion = KafkaInstance_Kind + "." + CRDGroupVersion.String() + var KafkaTopic_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: KafkaTopic_Kind}.String() + var KafkaTopic_GroupVersionKind = CRDGroupVersion.WithKind(KafkaTopic_Kind) + var KafkaTopic_Kind = "KafkaTopic" + var KafkaTopic_KindAPIVersion = KafkaTopic_Kind + "." + CRDGroupVersion.String() + var KafkaUser_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: KafkaUser_Kind}.String() + var KafkaUser_GroupVersionKind = CRDGroupVersion.WithKind(KafkaUser_Kind) + var KafkaUser_Kind = "KafkaUser" + var KafkaUser_KindAPIVersion = KafkaUser_Kind + "." + CRDGroupVersion.String() + var RocketMQConsumerGroup_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: RocketMQConsumerGroup_Kind}.String() + var RocketMQConsumerGroup_GroupVersionKind = CRDGroupVersion.WithKind(RocketMQConsumerGroup_Kind) + var RocketMQConsumerGroup_Kind = "RocketMQConsumerGroup" + var RocketMQConsumerGroup_KindAPIVersion = RocketMQConsumerGroup_Kind + "." + CRDGroupVersion.String() + var RocketMQInstance_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: RocketMQInstance_Kind}.String() + var RocketMQInstance_GroupVersionKind = CRDGroupVersion.WithKind(RocketMQInstance_Kind) + var RocketMQInstance_Kind = "RocketMQInstance" + var RocketMQInstance_KindAPIVersion = RocketMQInstance_Kind + "." + CRDGroupVersion.String() + var RocketMQTopic_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: RocketMQTopic_Kind}.String() + var RocketMQTopic_GroupVersionKind = CRDGroupVersion.WithKind(RocketMQTopic_Kind) + var RocketMQTopic_Kind = "RocketMQTopic" + var RocketMQTopic_KindAPIVersion = RocketMQTopic_Kind + "." + CRDGroupVersion.String() + var RocketMQUser_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: RocketMQUser_Kind}.String() + var RocketMQUser_GroupVersionKind = CRDGroupVersion.WithKind(RocketMQUser_Kind) + var RocketMQUser_Kind = "RocketMQUser" + var RocketMQUser_KindAPIVersion = RocketMQUser_Kind + "." + CRDGroupVersion.String() + var SchemeBuilder = &scheme.Builder + type BrokersObservation struct + ReadQueueNum *float64 + WriteQueueNum *float64 + func (in *BrokersObservation) DeepCopy() *BrokersObservation + func (in *BrokersObservation) DeepCopyInto(out *BrokersObservation) + type BrokersParameters struct + Name *string + func (in *BrokersParameters) DeepCopy() *BrokersParameters + func (in *BrokersParameters) DeepCopyInto(out *BrokersParameters) + type CrossVPCAccessesObservation struct + LisenterIP *string + Port *float64 + PortID *string + func (in *CrossVPCAccessesObservation) DeepCopy() *CrossVPCAccessesObservation + func (in *CrossVPCAccessesObservation) DeepCopyInto(out *CrossVPCAccessesObservation) + type CrossVPCAccessesParameters struct + AdvertisedIP *string + func (in *CrossVPCAccessesParameters) DeepCopy() *CrossVPCAccessesParameters + func (in *CrossVPCAccessesParameters) DeepCopyInto(out *CrossVPCAccessesParameters) + type GroupPermsObservation struct + func (in *GroupPermsObservation) DeepCopy() *GroupPermsObservation + func (in *GroupPermsObservation) DeepCopyInto(out *GroupPermsObservation) + type GroupPermsParameters struct + Name *string + NameRef *v1.Reference + NameSelector *v1.Selector + Perm *string + func (in *GroupPermsParameters) DeepCopy() *GroupPermsParameters + func (in *GroupPermsParameters) DeepCopyInto(out *GroupPermsParameters) + type KafkaInstance struct + Spec KafkaInstanceSpec + Status KafkaInstanceStatus + func (in *KafkaInstance) DeepCopy() *KafkaInstance + func (in *KafkaInstance) DeepCopyInto(out *KafkaInstance) + func (in *KafkaInstance) DeepCopyObject() runtime.Object + func (mg *KafkaInstance) GetCondition(ct xpv1.ConditionType) xpv1.Condition + func (mg *KafkaInstance) GetDeletionPolicy() xpv1.DeletionPolicy + func (mg *KafkaInstance) GetProviderConfigReference() *xpv1.Reference + func (mg *KafkaInstance) GetProviderReference() *xpv1.Reference + func (mg *KafkaInstance) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo + func (mg *KafkaInstance) GetTerraformResourceType() string + func (mg *KafkaInstance) GetWriteConnectionSecretToReference() *xpv1.SecretReference + func (mg *KafkaInstance) ResolveReferences(ctx context.Context, c client.Reader) error + func (mg *KafkaInstance) SetConditions(c ...xpv1.Condition) + func (mg *KafkaInstance) SetDeletionPolicy(r xpv1.DeletionPolicy) + func (mg *KafkaInstance) SetProviderConfigReference(r *xpv1.Reference) + func (mg *KafkaInstance) SetProviderReference(r *xpv1.Reference) + func (mg *KafkaInstance) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo) + func (mg *KafkaInstance) SetWriteConnectionSecretToReference(r *xpv1.SecretReference) + func (tr *KafkaInstance) GetConnectionDetailsMapping() map[string]string + func (tr *KafkaInstance) GetID() string + func (tr *KafkaInstance) GetObservation() (map[string]any, error) + func (tr *KafkaInstance) GetParameters() (map[string]any, error) + func (tr *KafkaInstance) GetTerraformSchemaVersion() int + func (tr *KafkaInstance) LateInitialize(attrs []byte) (bool, error) + func (tr *KafkaInstance) SetObservation(obs map[string]any) error + func (tr *KafkaInstance) SetParameters(params map[string]any) error + type KafkaInstanceList struct + Items []KafkaInstance + func (in *KafkaInstanceList) DeepCopy() *KafkaInstanceList + func (in *KafkaInstanceList) DeepCopyInto(out *KafkaInstanceList) + func (in *KafkaInstanceList) DeepCopyObject() runtime.Object + func (l *KafkaInstanceList) GetItems() []resource.Managed + type KafkaInstanceObservation struct + ConnectAddress *string + CreatedAt *string + Engine *string + EngineType *string + ID *string + ManegementConnectAddress *string + NodeNum *float64 + PartitionNum *float64 + Port *float64 + ProductSpecCode *string + SSLEnable *bool + SecurityGroupName *string + Status *string + SubnetName *string + UsedStorageSpace *float64 + VPCName *string + func (in *KafkaInstanceObservation) DeepCopy() *KafkaInstanceObservation + func (in *KafkaInstanceObservation) DeepCopyInto(out *KafkaInstanceObservation) + type KafkaInstanceParameters struct + AccessUser *string + AvailabilityZones []*string + Bandwidth *string + Description *string + EnableAutoTopic *bool + EngineVersion *string + MaintainBegin *string + MaintainEnd *string + ManagerPasswordSecretRef *v1.SecretKeySelector + ManagerUser *string + Name *string + NetworkID *string + NetworkIDRef *v1.Reference + NetworkIDSelector *v1.Selector + PasswordSecretRef *v1.SecretKeySelector + ProductID *string + Region *string + SecurityGroupID *string + SecurityGroupIDRef *v1.Reference + SecurityGroupIDSelector *v1.Selector + StorageSpace *float64 + StorageSpecCode *string + VPCID *string + VPCIDRef *v1.Reference + VPCIDSelector *v1.Selector + func (in *KafkaInstanceParameters) DeepCopy() *KafkaInstanceParameters + func (in *KafkaInstanceParameters) DeepCopyInto(out *KafkaInstanceParameters) + type KafkaInstanceSpec struct + ForProvider KafkaInstanceParameters + func (in *KafkaInstanceSpec) DeepCopy() *KafkaInstanceSpec + func (in *KafkaInstanceSpec) DeepCopyInto(out *KafkaInstanceSpec) + type KafkaInstanceStatus struct + AtProvider KafkaInstanceObservation + func (in *KafkaInstanceStatus) DeepCopy() *KafkaInstanceStatus + func (in *KafkaInstanceStatus) DeepCopyInto(out *KafkaInstanceStatus) + type KafkaTopic struct + Spec KafkaTopicSpec + Status KafkaTopicStatus + func (in *KafkaTopic) DeepCopy() *KafkaTopic + func (in *KafkaTopic) DeepCopyInto(out *KafkaTopic) + func (in *KafkaTopic) DeepCopyObject() runtime.Object + func (mg *KafkaTopic) GetCondition(ct xpv1.ConditionType) xpv1.Condition + func (mg *KafkaTopic) GetDeletionPolicy() xpv1.DeletionPolicy + func (mg *KafkaTopic) GetProviderConfigReference() *xpv1.Reference + func (mg *KafkaTopic) GetProviderReference() *xpv1.Reference + func (mg *KafkaTopic) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo + func (mg *KafkaTopic) GetTerraformResourceType() string + func (mg *KafkaTopic) GetWriteConnectionSecretToReference() *xpv1.SecretReference + func (mg *KafkaTopic) ResolveReferences(ctx context.Context, c client.Reader) error + func (mg *KafkaTopic) SetConditions(c ...xpv1.Condition) + func (mg *KafkaTopic) SetDeletionPolicy(r xpv1.DeletionPolicy) + func (mg *KafkaTopic) SetProviderConfigReference(r *xpv1.Reference) + func (mg *KafkaTopic) SetProviderReference(r *xpv1.Reference) + func (mg *KafkaTopic) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo) + func (mg *KafkaTopic) SetWriteConnectionSecretToReference(r *xpv1.SecretReference) + func (tr *KafkaTopic) GetConnectionDetailsMapping() map[string]string + func (tr *KafkaTopic) GetID() string + func (tr *KafkaTopic) GetObservation() (map[string]any, error) + func (tr *KafkaTopic) GetParameters() (map[string]any, error) + func (tr *KafkaTopic) GetTerraformSchemaVersion() int + func (tr *KafkaTopic) LateInitialize(attrs []byte) (bool, error) + func (tr *KafkaTopic) SetObservation(obs map[string]any) error + func (tr *KafkaTopic) SetParameters(params map[string]any) error + type KafkaTopicList struct + Items []KafkaTopic + func (in *KafkaTopicList) DeepCopy() *KafkaTopicList + func (in *KafkaTopicList) DeepCopyInto(out *KafkaTopicList) + func (in *KafkaTopicList) DeepCopyObject() runtime.Object + func (l *KafkaTopicList) GetItems() []resource.Managed + type KafkaTopicObservation struct + ID *string + func (in *KafkaTopicObservation) DeepCopy() *KafkaTopicObservation + func (in *KafkaTopicObservation) DeepCopyInto(out *KafkaTopicObservation) + type KafkaTopicParameters struct + AgingTime *float64 + InstanceID *string + InstanceIDRef *v1.Reference + InstanceIDSelector *v1.Selector + Name *string + Partitions *float64 + Region *string + Replicas *float64 + SyncFlushing *bool + SyncReplication *bool + func (in *KafkaTopicParameters) DeepCopy() *KafkaTopicParameters + func (in *KafkaTopicParameters) DeepCopyInto(out *KafkaTopicParameters) + type KafkaTopicSpec struct + ForProvider KafkaTopicParameters + func (in *KafkaTopicSpec) DeepCopy() *KafkaTopicSpec + func (in *KafkaTopicSpec) DeepCopyInto(out *KafkaTopicSpec) + type KafkaTopicStatus struct + AtProvider KafkaTopicObservation + func (in *KafkaTopicStatus) DeepCopy() *KafkaTopicStatus + func (in *KafkaTopicStatus) DeepCopyInto(out *KafkaTopicStatus) + type KafkaUser struct + Spec KafkaUserSpec + Status KafkaUserStatus + func (in *KafkaUser) DeepCopy() *KafkaUser + func (in *KafkaUser) DeepCopyInto(out *KafkaUser) + func (in *KafkaUser) DeepCopyObject() runtime.Object + func (mg *KafkaUser) GetCondition(ct xpv1.ConditionType) xpv1.Condition + func (mg *KafkaUser) GetDeletionPolicy() xpv1.DeletionPolicy + func (mg *KafkaUser) GetProviderConfigReference() *xpv1.Reference + func (mg *KafkaUser) GetProviderReference() *xpv1.Reference + func (mg *KafkaUser) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo + func (mg *KafkaUser) GetTerraformResourceType() string + func (mg *KafkaUser) GetWriteConnectionSecretToReference() *xpv1.SecretReference + func (mg *KafkaUser) ResolveReferences(ctx context.Context, c client.Reader) error + func (mg *KafkaUser) SetConditions(c ...xpv1.Condition) + func (mg *KafkaUser) SetDeletionPolicy(r xpv1.DeletionPolicy) + func (mg *KafkaUser) SetProviderConfigReference(r *xpv1.Reference) + func (mg *KafkaUser) SetProviderReference(r *xpv1.Reference) + func (mg *KafkaUser) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo) + func (mg *KafkaUser) SetWriteConnectionSecretToReference(r *xpv1.SecretReference) + func (tr *KafkaUser) GetConnectionDetailsMapping() map[string]string + func (tr *KafkaUser) GetID() string + func (tr *KafkaUser) GetObservation() (map[string]any, error) + func (tr *KafkaUser) GetParameters() (map[string]any, error) + func (tr *KafkaUser) GetTerraformSchemaVersion() int + func (tr *KafkaUser) LateInitialize(attrs []byte) (bool, error) + func (tr *KafkaUser) SetObservation(obs map[string]any) error + func (tr *KafkaUser) SetParameters(params map[string]any) error + type KafkaUserList struct + Items []KafkaUser + func (in *KafkaUserList) DeepCopy() *KafkaUserList + func (in *KafkaUserList) DeepCopyInto(out *KafkaUserList) + func (in *KafkaUserList) DeepCopyObject() runtime.Object + func (l *KafkaUserList) GetItems() []resource.Managed + type KafkaUserObservation struct + ID *string + func (in *KafkaUserObservation) DeepCopy() *KafkaUserObservation + func (in *KafkaUserObservation) DeepCopyInto(out *KafkaUserObservation) + type KafkaUserParameters struct + InstanceID *string + InstanceIDRef *v1.Reference + InstanceIDSelector *v1.Selector + Name *string + PasswordSecretRef v1.SecretKeySelector + Region *string + func (in *KafkaUserParameters) DeepCopy() *KafkaUserParameters + func (in *KafkaUserParameters) DeepCopyInto(out *KafkaUserParameters) + type KafkaUserSpec struct + ForProvider KafkaUserParameters + func (in *KafkaUserSpec) DeepCopy() *KafkaUserSpec + func (in *KafkaUserSpec) DeepCopyInto(out *KafkaUserSpec) + type KafkaUserStatus struct + AtProvider KafkaUserObservation + func (in *KafkaUserStatus) DeepCopy() *KafkaUserStatus + func (in *KafkaUserStatus) DeepCopyInto(out *KafkaUserStatus) + type RocketMQConsumerGroup struct + Spec RocketMQConsumerGroupSpec + Status RocketMQConsumerGroupStatus + func (in *RocketMQConsumerGroup) DeepCopy() *RocketMQConsumerGroup + func (in *RocketMQConsumerGroup) DeepCopyInto(out *RocketMQConsumerGroup) + func (in *RocketMQConsumerGroup) DeepCopyObject() runtime.Object + func (mg *RocketMQConsumerGroup) GetCondition(ct xpv1.ConditionType) xpv1.Condition + func (mg *RocketMQConsumerGroup) GetDeletionPolicy() xpv1.DeletionPolicy + func (mg *RocketMQConsumerGroup) GetProviderConfigReference() *xpv1.Reference + func (mg *RocketMQConsumerGroup) GetProviderReference() *xpv1.Reference + func (mg *RocketMQConsumerGroup) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo + func (mg *RocketMQConsumerGroup) GetTerraformResourceType() string + func (mg *RocketMQConsumerGroup) GetWriteConnectionSecretToReference() *xpv1.SecretReference + func (mg *RocketMQConsumerGroup) ResolveReferences(ctx context.Context, c client.Reader) error + func (mg *RocketMQConsumerGroup) SetConditions(c ...xpv1.Condition) + func (mg *RocketMQConsumerGroup) SetDeletionPolicy(r xpv1.DeletionPolicy) + func (mg *RocketMQConsumerGroup) SetProviderConfigReference(r *xpv1.Reference) + func (mg *RocketMQConsumerGroup) SetProviderReference(r *xpv1.Reference) + func (mg *RocketMQConsumerGroup) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo) + func (mg *RocketMQConsumerGroup) SetWriteConnectionSecretToReference(r *xpv1.SecretReference) + func (tr *RocketMQConsumerGroup) GetConnectionDetailsMapping() map[string]string + func (tr *RocketMQConsumerGroup) GetID() string + func (tr *RocketMQConsumerGroup) GetObservation() (map[string]any, error) + func (tr *RocketMQConsumerGroup) GetParameters() (map[string]any, error) + func (tr *RocketMQConsumerGroup) GetTerraformSchemaVersion() int + func (tr *RocketMQConsumerGroup) LateInitialize(attrs []byte) (bool, error) + func (tr *RocketMQConsumerGroup) SetObservation(obs map[string]any) error + func (tr *RocketMQConsumerGroup) SetParameters(params map[string]any) error + type RocketMQConsumerGroupList struct + Items []RocketMQConsumerGroup + func (in *RocketMQConsumerGroupList) DeepCopy() *RocketMQConsumerGroupList + func (in *RocketMQConsumerGroupList) DeepCopyInto(out *RocketMQConsumerGroupList) + func (in *RocketMQConsumerGroupList) DeepCopyObject() runtime.Object + func (l *RocketMQConsumerGroupList) GetItems() []resource.Managed + type RocketMQConsumerGroupObservation struct + ID *string + func (in *RocketMQConsumerGroupObservation) DeepCopy() *RocketMQConsumerGroupObservation + func (in *RocketMQConsumerGroupObservation) DeepCopyInto(out *RocketMQConsumerGroupObservation) + type RocketMQConsumerGroupParameters struct + Broadcast *bool + Brokers []*string + Enabled *bool + InstanceID *string + InstanceIDRef *v1.Reference + InstanceIDSelector *v1.Selector + Name *string + Region *string + RetryMaxTimes *float64 + func (in *RocketMQConsumerGroupParameters) DeepCopy() *RocketMQConsumerGroupParameters + func (in *RocketMQConsumerGroupParameters) DeepCopyInto(out *RocketMQConsumerGroupParameters) + type RocketMQConsumerGroupSpec struct + ForProvider RocketMQConsumerGroupParameters + func (in *RocketMQConsumerGroupSpec) DeepCopy() *RocketMQConsumerGroupSpec + func (in *RocketMQConsumerGroupSpec) DeepCopyInto(out *RocketMQConsumerGroupSpec) + type RocketMQConsumerGroupStatus struct + AtProvider RocketMQConsumerGroupObservation + func (in *RocketMQConsumerGroupStatus) DeepCopy() *RocketMQConsumerGroupStatus + func (in *RocketMQConsumerGroupStatus) DeepCopyInto(out *RocketMQConsumerGroupStatus) + type RocketMQInstance struct + Spec RocketMQInstanceSpec + Status RocketMQInstanceStatus + func (in *RocketMQInstance) DeepCopy() *RocketMQInstance + func (in *RocketMQInstance) DeepCopyInto(out *RocketMQInstance) + func (in *RocketMQInstance) DeepCopyObject() runtime.Object + func (mg *RocketMQInstance) GetCondition(ct xpv1.ConditionType) xpv1.Condition + func (mg *RocketMQInstance) GetDeletionPolicy() xpv1.DeletionPolicy + func (mg *RocketMQInstance) GetProviderConfigReference() *xpv1.Reference + func (mg *RocketMQInstance) GetProviderReference() *xpv1.Reference + func (mg *RocketMQInstance) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo + func (mg *RocketMQInstance) GetTerraformResourceType() string + func (mg *RocketMQInstance) GetWriteConnectionSecretToReference() *xpv1.SecretReference + func (mg *RocketMQInstance) ResolveReferences(ctx context.Context, c client.Reader) error + func (mg *RocketMQInstance) SetConditions(c ...xpv1.Condition) + func (mg *RocketMQInstance) SetDeletionPolicy(r xpv1.DeletionPolicy) + func (mg *RocketMQInstance) SetProviderConfigReference(r *xpv1.Reference) + func (mg *RocketMQInstance) SetProviderReference(r *xpv1.Reference) + func (mg *RocketMQInstance) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo) + func (mg *RocketMQInstance) SetWriteConnectionSecretToReference(r *xpv1.SecretReference) + func (tr *RocketMQInstance) GetConnectionDetailsMapping() map[string]string + func (tr *RocketMQInstance) GetID() string + func (tr *RocketMQInstance) GetObservation() (map[string]any, error) + func (tr *RocketMQInstance) GetParameters() (map[string]any, error) + func (tr *RocketMQInstance) GetTerraformSchemaVersion() int + func (tr *RocketMQInstance) LateInitialize(attrs []byte) (bool, error) + func (tr *RocketMQInstance) SetObservation(obs map[string]any) error + func (tr *RocketMQInstance) SetParameters(params map[string]any) error + type RocketMQInstanceList struct + Items []RocketMQInstance + func (in *RocketMQInstanceList) DeepCopy() *RocketMQInstanceList + func (in *RocketMQInstanceList) DeepCopyInto(out *RocketMQInstanceList) + func (in *RocketMQInstanceList) DeepCopyObject() runtime.Object + func (l *RocketMQInstanceList) GetItems() []resource.Managed + type RocketMQInstanceObservation struct + BrokerAddress *string + CrossVPCAccesses []CrossVPCAccessesObservation + ID *string + MaintainBegin *string + MaintainEnd *string + NamesrvAddress *string + NewSpecBillingEnable *bool + NodeNum *float64 + PublicBrokerAddress *string + PublicNamesrvAddress *string + PublicipAddress *string + ResourceSpecCode *string + Specification *string + Status *string + Type *string + UsedStorageSpace *float64 + func (in *RocketMQInstanceObservation) DeepCopy() *RocketMQInstanceObservation + func (in *RocketMQInstanceObservation) DeepCopyInto(out *RocketMQInstanceObservation) + type RocketMQInstanceParameters struct + AvailabilityZones []*string + BrokerNum *float64 + CrossVPCAccesses []CrossVPCAccessesParameters + Description *string + EnableACL *bool + EnablePublicip *bool + EngineVersion *string + EnterpriseProjectID *string + FlavorID *string + IPv6Enable *bool + Name *string + PublicipID *string + PublicipIDRef *v1.Reference + PublicipIDSelector *v1.Selector + Region *string + RetentionPolicy *bool + SSLEnable *bool + SecurityGroupID *string + SecurityGroupIDRef *v1.Reference + SecurityGroupIDSelector *v1.Selector + StorageSpace *float64 + StorageSpecCode *string + SubnetID *string + SubnetIDRef *v1.Reference + SubnetIDSelector *v1.Selector + VPCID *string + VPCIDRef *v1.Reference + VPCIDSelector *v1.Selector + func (in *RocketMQInstanceParameters) DeepCopy() *RocketMQInstanceParameters + func (in *RocketMQInstanceParameters) DeepCopyInto(out *RocketMQInstanceParameters) + type RocketMQInstanceSpec struct + ForProvider RocketMQInstanceParameters + func (in *RocketMQInstanceSpec) DeepCopy() *RocketMQInstanceSpec + func (in *RocketMQInstanceSpec) DeepCopyInto(out *RocketMQInstanceSpec) + type RocketMQInstanceStatus struct + AtProvider RocketMQInstanceObservation + func (in *RocketMQInstanceStatus) DeepCopy() *RocketMQInstanceStatus + func (in *RocketMQInstanceStatus) DeepCopyInto(out *RocketMQInstanceStatus) + type RocketMQTopic struct + Spec RocketMQTopicSpec + Status RocketMQTopicStatus + func (in *RocketMQTopic) DeepCopy() *RocketMQTopic + func (in *RocketMQTopic) DeepCopyInto(out *RocketMQTopic) + func (in *RocketMQTopic) DeepCopyObject() runtime.Object + func (mg *RocketMQTopic) GetCondition(ct xpv1.ConditionType) xpv1.Condition + func (mg *RocketMQTopic) GetDeletionPolicy() xpv1.DeletionPolicy + func (mg *RocketMQTopic) GetProviderConfigReference() *xpv1.Reference + func (mg *RocketMQTopic) GetProviderReference() *xpv1.Reference + func (mg *RocketMQTopic) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo + func (mg *RocketMQTopic) GetTerraformResourceType() string + func (mg *RocketMQTopic) GetWriteConnectionSecretToReference() *xpv1.SecretReference + func (mg *RocketMQTopic) ResolveReferences(ctx context.Context, c client.Reader) error + func (mg *RocketMQTopic) SetConditions(c ...xpv1.Condition) + func (mg *RocketMQTopic) SetDeletionPolicy(r xpv1.DeletionPolicy) + func (mg *RocketMQTopic) SetProviderConfigReference(r *xpv1.Reference) + func (mg *RocketMQTopic) SetProviderReference(r *xpv1.Reference) + func (mg *RocketMQTopic) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo) + func (mg *RocketMQTopic) SetWriteConnectionSecretToReference(r *xpv1.SecretReference) + func (tr *RocketMQTopic) GetConnectionDetailsMapping() map[string]string + func (tr *RocketMQTopic) GetID() string + func (tr *RocketMQTopic) GetObservation() (map[string]any, error) + func (tr *RocketMQTopic) GetParameters() (map[string]any, error) + func (tr *RocketMQTopic) GetTerraformSchemaVersion() int + func (tr *RocketMQTopic) LateInitialize(attrs []byte) (bool, error) + func (tr *RocketMQTopic) SetObservation(obs map[string]any) error + func (tr *RocketMQTopic) SetParameters(params map[string]any) error + type RocketMQTopicList struct + Items []RocketMQTopic + func (in *RocketMQTopicList) DeepCopy() *RocketMQTopicList + func (in *RocketMQTopicList) DeepCopyInto(out *RocketMQTopicList) + func (in *RocketMQTopicList) DeepCopyObject() runtime.Object + func (l *RocketMQTopicList) GetItems() []resource.Managed + type RocketMQTopicObservation struct + Brokers []BrokersObservation + ID *string + func (in *RocketMQTopicObservation) DeepCopy() *RocketMQTopicObservation + func (in *RocketMQTopicObservation) DeepCopyInto(out *RocketMQTopicObservation) + type RocketMQTopicParameters struct + Brokers []BrokersParameters + InstanceID *string + InstanceIDRef *v1.Reference + InstanceIDSelector *v1.Selector + Name *string + Permission *string + QueueNum *float64 + Region *string + TotalReadQueueNum *float64 + TotalWriteQueueNum *float64 + func (in *RocketMQTopicParameters) DeepCopy() *RocketMQTopicParameters + func (in *RocketMQTopicParameters) DeepCopyInto(out *RocketMQTopicParameters) + type RocketMQTopicSpec struct + ForProvider RocketMQTopicParameters + func (in *RocketMQTopicSpec) DeepCopy() *RocketMQTopicSpec + func (in *RocketMQTopicSpec) DeepCopyInto(out *RocketMQTopicSpec) + type RocketMQTopicStatus struct + AtProvider RocketMQTopicObservation + func (in *RocketMQTopicStatus) DeepCopy() *RocketMQTopicStatus + func (in *RocketMQTopicStatus) DeepCopyInto(out *RocketMQTopicStatus) + type RocketMQUser struct + Spec RocketMQUserSpec + Status RocketMQUserStatus + func (in *RocketMQUser) DeepCopy() *RocketMQUser + func (in *RocketMQUser) DeepCopyInto(out *RocketMQUser) + func (in *RocketMQUser) DeepCopyObject() runtime.Object + func (mg *RocketMQUser) GetCondition(ct xpv1.ConditionType) xpv1.Condition + func (mg *RocketMQUser) GetDeletionPolicy() xpv1.DeletionPolicy + func (mg *RocketMQUser) GetProviderConfigReference() *xpv1.Reference + func (mg *RocketMQUser) GetProviderReference() *xpv1.Reference + func (mg *RocketMQUser) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo + func (mg *RocketMQUser) GetTerraformResourceType() string + func (mg *RocketMQUser) GetWriteConnectionSecretToReference() *xpv1.SecretReference + func (mg *RocketMQUser) ResolveReferences(ctx context.Context, c client.Reader) error + func (mg *RocketMQUser) SetConditions(c ...xpv1.Condition) + func (mg *RocketMQUser) SetDeletionPolicy(r xpv1.DeletionPolicy) + func (mg *RocketMQUser) SetProviderConfigReference(r *xpv1.Reference) + func (mg *RocketMQUser) SetProviderReference(r *xpv1.Reference) + func (mg *RocketMQUser) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo) + func (mg *RocketMQUser) SetWriteConnectionSecretToReference(r *xpv1.SecretReference) + func (tr *RocketMQUser) GetConnectionDetailsMapping() map[string]string + func (tr *RocketMQUser) GetID() string + func (tr *RocketMQUser) GetObservation() (map[string]any, error) + func (tr *RocketMQUser) GetParameters() (map[string]any, error) + func (tr *RocketMQUser) GetTerraformSchemaVersion() int + func (tr *RocketMQUser) LateInitialize(attrs []byte) (bool, error) + func (tr *RocketMQUser) SetObservation(obs map[string]any) error + func (tr *RocketMQUser) SetParameters(params map[string]any) error + type RocketMQUserList struct + Items []RocketMQUser + func (in *RocketMQUserList) DeepCopy() *RocketMQUserList + func (in *RocketMQUserList) DeepCopyInto(out *RocketMQUserList) + func (in *RocketMQUserList) DeepCopyObject() runtime.Object + func (l *RocketMQUserList) GetItems() []resource.Managed + type RocketMQUserObservation struct + ID *string + func (in *RocketMQUserObservation) DeepCopy() *RocketMQUserObservation + func (in *RocketMQUserObservation) DeepCopyInto(out *RocketMQUserObservation) + type RocketMQUserParameters struct + AccessKey *string + Admin *bool + DefaultGroupPerm *string + DefaultTopicPerm *string + GroupPerms []GroupPermsParameters + InstanceID *string + InstanceIDRef *v1.Reference + InstanceIDSelector *v1.Selector + Region *string + SecretKey *string + TopicPerms []TopicPermsParameters + WhiteRemoteAddress *string + func (in *RocketMQUserParameters) DeepCopy() *RocketMQUserParameters + func (in *RocketMQUserParameters) DeepCopyInto(out *RocketMQUserParameters) + type RocketMQUserSpec struct + ForProvider RocketMQUserParameters + func (in *RocketMQUserSpec) DeepCopy() *RocketMQUserSpec + func (in *RocketMQUserSpec) DeepCopyInto(out *RocketMQUserSpec) + type RocketMQUserStatus struct + AtProvider RocketMQUserObservation + func (in *RocketMQUserStatus) DeepCopy() *RocketMQUserStatus + func (in *RocketMQUserStatus) DeepCopyInto(out *RocketMQUserStatus) + type TopicPermsObservation struct + func (in *TopicPermsObservation) DeepCopy() *TopicPermsObservation + func (in *TopicPermsObservation) DeepCopyInto(out *TopicPermsObservation) + type TopicPermsParameters struct + Name *string + NameRef *v1.Reference + NameSelector *v1.Selector + Perm *string + func (in *TopicPermsParameters) DeepCopy() *TopicPermsParameters + func (in *TopicPermsParameters) DeepCopyInto(out *TopicPermsParameters)
Go to main page