v1beta2

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
• Variables
• func Resource(resource string) schema.GroupResource
• type Kafka
  • func (in *Kafka) DeepCopy() *Kafka
  • func (in *Kafka) DeepCopyInto(out *Kafka)
  • func (in *Kafka) DeepCopyObject() runtime.Object
• type KafkaList
  • func (in *KafkaList) DeepCopy() *KafkaList
  • func (in *KafkaList) DeepCopyInto(out *KafkaList)
  • func (in *KafkaList) DeepCopyObject() runtime.Object
• type KafkaStatus
  • func (in *KafkaStatus) DeepCopy() *KafkaStatus
  • func (in *KafkaStatus) DeepCopyInto(out *KafkaStatus)
• type KafkaStatusListener
  • func (in *KafkaStatusListener) DeepCopy() *KafkaStatusListener
  • func (in *KafkaStatusListener) DeepCopyInto(out *KafkaStatusListener)
• type KafkaTopic
  • func (in *KafkaTopic) DeepCopy() *KafkaTopic
  • func (in *KafkaTopic) DeepCopyInto(out *KafkaTopic)
  • func (in *KafkaTopic) DeepCopyObject() runtime.Object
• type KafkaTopicList
  • func (in *KafkaTopicList) DeepCopy() *KafkaTopicList
  • func (in *KafkaTopicList) DeepCopyInto(out *KafkaTopicList)
  • func (in *KafkaTopicList) DeepCopyObject() runtime.Object

Constants

const (
	StrimziGroup            = "kafka.strimzi.io"
	StrimziVersion          = "v1beta2"
	StrimziKindTopic        = "KafkaTopic"
	StrimziKindKafkaCluster = "Kafka"

	StrimziKafkaClusterLabel = "strimzi.io/cluster"

	StrimziListenerTypePlain = "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

func (in *Kafka) DeepCopy() *Kafka

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

func (*Kafka) DeepCopyInto

func (in *Kafka) DeepCopyInto(out *Kafka)

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

func (*Kafka) DeepCopyObject

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

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

func (in *KafkaList) DeepCopy() *KafkaList

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

func (*KafkaList) DeepCopyInto

func (in *KafkaList) DeepCopyInto(out *KafkaList)

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

func (*KafkaList) DeepCopyObject

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

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"`
	Type             string `json:"type,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"`
}

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.