Documentation ¶
Overview ¶
Package v1alpha1 contains API Schema definitions for the rocketmq v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=rocketmq.apache.org
Index ¶
- Variables
- type Broker
- type BrokerList
- type BrokerSpec
- type BrokerStatus
- type Console
- type ConsoleList
- type ConsoleSpec
- type ConsoleStatus
- type Controller
- type ControllerList
- type ControllerSpec
- type ControllerStatus
- type NameService
- type NameServiceList
- type NameServiceSpec
- type NameServiceStatus
- type TopicTransfer
- type TopicTransferList
- type TopicTransferSpec
- type TopicTransferStatus
Constants ¶
This section is empty.
Variables ¶
var ( // GroupVersion is group version used to register these objects GroupVersion = schema.GroupVersion{Group: "rocketmq.apache.org", Version: "v1alpha1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion} // AddToScheme adds the types in this group-version to the given scheme. AddToScheme = SchemeBuilder.AddToScheme )
Functions ¶
This section is empty.
Types ¶
type Broker ¶
type Broker struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec BrokerSpec `json:"spec,omitempty"` Status BrokerStatus `json:"status,omitempty"` }
Broker is the Schema for the brokers API +k8s:openapi-gen=true +kubebuilder:printcolumn:name="Size",type="integer",JSONPath=".spec.size" +kubebuilder:printcolumn:name="Replica-Per-Group",type="integer",JSONPath=".spec.replicaPerGroup" +kubebuilder:printcolumn:name="Allow-Restart",type="boolean",JSONPath=".spec.allowRestart" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status
func (*Broker) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Broker.
func (*Broker) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Broker) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type BrokerList ¶
type BrokerList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Broker `json:"items"` }
BrokerList contains a list of Broker
func (*BrokerList) DeepCopy ¶
func (in *BrokerList) DeepCopy() *BrokerList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerList.
func (*BrokerList) DeepCopyInto ¶
func (in *BrokerList) DeepCopyInto(out *BrokerList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BrokerList) DeepCopyObject ¶
func (in *BrokerList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type BrokerSpec ¶
type BrokerSpec struct { // INSERT ADDITIONAL SPEC FIELDS - desired state of cluster // Important: Run "operator-sdk generate k8s" to regenerate code after modifying this file // Add custom validation using kubebuilder tags: https://book-v1.book.kubebuilder.io/beyond_basics/generating_crd.html // Size of broker clusters Size int `json:"size"` // NameServers defines the name service list e.g. 192.168.1.1:9876;192.168.1.2:9876 NameServers string `json:"nameServers,omitempty"` // ClusterMode defines the way to be a broker cluster, valid values can be one of the following: // - STATIC: default clusters with static broker roles // - CONTROLLER: clusters with DLedger Controller since RocketMQ 5.0 // - CONTAINER: [NOT implemented yet] enabling broker containers since RocketMQ 5.0 ClusterMode string `json:"clusterMode,omitempty"` // ReplicaPerGroup each broker cluster's replica number ReplicaPerGroup int `json:"replicaPerGroup"` // BaseImage is the broker image to use for the Pods BrokerImage string `json:"brokerImage"` // ImagePullPolicy defines how the image is pulled ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy"` // HostNetwork can be true or false HostNetwork bool `json:"hostNetwork,omitempty"` // AllowRestart defines whether allow pod restart AllowRestart bool `json:"allowRestart"` // Resources describes the compute resource requirements Resources corev1.ResourceRequirements `json:"resources"` // StorageMode can be EmptyDir, HostPath, StorageClass StorageMode string `json:"storageMode"` // HostPath is the local path to store data HostPath string `json:"hostPath"` // Env defines custom env, e.g. BROKER_MEM Env []corev1.EnvVar `json:"env"` // Volumes define the broker.conf Volumes []corev1.Volume `json:"volumes"` // VolumeClaimTemplates defines the StorageClass VolumeClaimTemplates []corev1.PersistentVolumeClaim `json:"volumeClaimTemplates"` // The name of pod where the metadata from ScalePodName string `json:"scalePodName"` // Pod Security Context PodSecurityContext *corev1.PodSecurityContext `json:"securityContext,omitempty"` // Container Security Context ContainerSecurityContext *corev1.SecurityContext `json:"containerSecurityContext,omitempty"` // The secrets used to pull image from private registry ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"` // Affinity the pod's scheduling constraints Affinity *corev1.Affinity `json:"affinity,omitempty"` // Tolerations the pod's tolerations. Tolerations []corev1.Toleration `json:"tolerations,omitempty"` // NodeSelector is a selector which must be true for the pod to fit on a node NodeSelector map[string]string `json:"nodeSelector,omitempty"` // PriorityClassName indicates the pod's priority PriorityClassName string `json:"priorityClassName,omitempty"` // ServiceAccountName ServiceAccountName string `json:"serviceAccountName,omitempty"` }
BrokerSpec defines the desired state of Broker +k8s:openapi-gen=true
func (*BrokerSpec) DeepCopy ¶
func (in *BrokerSpec) DeepCopy() *BrokerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerSpec.
func (*BrokerSpec) DeepCopyInto ¶
func (in *BrokerSpec) DeepCopyInto(out *BrokerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerStatus ¶
type BrokerStatus struct { // INSERT ADDITIONAL STATUS FIELD - define observed state of cluster // Important: Run "operator-sdk generate k8s" to regenerate code after modifying this file // Add custom validation using kubebuilder tags: https://book-v1.book.kubebuilder.io/beyond_basics/generating_crd.html Nodes []string `json:"nodes"` Size int `json:"size"` }
BrokerStatus defines the observed state of Broker +k8s:openapi-gen=true
func (*BrokerStatus) DeepCopy ¶
func (in *BrokerStatus) DeepCopy() *BrokerStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerStatus.
func (*BrokerStatus) DeepCopyInto ¶
func (in *BrokerStatus) DeepCopyInto(out *BrokerStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Console ¶
type Console struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ConsoleSpec `json:"spec,omitempty"` Status ConsoleStatus `json:"status,omitempty"` }
Console is the Schema for the consoles API +k8s:openapi-gen=true +kubebuilder:subresource:status +kubebuilder:printcolumn:name="Size",type="integer",JSONPath=".spec.consoleDeployment.spec.replicas" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:path=consoles,scope=Namespaced
func (*Console) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Console.
func (*Console) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Console) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ConsoleList ¶
type ConsoleList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Console `json:"items"` }
ConsoleList contains a list of Console
func (*ConsoleList) DeepCopy ¶
func (in *ConsoleList) DeepCopy() *ConsoleList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConsoleList.
func (*ConsoleList) DeepCopyInto ¶
func (in *ConsoleList) DeepCopyInto(out *ConsoleList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ConsoleList) DeepCopyObject ¶
func (in *ConsoleList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ConsoleSpec ¶
type ConsoleSpec struct { // INSERT ADDITIONAL SPEC FIELDS - desired state of cluster // Important: Run "operator-sdk generate k8s" to regenerate code after modifying this file // Add custom validation using kubebuilder tags: https://book-v1.book.kubebuilder.io/beyond_basics/generating_crd.html ConsoleDeployment v1.Deployment `json:"consoleDeployment"` // NameServers defines the name service list e.g. 192.168.1.1:9876;192.168.1.2:9876 NameServers string `json:"nameServers,omitempty"` }
ConsoleSpec defines the desired state of Console +k8s:openapi-gen=true
func (*ConsoleSpec) DeepCopy ¶
func (in *ConsoleSpec) DeepCopy() *ConsoleSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConsoleSpec.
func (*ConsoleSpec) DeepCopyInto ¶
func (in *ConsoleSpec) DeepCopyInto(out *ConsoleSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConsoleStatus ¶
type ConsoleStatus struct { }
ConsoleStatus defines the observed state of Console +k8s:openapi-gen=true
func (*ConsoleStatus) DeepCopy ¶
func (in *ConsoleStatus) DeepCopy() *ConsoleStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConsoleStatus.
func (*ConsoleStatus) DeepCopyInto ¶
func (in *ConsoleStatus) DeepCopyInto(out *ConsoleStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Controller ¶
type Controller struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ControllerSpec `json:"spec,omitempty"` Status ControllerStatus `json:"status,omitempty"` }
Controller is the Schema for the Controllers API +k8s:openapi-gen=true +kubebuilder:printcolumn:name="Size",type="integer",JSONPath=".spec.size" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status
func (*Controller) DeepCopy ¶
func (in *Controller) DeepCopy() *Controller
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Controller.
func (*Controller) DeepCopyInto ¶
func (in *Controller) DeepCopyInto(out *Controller)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Controller) DeepCopyObject ¶
func (in *Controller) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ControllerList ¶
type ControllerList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Controller `json:"items"` }
ControllerList contains a list of Controller
func (*ControllerList) DeepCopy ¶
func (in *ControllerList) DeepCopy() *ControllerList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ControllerList.
func (*ControllerList) DeepCopyInto ¶
func (in *ControllerList) DeepCopyInto(out *ControllerList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ControllerList) DeepCopyObject ¶
func (in *ControllerList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type ControllerSpec ¶
type ControllerSpec struct { // size of controller Size int `json:"size"` // BaseImage is the controller image to use for the Pods ControllerImage string `json:"controllerImage"` // ImagePullPolicy defines how the image is pulled ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty"` // Resources describes the compute resource requirements Resources corev1.ResourceRequirements `json:"resources"` // StorageMode can be EmptyDir, HostPath, StorageClass StorageMode string `json:"storageMode"` // HostPath is the local path to store data HostPath string `json:"hostPath"` // Env defines custom env Env []corev1.EnvVar `json:"env,omitempty"` // VolumeClaimTemplates defines the StorageClass VolumeClaimTemplates []corev1.PersistentVolumeClaim `json:"volumeClaimTemplates"` // Pod Security Context PodSecurityContext *corev1.PodSecurityContext `json:"securityContext,omitempty"` // Container Security Context ContainerSecurityContext *corev1.SecurityContext `json:"containerSecurityContext,omitempty"` // The secrets used to pull image from private registry ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"` // Affinity the pod's scheduling constraints Affinity *corev1.Affinity `json:"affinity,omitempty"` // Tolerations the pod's tolerations. Tolerations []corev1.Toleration `json:"tolerations,omitempty"` // NodeSelector is a selector which must be true for the pod to fit on a node NodeSelector map[string]string `json:"nodeSelector,omitempty"` // PriorityClassName indicates the pod's priority PriorityClassName string `json:"priorityClassName,omitempty"` // ServiceAccountName ServiceAccountName string `json:"serviceAccountName,omitempty"` }
ControllerSpec defines the desired state of Controller +k8s:openapi-gen=true
func (*ControllerSpec) DeepCopy ¶
func (in *ControllerSpec) DeepCopy() *ControllerSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ControllerSpec.
func (*ControllerSpec) DeepCopyInto ¶
func (in *ControllerSpec) DeepCopyInto(out *ControllerSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ControllerStatus ¶
type ControllerStatus struct { // INSERT ADDITIONAL STATUS FIELD - define observed state of cluster // Important: Run "operator-sdk generate k8s" to regenerate code after modifying this file // Add custom validation using kubebuilder tags: https://book-v1.book.kubebuilder.io/beyond_basics/generating_crd.html Nodes []string `json:"nodes"` Size int `json:"size"` }
ControllerStatus defines the observed state of Controller +k8s:openapi-gen=true
func (*ControllerStatus) DeepCopy ¶
func (in *ControllerStatus) DeepCopy() *ControllerStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ControllerStatus.
func (*ControllerStatus) DeepCopyInto ¶
func (in *ControllerStatus) DeepCopyInto(out *ControllerStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NameService ¶
type NameService struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec NameServiceSpec `json:"spec,omitempty"` Status NameServiceStatus `json:"status,omitempty"` }
NameService is the Schema for the nameservices API +k8s:openapi-gen=true +kubebuilder:printcolumn:name="Size",type="integer",JSONPath=".spec.size" +kubebuilder:printcolumn:name="Host-Network",type="boolean",JSONPath=".spec.hostNetwork" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status
func (*NameService) DeepCopy ¶
func (in *NameService) DeepCopy() *NameService
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NameService.
func (*NameService) DeepCopyInto ¶
func (in *NameService) DeepCopyInto(out *NameService)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NameService) DeepCopyObject ¶
func (in *NameService) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type NameServiceList ¶
type NameServiceList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []NameService `json:"items"` }
NameServiceList contains a list of NameService
func (*NameServiceList) DeepCopy ¶
func (in *NameServiceList) DeepCopy() *NameServiceList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NameServiceList.
func (*NameServiceList) DeepCopyInto ¶
func (in *NameServiceList) DeepCopyInto(out *NameServiceList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NameServiceList) DeepCopyObject ¶
func (in *NameServiceList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type NameServiceSpec ¶
type NameServiceSpec struct { // INSERT ADDITIONAL SPEC FIELDS - desired state of cluster // Important: Run "operator-sdk generate k8s" to regenerate code after modifying this file // Add custom validation using kubebuilder tags: https://book-v1.book.kubebuilder.io/beyond_basics/generating_crd.html // Size is the number of the name service Pod Size int32 `json:"size"` //NameServiceImage is the name service image NameServiceImage string `json:"nameServiceImage"` // ImagePullPolicy defines how the image is pulled. ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy"` // HostNetwork can be true or false HostNetwork bool `json:"hostNetwork"` // dnsPolicy defines how a pod's DNS will be configured DNSPolicy corev1.DNSPolicy `json:"dnsPolicy"` // Resources describes the compute resource requirements Resources corev1.ResourceRequirements `json:"resources"` // StorageMode can be EmptyDir, HostPath, StorageClass StorageMode string `json:"storageMode"` // HostPath is the local path to store data HostPath string `json:"hostPath"` // Env defines custom env, e.g. JAVA_OPT_EXT Env []corev1.EnvVar `json:"env,omitempty"` // VolumeClaimTemplates defines the StorageClass VolumeClaimTemplates []corev1.PersistentVolumeClaim `json:"volumeClaimTemplates"` // Pod Security Context PodSecurityContext *corev1.PodSecurityContext `json:"securityContext,omitempty"` // Container Security Context ContainerSecurityContext *corev1.SecurityContext `json:"containerSecurityContext,omitempty"` // The secrets used to pull image from private registry ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"` // Affinity the pod's scheduling constraints Affinity *corev1.Affinity `json:"affinity,omitempty"` // Tolerations the pod's tolerations. Tolerations []corev1.Toleration `json:"tolerations,omitempty"` // NodeSelector is a selector which must be true for the pod to fit on a node NodeSelector map[string]string `json:"nodeSelector,omitempty"` // PriorityClassName indicates the pod's priority PriorityClassName string `json:"priorityClassName,omitempty"` // ServiceAccountName ServiceAccountName string `json:"serviceAccountName,omitempty"` }
NameServiceSpec defines the desired state of NameService +k8s:openapi-gen=true
func (*NameServiceSpec) DeepCopy ¶
func (in *NameServiceSpec) DeepCopy() *NameServiceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NameServiceSpec.
func (*NameServiceSpec) DeepCopyInto ¶
func (in *NameServiceSpec) DeepCopyInto(out *NameServiceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NameServiceStatus ¶
type NameServiceStatus struct { // INSERT ADDITIONAL STATUS FIELD - define observed state of cluster // Important: Run "operator-sdk generate k8s" to regenerate code after modifying this file // Add custom validation using kubebuilder tags: https://book-v1.book.kubebuilder.io/beyond_basics/generating_crd.html // NameServers is the name service ip list NameServers []string `json:"nameServers"` }
NameServiceStatus defines the observed state of NameService +k8s:openapi-gen=true
func (*NameServiceStatus) DeepCopy ¶
func (in *NameServiceStatus) DeepCopy() *NameServiceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NameServiceStatus.
func (*NameServiceStatus) DeepCopyInto ¶
func (in *NameServiceStatus) DeepCopyInto(out *NameServiceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TopicTransfer ¶
type TopicTransfer struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec TopicTransferSpec `json:"spec,omitempty"` Status TopicTransferStatus `json:"status,omitempty"` }
TopicTransfer is the Schema for the topictransfers API +k8s:openapi-gen=true +kubebuilder:subresource:status
func (*TopicTransfer) DeepCopy ¶
func (in *TopicTransfer) DeepCopy() *TopicTransfer
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicTransfer.
func (*TopicTransfer) DeepCopyInto ¶
func (in *TopicTransfer) DeepCopyInto(out *TopicTransfer)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TopicTransfer) DeepCopyObject ¶
func (in *TopicTransfer) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type TopicTransferList ¶
type TopicTransferList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []TopicTransfer `json:"items"` }
TopicTransferList contains a list of TopicTransfer
func (*TopicTransferList) DeepCopy ¶
func (in *TopicTransferList) DeepCopy() *TopicTransferList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicTransferList.
func (*TopicTransferList) DeepCopyInto ¶
func (in *TopicTransferList) DeepCopyInto(out *TopicTransferList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*TopicTransferList) DeepCopyObject ¶
func (in *TopicTransferList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type TopicTransferSpec ¶
type TopicTransferSpec struct { // Topic name Topic string `json:"topic,omitempty"` // The cluster where the transferred topic from SourceCluster string `json:"sourceCluster,omitempty"` // The cluster where the topic will be transferred to TargetCluster string `json:"targetCluster,omitempty"` }
TopicTransferSpec defines the desired state of TopicTransfer +k8s:openapi-gen=true
func (*TopicTransferSpec) DeepCopy ¶
func (in *TopicTransferSpec) DeepCopy() *TopicTransferSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicTransferSpec.
func (*TopicTransferSpec) DeepCopyInto ¶
func (in *TopicTransferSpec) DeepCopyInto(out *TopicTransferSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TopicTransferStatus ¶
type TopicTransferStatus struct { }
TopicTransferStatus defines the observed state of TopicTransfer +k8s:openapi-gen=true
func (*TopicTransferStatus) DeepCopy ¶
func (in *TopicTransferStatus) DeepCopy() *TopicTransferStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TopicTransferStatus.
func (*TopicTransferStatus) DeepCopyInto ¶
func (in *TopicTransferStatus) DeepCopyInto(out *TopicTransferStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.