v1beta2

package
v1.12.0 Latest Latest
Warning

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

 Go to latest Published: Oct 14, 2021 License: Apache-2.0 Imports: 6 Imported by: 4

Documentation

Overview

Package v1beta2 contains API Schema definitions for the kafka v1beta2 API group +k8s:deepcopy-gen=package,register +groupName=kafka.strimzi.io +kubebuilder:skip

Package v1beta2 contains API Schema definitions for the kafka v1beta2 API group +kubebuilder:skip +k8s:deepcopy-gen=package,register +groupName=kafka.strimzi.io

Index

Constants

View Source 
const (
	// KafkaConditionTypeReady ...
	KafkaConditionTypeReady = "Ready"
	// KafkaLastTransitionTimeLayout the default date layout for KafkaCondition
	KafkaLastTransitionTimeLayout = time.RFC3339
)

Variables

View Source 
var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: "kafka.strimzi.io", Version: "v1beta2"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}
)

Functions

This section is empty.

Types

type EntityOperatorSpec 

type EntityOperatorSpec struct {
	TopicOperator EntityTopicOperatorSpec `json:"topicOperator,omitempty"`
	UserOperator  EntityUserOperatorSpec  `json:"userOperator,omitempty"`
}

EntityOperatorSpec ...

func (*EntityOperatorSpec) DeepCopy 

func (in *EntityOperatorSpec) DeepCopy() *EntityOperatorSpec

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

func (*EntityOperatorSpec) DeepCopyInto 

func (in *EntityOperatorSpec) DeepCopyInto(out *EntityOperatorSpec)

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

type EntityTopicOperatorSpec 

type EntityTopicOperatorSpec struct {
}

EntityTopicOperatorSpec ...

func (*EntityTopicOperatorSpec) DeepCopy 

func (in *EntityTopicOperatorSpec) DeepCopy() *EntityTopicOperatorSpec

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

func (*EntityTopicOperatorSpec) DeepCopyInto 

func (in *EntityTopicOperatorSpec) DeepCopyInto(out *EntityTopicOperatorSpec)

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

type EntityUserOperatorSpec 

type EntityUserOperatorSpec struct {
}

EntityUserOperatorSpec ...

func (*EntityUserOperatorSpec) DeepCopy 

func (in *EntityUserOperatorSpec) DeepCopy() *EntityUserOperatorSpec

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

func (*EntityUserOperatorSpec) DeepCopyInto 

func (in *EntityUserOperatorSpec) DeepCopyInto(out *EntityUserOperatorSpec)

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

type GenericKafkaListener 

type GenericKafkaListener struct {
	Name         string `json:"name,omitempty"`
	Port         int    `json:"port,omitempty"`
	ListenerType string `json:"type,omitempty"`
	TLS          bool   `json:"tls"`
}

GenericKafkaListener ...

func (*GenericKafkaListener) DeepCopy 

func (in *GenericKafkaListener) DeepCopy() *GenericKafkaListener

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

func (*GenericKafkaListener) DeepCopyInto 

func (in *GenericKafkaListener) DeepCopyInto(out *GenericKafkaListener)

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

type Kafka 

type Kafka struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   KafkaSpec   `json:"spec,omitempty"`
	Status KafkaStatus `json:"status,omitempty"`
}

Kafka is the Schema for the kafkas API +kubebuilder:object:root=true

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 KafkaClusterSpec 

type KafkaClusterSpec struct {
	Replicas   int32                  `json:"replicas,omitempty"`
	Listeners  []GenericKafkaListener `json:"listeners,omitempty"`
	Storage    KafkaStorage           `json:"storage,omitempty"`
	Config     KafkaMap               `json:"config,omitempty"`
	JvmOptions KafkaMap               `json:"jvmOptions,omitempty"`
}

KafkaClusterSpec defines the desired state of Kafka Cluster

func (*KafkaClusterSpec) DeepCopy 

func (in *KafkaClusterSpec) DeepCopy() *KafkaClusterSpec

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

func (*KafkaClusterSpec) DeepCopyInto 

func (in *KafkaClusterSpec) DeepCopyInto(out *KafkaClusterSpec)

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

type KafkaCondition 

type KafkaCondition struct {
	Type   string                 `json:"type"`
	Status corev1.ConditionStatus `json:"status"`
	// This is defined by the Strimzi Java API as String
	LastTransitionTime string `json:"lastTransitionTime,omitempty"`
	// we don't have all possibilities for this type, leave as string and compare with known values
	Reason  string `json:"reason,omitempty"`
	Message string `json:"message,omitempty"`
}

KafkaCondition conditions for a Kafka resource

func (*KafkaCondition) DeepCopy 

func (in *KafkaCondition) DeepCopy() *KafkaCondition

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

func (*KafkaCondition) DeepCopyInto 

func (in *KafkaCondition) DeepCopyInto(out *KafkaCondition)

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

type KafkaList 

type KafkaList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Kafka `json:"items"`
}

KafkaList contains a list of Kafka +kubebuilder:object:root=true

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 KafkaMap 

type KafkaMap map[string]interface{}

KafkaMap a feasible way to implement a map with interface values to match the Java counterpart: Map<String, Object>

func (*KafkaMap) DeepCopy 

func (kafkaMap *KafkaMap) DeepCopy() *KafkaMap

DeepCopy implements a custom deepcopy function since map[string]interface{} it's not available

func (KafkaMap) DeepCopyInto 

func (in KafkaMap) DeepCopyInto(out *KafkaMap)

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

type KafkaSpec 

type KafkaSpec struct {
	Kafka          KafkaClusterSpec     `json:"kafka,omitempty"`
	Zookeeper      ZookeeperClusterSpec `json:"zookeeper,omitempty"`
	EntityOperator EntityOperatorSpec   `json:"entityOperator,omitempty"`
}

KafkaSpec defines the desired state of Kafka

func (*KafkaSpec) DeepCopy 

func (in *KafkaSpec) DeepCopy() *KafkaSpec

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

func (*KafkaSpec) DeepCopyInto 

func (in *KafkaSpec) DeepCopyInto(out *KafkaSpec)

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

type KafkaStatus 

type KafkaStatus struct {
	Listeners  []ListenerStatus `json:"listeners,omitempty"`
	Conditions []KafkaCondition `json:"conditions,omitempty"`
}

KafkaStatus defines the observed state of Kafka

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 KafkaStorage 

type KafkaStorage struct {
	StorageType KafkaStorageType `json:"type,omitempty"`
}

KafkaStorage The type of storage used by Kafka brokers

func (*KafkaStorage) DeepCopy 

func (in *KafkaStorage) DeepCopy() *KafkaStorage

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

func (*KafkaStorage) DeepCopyInto 

func (in *KafkaStorage) DeepCopyInto(out *KafkaStorage)

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

type KafkaStorageType 

type KafkaStorageType string

KafkaStorageType defines the enum for Kafka storage 

const (
	// KafkaEphemeralStorage ...
	KafkaEphemeralStorage KafkaStorageType = "ephemeral"
)

type KafkaTopic 

type KafkaTopic struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   KafkaTopicSpec   `json:"spec,omitempty"`
	Status KafkaTopicStatus `json:"status,omitempty"`
}

KafkaTopic is the Schema for the kafkatopics API +kubebuilder:object:root=true

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 +kubebuilder:object:root=true

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 KafkaTopicSpec 

type KafkaTopicSpec struct {
	Partitions int32             `json:"partitions,omitempty"`
	Replicas   int32             `json:"replicas,omitempty"`
	Config     map[string]string `json:"config,omitempty"`
	TopicName  string            `json:"topicName,omitempty"`
}

KafkaTopicSpec defines the desired state of KafkaTopic

func (*KafkaTopicSpec) DeepCopy 

func (in *KafkaTopicSpec) DeepCopy() *KafkaTopicSpec

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

func (*KafkaTopicSpec) DeepCopyInto 

func (in *KafkaTopicSpec) DeepCopyInto(out *KafkaTopicSpec)

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

type KafkaTopicStatus 

type KafkaTopicStatus struct {
}

KafkaTopicStatus defines the observed state of KafkaTopic

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.

type ListenerAddress 

type ListenerAddress struct {
	Host string `json:"host,omitempty"`
	Port int32  `json:"port,omitempty"`
}

ListenerAddress defines a single address of particular listener

func (*ListenerAddress) DeepCopy 

func (in *ListenerAddress) DeepCopy() *ListenerAddress

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

func (*ListenerAddress) DeepCopyInto 

func (in *ListenerAddress) DeepCopyInto(out *ListenerAddress)

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

type ListenerStatus 

type ListenerStatus struct {
	Type      string            `json:"type,omitempty"`
	Addresses []ListenerAddress `json:"addresses,omitempty"`
}

ListenerStatus defines a single listener

func (*ListenerStatus) DeepCopy 

func (in *ListenerStatus) DeepCopy() *ListenerStatus

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

func (*ListenerStatus) DeepCopyInto 

func (in *ListenerStatus) DeepCopyInto(out *ListenerStatus)

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

type ZookeeperClusterSpec 

type ZookeeperClusterSpec struct {
	Replicas int32        `json:"replicas,omitempty"`
	Storage  KafkaStorage `json:"storage,omitempty"`
}

ZookeeperClusterSpec Representation of a Strimzi-managed ZooKeeper "cluster".

func (*ZookeeperClusterSpec) DeepCopy 

func (in *ZookeeperClusterSpec) DeepCopy() *ZookeeperClusterSpec

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

func (*ZookeeperClusterSpec) DeepCopyInto 

func (in *ZookeeperClusterSpec) DeepCopyInto(out *ZookeeperClusterSpec)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.