Documentation ¶
Overview ¶
Package v1alpha1 contains the v1alpha1 group Sample resources of the Template provider. +kubebuilder:object:generate=true +groupName=topic.kafka.crossplane.io +versionName=v1alpha1
Index ¶
- Constants
- Variables
- 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 (mg *Topic) GetDeletionPolicy() xpv1.DeletionPolicy
- func (mg *Topic) GetManagementPolicies() xpv1.ManagementPolicies
- func (mg *Topic) GetProviderConfigReference() *xpv1.Reference
- func (mg *Topic) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *Topic) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (mg *Topic) SetConditions(c ...xpv1.Condition)
- func (mg *Topic) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (mg *Topic) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (mg *Topic) SetProviderConfigReference(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
Constants ¶
const ( Group = "topic.kafka.crossplane.io" Version = "v1alpha1" )
Package type metadata.
Variables ¶
var ( // SchemeGroupVersion is group version used to register these objects SchemeGroupVersion = schema.GroupVersion{Group: Group, Version: Version} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion} )
var ( TopicKind = reflect.TypeOf(Topic{}).Name() TopicGroupKind = schema.GroupKind{Group: Group, Kind: TopicKind}.String() TopicKindAPIVersion = TopicKind + "." + SchemeGroupVersion.String() TopicGroupVersionKind = SchemeGroupVersion.WithKind(TopicKind) )
Topic type metadata.
Functions ¶
This section is empty.
Types ¶
type Topic ¶
type Topic struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec TopicSpec `json:"spec"` Status TopicStatus `json:"status,omitempty"` }
A Topic is an example API type. +kubebuilder:subresource:status +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,kafka}
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) GetDeletionPolicy ¶
func (mg *Topic) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this Topic.
func (*Topic) GetManagementPolicies ¶ added in v0.5.0
func (mg *Topic) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this Topic.
func (*Topic) GetProviderConfigReference ¶
GetProviderConfigReference of this Topic.
func (*Topic) GetPublishConnectionDetailsTo ¶ added in v0.4.0
func (mg *Topic) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this Topic.
func (*Topic) GetWriteConnectionSecretToReference ¶
func (mg *Topic) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference 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) SetManagementPolicies ¶ added in v0.5.0
func (mg *Topic) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this Topic.
func (*Topic) SetProviderConfigReference ¶
SetProviderConfigReference of this Topic.
func (*Topic) SetPublishConnectionDetailsTo ¶ added in v0.4.0
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 Topic
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 {
ID string `json:"id,omitempty"`
}
TopicObservation are the observable fields of a Topic.
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 { // ReplicationFactor defines the number of replicas the topic should have. // +kubebuilder:validation:Minimum:=1 ReplicationFactor int `json:"replicationFactor"` // Partitions defines the number of partitions the topic should have. // +kubebuilder:validation:Minimum:=1 Partitions int `json:"partitions"` // Config is an optional map of string key/ value pairs. // +optional Config map[string]*string `json:"config,omitempty"` }
TopicParameters are the configurable fields of a Topic.
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 { xpv1.ResourceSpec `json:",inline"` ForProvider TopicParameters `json:"forProvider"` }
A TopicSpec defines the desired state of a 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 { xpv1.ResourceStatus `json:",inline"` AtProvider TopicObservation `json:"atProvider,omitempty"` }
A TopicStatus represents the observed state of a 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.