v1alpha1

package
v0.5.0 Latest Latest
Warning

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

Go to latest
Published: May 8, 2022 License: Apache-2.0 Imports: 14 Imported by: 2

Documentation

Overview

+groupName=alikafka.alicloud.kubeform.com

Index

Constants

This section is empty.

Variables

View Source
var (
	// TODO: move SchemeBuilder with zz_generated.deepcopy.go to k8s.io/api.
	// localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes.
	SchemeBuilder runtime.SchemeBuilder

	AddToScheme = localSchemeBuilder.AddToScheme
)
View Source
var SchemeGroupVersion = schema.GroupVersion{Group: alikafka.GroupName, Version: "v1alpha1"}

Functions

func GetDecoder

func GetDecoder() map[string]jsoniter.ValDecoder

func GetEncoder

func GetEncoder() map[string]jsoniter.ValEncoder

func Kind

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns a Group qualified GroupKind

func Resource

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type ConsumerGroup

type ConsumerGroup struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ConsumerGroupSpec   `json:"spec,omitempty"`
	Status            ConsumerGroupStatus `json:"status,omitempty"`
}

func (*ConsumerGroup) DeepCopy

func (in *ConsumerGroup) DeepCopy() *ConsumerGroup

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

func (*ConsumerGroup) DeepCopyInto

func (in *ConsumerGroup) DeepCopyInto(out *ConsumerGroup)

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

func (*ConsumerGroup) DeepCopyObject

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

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

func (*ConsumerGroup) SetupWebhookWithManager

func (r *ConsumerGroup) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*ConsumerGroup) ValidateCreate

func (r *ConsumerGroup) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*ConsumerGroup) ValidateDelete

func (r *ConsumerGroup) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*ConsumerGroup) ValidateUpdate

func (r *ConsumerGroup) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type ConsumerGroupList

type ConsumerGroupList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of ConsumerGroup CRD objects
	Items []ConsumerGroup `json:"items,omitempty"`
}

ConsumerGroupList is a list of ConsumerGroups

func (*ConsumerGroupList) DeepCopy

func (in *ConsumerGroupList) DeepCopy() *ConsumerGroupList

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

func (*ConsumerGroupList) DeepCopyInto

func (in *ConsumerGroupList) DeepCopyInto(out *ConsumerGroupList)

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

func (*ConsumerGroupList) DeepCopyObject

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

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

type ConsumerGroupSpec

type ConsumerGroupSpec struct {
	State *ConsumerGroupSpecResource `json:"state,omitempty" tf:"-"`

	Resource ConsumerGroupSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*ConsumerGroupSpec) DeepCopy

func (in *ConsumerGroupSpec) DeepCopy() *ConsumerGroupSpec

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

func (*ConsumerGroupSpec) DeepCopyInto

func (in *ConsumerGroupSpec) DeepCopyInto(out *ConsumerGroupSpec)

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

type ConsumerGroupSpecResource

type ConsumerGroupSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	ConsumerID *string `json:"consumerID" tf:"consumer_id"`
	// +optional
	Description *string `json:"description,omitempty" tf:"description"`
	InstanceID  *string `json:"instanceID" tf:"instance_id"`
	// +optional
	Tags map[string]string `json:"tags,omitempty" tf:"tags"`
}

func (*ConsumerGroupSpecResource) DeepCopy

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

func (*ConsumerGroupSpecResource) DeepCopyInto

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

type ConsumerGroupStatus

type ConsumerGroupStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*ConsumerGroupStatus) DeepCopy

func (in *ConsumerGroupStatus) DeepCopy() *ConsumerGroupStatus

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

func (*ConsumerGroupStatus) DeepCopyInto

func (in *ConsumerGroupStatus) DeepCopyInto(out *ConsumerGroupStatus)

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,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              InstanceSpec   `json:"spec,omitempty"`
	Status            InstanceStatus `json:"status,omitempty"`
}

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

func (r *Instance) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Instance) ValidateCreate

func (r *Instance) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Instance) ValidateDelete

func (r *Instance) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*Instance) ValidateUpdate

func (r *Instance) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type InstanceList

type InstanceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of Instance CRD objects
	Items []Instance `json:"items,omitempty"`
}

InstanceList is 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.

type InstanceSpec

type InstanceSpec struct {
	State *InstanceSpecResource `json:"state,omitempty" tf:"-"`

	Resource InstanceSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

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 InstanceSpecResource

type InstanceSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// +optional
	Config     *string `json:"config,omitempty" tf:"config"`
	DeployType *int64  `json:"deployType" tf:"deploy_type"`
	DiskSize   *int64  `json:"diskSize" tf:"disk_size"`
	DiskType   *int64  `json:"diskType" tf:"disk_type"`
	// +optional
	EipMax *int64 `json:"eipMax,omitempty" tf:"eip_max"`
	// +optional
	EndPoint *string `json:"endPoint,omitempty" tf:"end_point"`
	IoMax    *int64  `json:"ioMax" tf:"io_max"`
	// +optional
	Name *string `json:"name,omitempty" tf:"name"`
	// +optional
	PaidType *string `json:"paidType,omitempty" tf:"paid_type"`
	// +optional
	SecurityGroup *string `json:"securityGroup,omitempty" tf:"security_group"`
	// +optional
	ServiceVersion *string `json:"serviceVersion,omitempty" tf:"service_version"`
	// +optional
	SpecType *string `json:"specType,omitempty" tf:"spec_type"`
	// +optional
	Tags       map[string]string `json:"tags,omitempty" tf:"tags"`
	TopicQuota *int64            `json:"topicQuota" tf:"topic_quota"`
	// +optional
	VpcID     *string `json:"vpcID,omitempty" tf:"vpc_id"`
	VswitchID *string `json:"vswitchID" tf:"vswitch_id"`
	// +optional
	ZoneID *string `json:"zoneID,omitempty" tf:"zone_id"`
}

func (*InstanceSpecResource) DeepCopy

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

func (*InstanceSpecResource) DeepCopyInto

func (in *InstanceSpecResource) DeepCopyInto(out *InstanceSpecResource)

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

type InstanceStatus

type InstanceStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

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 SaslACL

type SaslACL struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              SaslACLSpec   `json:"spec,omitempty"`
	Status            SaslACLStatus `json:"status,omitempty"`
}

func (*SaslACL) DeepCopy

func (in *SaslACL) DeepCopy() *SaslACL

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

func (*SaslACL) DeepCopyInto

func (in *SaslACL) DeepCopyInto(out *SaslACL)

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

func (*SaslACL) DeepCopyObject

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

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

func (*SaslACL) SetupWebhookWithManager

func (r *SaslACL) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*SaslACL) ValidateCreate

func (r *SaslACL) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*SaslACL) ValidateDelete

func (r *SaslACL) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*SaslACL) ValidateUpdate

func (r *SaslACL) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type SaslACLList

type SaslACLList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of SaslACL CRD objects
	Items []SaslACL `json:"items,omitempty"`
}

SaslACLList is a list of SaslACLs

func (*SaslACLList) DeepCopy

func (in *SaslACLList) DeepCopy() *SaslACLList

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

func (*SaslACLList) DeepCopyInto

func (in *SaslACLList) DeepCopyInto(out *SaslACLList)

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

func (*SaslACLList) DeepCopyObject

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

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

type SaslACLSpec

type SaslACLSpec struct {
	State *SaslACLSpecResource `json:"state,omitempty" tf:"-"`

	Resource SaslACLSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*SaslACLSpec) DeepCopy

func (in *SaslACLSpec) DeepCopy() *SaslACLSpec

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

func (*SaslACLSpec) DeepCopyInto

func (in *SaslACLSpec) DeepCopyInto(out *SaslACLSpec)

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

type SaslACLSpecResource

type SaslACLSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	AclOperationType       *string `json:"aclOperationType" tf:"acl_operation_type"`
	AclResourceName        *string `json:"aclResourceName" tf:"acl_resource_name"`
	AclResourcePatternType *string `json:"aclResourcePatternType" tf:"acl_resource_pattern_type"`
	AclResourceType        *string `json:"aclResourceType" tf:"acl_resource_type"`
	// +optional
	Host       *string `json:"host,omitempty" tf:"host"`
	InstanceID *string `json:"instanceID" tf:"instance_id"`
	Username   *string `json:"username" tf:"username"`
}

func (*SaslACLSpecResource) DeepCopy

func (in *SaslACLSpecResource) DeepCopy() *SaslACLSpecResource

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

func (*SaslACLSpecResource) DeepCopyInto

func (in *SaslACLSpecResource) DeepCopyInto(out *SaslACLSpecResource)

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

type SaslACLStatus

type SaslACLStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*SaslACLStatus) DeepCopy

func (in *SaslACLStatus) DeepCopy() *SaslACLStatus

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

func (*SaslACLStatus) DeepCopyInto

func (in *SaslACLStatus) DeepCopyInto(out *SaslACLStatus)

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

type SaslUser

type SaslUser struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              SaslUserSpec   `json:"spec,omitempty"`
	Status            SaslUserStatus `json:"status,omitempty"`
}

func (*SaslUser) DeepCopy

func (in *SaslUser) DeepCopy() *SaslUser

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

func (*SaslUser) DeepCopyInto

func (in *SaslUser) DeepCopyInto(out *SaslUser)

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

func (*SaslUser) DeepCopyObject

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

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

func (*SaslUser) SetupWebhookWithManager

func (r *SaslUser) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*SaslUser) ValidateCreate

func (r *SaslUser) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*SaslUser) ValidateDelete

func (r *SaslUser) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*SaslUser) ValidateUpdate

func (r *SaslUser) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type SaslUserList

type SaslUserList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of SaslUser CRD objects
	Items []SaslUser `json:"items,omitempty"`
}

SaslUserList is a list of SaslUsers

func (*SaslUserList) DeepCopy

func (in *SaslUserList) DeepCopy() *SaslUserList

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

func (*SaslUserList) DeepCopyInto

func (in *SaslUserList) DeepCopyInto(out *SaslUserList)

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

func (*SaslUserList) DeepCopyObject

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

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

type SaslUserSpec

type SaslUserSpec struct {
	State *SaslUserSpecResource `json:"state,omitempty" tf:"-"`

	Resource SaslUserSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	SecretRef *core.LocalObjectReference `json:"secretRef,omitempty" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*SaslUserSpec) DeepCopy

func (in *SaslUserSpec) DeepCopy() *SaslUserSpec

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

func (*SaslUserSpec) DeepCopyInto

func (in *SaslUserSpec) DeepCopyInto(out *SaslUserSpec)

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

type SaslUserSpecResource

type SaslUserSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	InstanceID *string `json:"instanceID" tf:"instance_id"`
	// +optional
	KmsEncryptedPassword *string `json:"kmsEncryptedPassword,omitempty" tf:"kms_encrypted_password"`
	// +optional
	KmsEncryptionContext map[string]string `json:"kmsEncryptionContext,omitempty" tf:"kms_encryption_context"`
	// +optional
	Password *string `json:"-" sensitive:"true" tf:"password"`
	// +optional
	Type     *string `json:"type,omitempty" tf:"type"`
	Username *string `json:"username" tf:"username"`
}

func (*SaslUserSpecResource) DeepCopy

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

func (*SaslUserSpecResource) DeepCopyInto

func (in *SaslUserSpecResource) DeepCopyInto(out *SaslUserSpecResource)

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

type SaslUserStatus

type SaslUserStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*SaslUserStatus) DeepCopy

func (in *SaslUserStatus) DeepCopy() *SaslUserStatus

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

func (*SaslUserStatus) DeepCopyInto

func (in *SaslUserStatus) DeepCopyInto(out *SaslUserStatus)

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,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              TopicSpec   `json:"spec,omitempty"`
	Status            TopicStatus `json:"status,omitempty"`
}

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

func (r *Topic) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Topic) ValidateCreate

func (r *Topic) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Topic) ValidateDelete

func (r *Topic) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*Topic) ValidateUpdate

func (r *Topic) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type TopicList

type TopicList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of Topic CRD objects
	Items []Topic `json:"items,omitempty"`
}

TopicList is 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.

type TopicSpec

type TopicSpec struct {
	State *TopicSpecResource `json:"state,omitempty" tf:"-"`

	Resource TopicSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

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 TopicSpecResource

type TopicSpecResource struct {
	Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"`

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

	// +optional
	CompactTopic *bool   `json:"compactTopic,omitempty" tf:"compact_topic"`
	InstanceID   *string `json:"instanceID" tf:"instance_id"`
	// +optional
	LocalTopic *bool `json:"localTopic,omitempty" tf:"local_topic"`
	// +optional
	PartitionNum *int64  `json:"partitionNum,omitempty" tf:"partition_num"`
	Remark       *string `json:"remark" tf:"remark"`
	// +optional
	Tags  map[string]string `json:"tags,omitempty" tf:"tags"`
	Topic *string           `json:"topic" tf:"topic"`
}

func (*TopicSpecResource) DeepCopy

func (in *TopicSpecResource) DeepCopy() *TopicSpecResource

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

func (*TopicSpecResource) DeepCopyInto

func (in *TopicSpecResource) DeepCopyInto(out *TopicSpecResource)

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

type TopicStatus

type TopicStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL