v1alpha1

package
v1.19.0 Latest Latest
Warning

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

 Go to latest Published: Feb 21, 2020 License: Apache-2.0 Imports: 6 Imported by: 4

Documentation

Overview

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

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

Index

Constants

This section is empty.

Variables

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

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

Functions

func GetOpenAPIDefinitions 

func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition

func RegisterDefaults 

func RegisterDefaults(scheme *runtime.Scheme) error

RegisterDefaults adds defaulters functions to the given scheme. Public to allow building arbitrary schemes. All generated defaulters are covering - they call all nested defaulters.

Types

type Kafka 

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

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

Installation is the Schema for the installations API +k8s:openapi-gen=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 KafkaList 

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

InstallationList contains a list of Installation

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 KafkaListener 

type KafkaListener struct{}

func (*KafkaListener) DeepCopy 

func (in *KafkaListener) DeepCopy() *KafkaListener

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

func (*KafkaListener) DeepCopyInto 

func (in *KafkaListener) DeepCopyInto(out *KafkaListener)

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

type KafkaSpec 

type KafkaSpec 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.kubebuilder.io/beyond_basics/generating_crd.html
	Kafka          KafkaSpecKafka          `json:"kafka,omitempty"`
	Zookeeper      KafkaSpecZookeeper      `json:"zookeeper,omitempty"`
	EntityOperator KafkaSpecEntityOperator `json:"entityOperator,omitempty"`
}

InstallationSpec defines the desired state of Installation +k8s:openapi-gen=true

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 KafkaSpecEntityOperator 

type KafkaSpecEntityOperator struct {
	TopicOperator KafkaTopicOperator `json:"topicOperator"`
	UserOperator  KafkaUserOperator  `json:"userOperator"`
}

func (*KafkaSpecEntityOperator) DeepCopy 

func (in *KafkaSpecEntityOperator) DeepCopy() *KafkaSpecEntityOperator

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

func (*KafkaSpecEntityOperator) DeepCopyInto 

func (in *KafkaSpecEntityOperator) DeepCopyInto(out *KafkaSpecEntityOperator)

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

type KafkaSpecKafka 

type KafkaSpecKafka struct {
	Version   string                   `json:"version,omitempty"`
	Replicas  int                      `json:"replicas,omitempty"`
	Listeners map[string]KafkaListener `json:"listeners,omitempty"`
	Config    KafkaSpecKafkaConfig     `json:"config,omitempty"`
	Storage   KafkaStorage             `json:"storage,omitempty"`
}

func (*KafkaSpecKafka) DeepCopy 

func (in *KafkaSpecKafka) DeepCopy() *KafkaSpecKafka

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

func (*KafkaSpecKafka) DeepCopyInto 

func (in *KafkaSpecKafka) DeepCopyInto(out *KafkaSpecKafka)

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

type KafkaSpecKafkaConfig 

type KafkaSpecKafkaConfig struct {
	OffsetsTopicReplicationFactor        string `json:"offsets.topic.replication.factor,omitempty"`
	TransactionStateLogReplicationFactor string `json:"transaction.state.log.replication.factor,omitempty"`
	TransactionStateLogMinIsr            string `json:"transaction.state.log.min.isr,omitempty"`
	LogMessageFormatVersion              string `json:"log.message.format.version,omitempty"`
}

func (*KafkaSpecKafkaConfig) DeepCopy 

func (in *KafkaSpecKafkaConfig) DeepCopy() *KafkaSpecKafkaConfig

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

func (*KafkaSpecKafkaConfig) DeepCopyInto 

func (in *KafkaSpecKafkaConfig) DeepCopyInto(out *KafkaSpecKafkaConfig)

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

type KafkaSpecZookeeper 

type KafkaSpecZookeeper struct {
	Replicas int          `json:"replicas,omitempty"`
	Storage  KafkaStorage `json:"storage,omitempty"`
}

func (*KafkaSpecZookeeper) DeepCopy 

func (in *KafkaSpecZookeeper) DeepCopy() *KafkaSpecZookeeper

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

func (*KafkaSpecZookeeper) DeepCopyInto 

func (in *KafkaSpecZookeeper) DeepCopyInto(out *KafkaSpecZookeeper)

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

type KafkaStatus 

type KafkaStatus struct {
}

InstallationStatus defines the observed state of Installation +k8s:openapi-gen=true

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 {
	Type        string `json:"type,omitempty"`
	Size        string `json:"size,omitempty"`
	DeleteClaim bool   `json:"deleteClaim,omitempty"`
}

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 KafkaTopicOperator 

type KafkaTopicOperator struct{}

func (*KafkaTopicOperator) DeepCopy 

func (in *KafkaTopicOperator) DeepCopy() *KafkaTopicOperator

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

func (*KafkaTopicOperator) DeepCopyInto 

func (in *KafkaTopicOperator) DeepCopyInto(out *KafkaTopicOperator)

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

type KafkaUserOperator 

type KafkaUserOperator struct{}

func (*KafkaUserOperator) DeepCopy 

func (in *KafkaUserOperator) DeepCopy() *KafkaUserOperator

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

func (*KafkaUserOperator) DeepCopyInto 

func (in *KafkaUserOperator) DeepCopyInto(out *KafkaUserOperator)

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.