Documentation
¶
Overview ¶
Package duck contains a partial schema of the Strimzi APIs +kubebuilder:object:generate=true +groupName=kafka.strimzi.io
Package duck contains duck-types for accessing Strimzi resources
Index ¶
Constants ¶
const ( StrimziGroup = "kafka.strimzi.io" StrimziVersion = "v1beta2" StrimziKindTopic = "KafkaTopic" StrimziKindKafkaCluster = "Kafka" StrimziKafkaClusterLabel = "strimzi.io/cluster" StrimziListenerNamePlain = "plain" )
Variables ¶
var ( // SchemeGroupVersion is group version used to register these objects. SchemeGroupVersion = schema.GroupVersion{Group: StrimziGroup, Version: StrimziVersion} // SchemeBuilder is used to add go types to the GroupVersionKind scheme. SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) // AddToScheme is a shortcut to SchemeBuilder.AddToScheme. AddToScheme = SchemeBuilder.AddToScheme )
Functions ¶
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group qualified GroupResource.
Types ¶
type Kafka ¶
type Kafka struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Status KafkaStatus `json:"status,omitempty"`
}
Kafka is the duck of a Kafka.
func (*Kafka) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Kafka.
func (*Kafka) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Kafka) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type KafkaList ¶
type KafkaList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []Kafka `json:"items"`
}
KafkaList contains a list of Kafka.
func (*KafkaList) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaList.
func (*KafkaList) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaList) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type KafkaStatus ¶
type KafkaStatus struct {
Listeners []KafkaStatusListener `json:"listeners,omitempty"`
}
KafkaStatus contains the relevant info of the Kafka status.
func (*KafkaStatus) DeepCopy ¶
func (in *KafkaStatus) DeepCopy() *KafkaStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaStatus.
func (*KafkaStatus) DeepCopyInto ¶
func (in *KafkaStatus) DeepCopyInto(out *KafkaStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaStatusListener ¶
type KafkaStatusListener struct {
BootstrapServers string `json:"bootstrapServers,omitempty"`
Name string `json:"name,omitempty"`
}
KafkaStatusListener contains listener information.
func (*KafkaStatusListener) DeepCopy ¶
func (in *KafkaStatusListener) DeepCopy() *KafkaStatusListener
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaStatusListener.
func (*KafkaStatusListener) DeepCopyInto ¶
func (in *KafkaStatusListener) DeepCopyInto(out *KafkaStatusListener)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaTopic ¶
type KafkaTopic struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Status KafkaTopicStatus `json:"status,omitempty"`
}
KafkaTopic is the duck of a KafkaTopic.
func (*KafkaTopic) DeepCopy ¶
func (in *KafkaTopic) DeepCopy() *KafkaTopic
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaTopic.
func (*KafkaTopic) DeepCopyInto ¶
func (in *KafkaTopic) DeepCopyInto(out *KafkaTopic)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaTopic) DeepCopyObject ¶
func (in *KafkaTopic) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type KafkaTopicList ¶
type KafkaTopicList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []KafkaTopic `json:"items"`
}
KafkaTopicList contains a list of KafkaTopic.
func (*KafkaTopicList) DeepCopy ¶
func (in *KafkaTopicList) DeepCopy() *KafkaTopicList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaTopicList.
func (*KafkaTopicList) DeepCopyInto ¶
func (in *KafkaTopicList) DeepCopyInto(out *KafkaTopicList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaTopicList) DeepCopyObject ¶
func (in *KafkaTopicList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type KafkaTopicStatus ¶
type KafkaTopicStatus struct {
TopicName string `json:"topicName,omitempty"`
}
KafkaTopicStatus is the duck of a KafkaTopic status.
func (*KafkaTopicStatus) DeepCopy ¶
func (in *KafkaTopicStatus) DeepCopy() *KafkaTopicStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaTopicStatus.
func (*KafkaTopicStatus) DeepCopyInto ¶
func (in *KafkaTopicStatus) DeepCopyInto(out *KafkaTopicStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
Source Files