v1beta1

package
v0.0.0-...-28ca6ac Latest Latest
Warning

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

 Go to latest Published: Oct 2, 2019 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package v1beta1 contains API Schema definitions for the banzaicloud v1beta1 API group +kubebuilder:object:generate=true +groupName=kafka.banzaicloud.io

Index

Constants

View Source 
const (
	// Configured states the broker is running
	Configured RackAwarenessState = "Configured"
	// WaitingForRackAwareness states the broker is waiting for the rack awareness config
	WaitingForRackAwareness RackAwarenessState = "WaitingForRackAwareness"
	// GracefulUpdateSucceeded states the broker is updated gracefully
	GracefulUpdateSucceeded CruiseControlState = "GracefulUpdateSucceeded"
	// GracefulUpdateFailed states the broker could not be updated gracefully
	GracefulUpdateFailed CruiseControlState = "GracefulUpdateFailed"
	// GracefulUpdateRequired states the broker requires an
	GracefulUpdateRequired CruiseControlState = "GracefulUpdateRequired"
	// GracefulUpdateNotRequired states the broker is the part of the initial cluster where CC is still in creating stage
	GracefulUpdateNotRequired CruiseControlState = "GracefulUpdateNotRequired"
	// CruiseControlTopicNotReady states the CC required topic is not yet created
	CruiseControlTopicNotReady CruiseControlTopicStatus = "CruiseControlTopicNotReady"
	// CruiseControlTopicReady states the CC required topic is created
	CruiseControlTopicReady CruiseControlTopicStatus = "CruiseControlTopicReady"
	// KafkaClusterReconciling states that the cluster is still in reconciling stage
	KafkaClusterReconciling ClusterState = "ClusterReconciling"
	// KafkaClusterRollingUpgrading states that the cluster is rolling upgrading
	KafkaClusterRollingUpgrading ClusterState = "ClusterRollingUpgrading"
	// KafkaClusterRunning states that the cluster is in running state
	KafkaClusterRunning ClusterState = "ClusterRunning"
	// ConfigInSync states that the generated brokerConfig is in sync with the Broker
	ConfigInSync ConfigurationState = "ConfigInSync"
	// ConfigOutOfSync states that the generated brokerConfig is out of sync with the Broker
	ConfigOutOfSync ConfigurationState = "ConfigOutOfSync"
)

Variables

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

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

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

This section is empty.

Types

type Broker 

type Broker struct {
	Id                int32         `json:"id"`
	BrokerConfigGroup string        `json:"brokerConfigGroup,omitempty"`
	ReadOnlyConfig    string        `json:"readOnlyConfig,omitempty"`
	BrokerConfig      *BrokerConfig `json:"brokerConfig,omitempty"`
}

Broker defines the broker basic configuration

func (*Broker) DeepCopy 

func (in *Broker) DeepCopy() *Broker

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

func (*Broker) DeepCopyInto 

func (in *Broker) DeepCopyInto(out *Broker)

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

type BrokerConfig 

type BrokerConfig struct {
	Image              string                        `json:"image,omitempty"`
	NodeAffinity       *corev1.NodeAffinity          `json:"nodeAffinity,omitempty"`
	Config             string                        `json:"config,omitempty"`
	StorageConfigs     []StorageConfig               `json:"storageConfigs,omitempty"`
	ServiceAccountName string                        `json:"serviceAccountName,omitempty"`
	Resources          *corev1.ResourceRequirements  `json:"resourceRequirements,omitempty"`
	ImagePullSecrets   []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
	NodeSelector       map[string]string             `json:"nodeSelector,omitempty"`
	Tolerations        []corev1.Toleration           `json:"tolerations,omitempty"`
	KafkaHeapOpts      string                        `json:"kafkaHeapOpts,omitempty"`
	KafkaJVMPerfOpts   string                        `json:"kafkaJvmPerfOpts,omitempty"`
}

BrokerConfig defines the broker configuration

func (*BrokerConfig) DeepCopy 

func (in *BrokerConfig) DeepCopy() *BrokerConfig

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

func (*BrokerConfig) DeepCopyInto 

func (in *BrokerConfig) DeepCopyInto(out *BrokerConfig)

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

func (*BrokerConfig) GetImagePullSecrets 

func (bConfig *BrokerConfig) GetImagePullSecrets() []corev1.LocalObjectReference

GetImagePullSecrets returns the list of Secrets needed to pull Containers images from private repositories

func (*BrokerConfig) GetKafkaHeapOpts 

func (bConfig *BrokerConfig) GetKafkaHeapOpts() string

GetKafkaHeapOpts returns the broker specific Heap settings

func (*BrokerConfig) GetKafkaPerfJmvOpts 

func (bConfig *BrokerConfig) GetKafkaPerfJmvOpts() string

GetKafkaPerfJmvOpts returns the broker specific Perf JVM settings

func (*BrokerConfig) GetNodeSelector 

func (bConfig *BrokerConfig) GetNodeSelector() map[string]string

GetNodeSelector returns the node selector for the given broker

func (*BrokerConfig) GetResources 

func (bConfig *BrokerConfig) GetResources() *corev1.ResourceRequirements

GetResources returns the broker specific Kubernetes resource

func (*BrokerConfig) GetServiceAccount 

func (bConfig *BrokerConfig) GetServiceAccount() string

GetServiceAccount returns the Kubernetes Service Account to use for Kafka Cluster

func (*BrokerConfig) GetTolerations 

func (bConfig *BrokerConfig) GetTolerations() []corev1.Toleration

GetTolerations returns the tolerations for the given broker

type BrokerState 

type BrokerState struct {
	// RackAwarenessState holds info about rack awareness status
	RackAwarenessState RackAwarenessState `json:"rackAwarenessState"`
	// GracefulActionState holds info about cc action status
	GracefulActionState GracefulActionState `json:"gracefulActionState"`
	// ConfigurationState holds info about the config
	ConfigurationState ConfigurationState `json:"configurationState"`
}

BrokerState holds information about broker state

func (*BrokerState) DeepCopy 

func (in *BrokerState) DeepCopy() *BrokerState

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

func (*BrokerState) DeepCopyInto 

func (in *BrokerState) DeepCopyInto(out *BrokerState)

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

type ClusterState 

type ClusterState string

ClusterState holds info about the cluster state

type ConfigurationState 

type ConfigurationState string

ConfigurationState holds info about the configuration state

type CruiseControlConfig 

type CruiseControlConfig struct {
	CruiseControlEndpoint string                        `json:"cruiseControlEndpoint,omitempty"`
	Resources             *corev1.ResourceRequirements  `json:"resourceRequirements,omitempty"`
	ServiceAccountName    string                        `json:"serviceAccountName,omitempty"`
	ImagePullSecrets      []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
	NodeSelector          map[string]string             `json:"nodeSelector,omitempty"`
	Tolerations           []corev1.Toleration           `json:"tolerations,omitempty"`
	Config                string                        `json:"config,omitempty"`
	CapacityConfig        string                        `json:"capacityConfig,omitempty"`
	ClusterConfig         string                        `json:"clusterConfig,omitempty"`
	Image                 string                        `json:"image,omitempty"`
	InitContainerImage    string                        `json:"initContainerImage,omitempty"`
}

CruiseControlConfig defines the config for Cruise Control

func (*CruiseControlConfig) DeepCopy 

func (in *CruiseControlConfig) DeepCopy() *CruiseControlConfig

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

func (*CruiseControlConfig) DeepCopyInto 

func (in *CruiseControlConfig) DeepCopyInto(out *CruiseControlConfig)

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

func (*CruiseControlConfig) GetCCImage 

func (cConfig *CruiseControlConfig) GetCCImage() string

GetCCImage returns the used Cruise Control image

func (*CruiseControlConfig) GetImagePullSecrets 

func (cConfig *CruiseControlConfig) GetImagePullSecrets() []corev1.LocalObjectReference

GetImagePullSecrets returns the list of Secrets needed to pull Containers images from private repositories

func (*CruiseControlConfig) GetInitContainerImage 

func (cConfig *CruiseControlConfig) GetInitContainerImage() string

GetInitContainerImage returns the Init container image to use for CruiseControl

func (*CruiseControlConfig) GetNodeSelector 

func (cConfig *CruiseControlConfig) GetNodeSelector() map[string]string

GetNodeSelector returns the node selector for cruise control

func (*CruiseControlConfig) GetResources 

func (cConfig *CruiseControlConfig) GetResources() *corev1.ResourceRequirements

GetResources returns the CC specific Kubernetes resource

func (*CruiseControlConfig) GetServiceAccount 

func (cConfig *CruiseControlConfig) GetServiceAccount() string

GetServiceAccount returns the Kubernetes Service Account to use for CruiseControl

func (*CruiseControlConfig) GetTolerations 

func (cConfig *CruiseControlConfig) GetTolerations() []corev1.Toleration

GetTolerations returns the tolerations for cruise control

type CruiseControlState 

type CruiseControlState string

CruiseControlState holds info about the state of Cruise Control

type CruiseControlTopicStatus 

type CruiseControlTopicStatus string

CruiseControlTopicStatus holds info about the CC topic status

type EnvoyConfig 

type EnvoyConfig struct {
	Image                    string                        `json:"image"`
	Resources                *corev1.ResourceRequirements  `json:"resourceRequirements,omitempty"`
	ServiceAccountName       string                        `json:"serviceAccountName,omitempty"`
	ImagePullSecrets         []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty"`
	NodeSelector             map[string]string             `json:"nodeSelector,omitempty"`
	Tolerations              []corev1.Toleration           `json:"tolerations,omitempty"`
	Annotations              map[string]string             `json:"annotations,omitempty"`
	LoadBalancerSourceRanges []string                      `json:"loadBalancerSourceRanges,omitempty"`
}

EnvoyConfig defines the config for Envoy

func (*EnvoyConfig) DeepCopy 

func (in *EnvoyConfig) DeepCopy() *EnvoyConfig

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

func (*EnvoyConfig) DeepCopyInto 

func (in *EnvoyConfig) DeepCopyInto(out *EnvoyConfig)

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

func (*EnvoyConfig) GetAnnotations 

func (eConfig *EnvoyConfig) GetAnnotations() map[string]string

GetAnnotations returns Annotations to use for Envoy generated LoadBalancer

func (*EnvoyConfig) GetEnvoyImage 

func (eConfig *EnvoyConfig) GetEnvoyImage() string

GetEnvoyImage returns the used envoy image

func (*EnvoyConfig) GetImagePullSecrets 

func (eConfig *EnvoyConfig) GetImagePullSecrets() []corev1.LocalObjectReference

GetImagePullSecrets returns the list of Secrets needed to pull Containers images from private repositories

func (*EnvoyConfig) GetLoadBalancerSourceRanges 

func (eConfig *EnvoyConfig) GetLoadBalancerSourceRanges() []string

GetLoadBalancerSourceRanges returns LoadBalancerSourceRanges to use for Envoy generated LoadBalancer

func (*EnvoyConfig) GetNodeSelector 

func (eConfig *EnvoyConfig) GetNodeSelector() map[string]string

GetNodeSelector returns the node selector for envoy

func (*EnvoyConfig) GetResources 

func (eConfig *EnvoyConfig) GetResources() *corev1.ResourceRequirements

GetResources returns the envoy specific Kubernetes resource

func (*EnvoyConfig) GetServiceAccount 

func (eConfig *EnvoyConfig) GetServiceAccount() string

GetServiceAccount returns the Kubernetes Service Account to use for EnvoyConfig

func (*EnvoyConfig) GetTolerations 

func (eConfig *EnvoyConfig) GetTolerations() []corev1.Toleration

GetTolerations returns the tolerations for envoy

type ExternalListenerConfig 

type ExternalListenerConfig struct {
	Type                 string `json:"type"`
	Name                 string `json:"name"`
	ExternalStartingPort int32  `json:"externalStartingPort"`
	ContainerPort        int32  `json:"containerPort"`
}

ExternalListenerConfig defines the external listener config for Kafka

func (*ExternalListenerConfig) DeepCopy 

func (in *ExternalListenerConfig) DeepCopy() *ExternalListenerConfig

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

func (*ExternalListenerConfig) DeepCopyInto 

func (in *ExternalListenerConfig) DeepCopyInto(out *ExternalListenerConfig)

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

type GracefulActionState 

type GracefulActionState struct {
	// ErrorMessage holds the information what happened with CC
	ErrorMessage string `json:"errorMessage"`
	// CruiseControlState holds the information about CC state
	CruiseControlState CruiseControlState `json:"cruiseControlState"`
}

GracefulActionState holds information about GracefulAction State

func (*GracefulActionState) DeepCopy 

func (in *GracefulActionState) DeepCopy() *GracefulActionState

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

func (*GracefulActionState) DeepCopyInto 

func (in *GracefulActionState) DeepCopyInto(out *GracefulActionState)

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

type InternalListenerConfig 

type InternalListenerConfig struct {
	Type                            string `json:"type"`
	Name                            string `json:"name"`
	UsedForInnerBrokerCommunication bool   `json:"usedForInnerBrokerCommunication"`
	ContainerPort                   int32  `json:"containerPort"`
}

InternalListenerConfig defines the internal listener config for Kafka

func (*InternalListenerConfig) DeepCopy 

func (in *InternalListenerConfig) DeepCopy() *InternalListenerConfig

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

func (*InternalListenerConfig) DeepCopyInto 

func (in *InternalListenerConfig) DeepCopyInto(out *InternalListenerConfig)

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

type KafkaCluster 

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

	Spec   KafkaClusterSpec   `json:"spec,omitempty"`
	Status KafkaClusterStatus `json:"status,omitempty"`
}

KafkaCluster is the Schema for the kafkaclusters API

func (*KafkaCluster) DeepCopy 

func (in *KafkaCluster) DeepCopy() *KafkaCluster

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

func (*KafkaCluster) DeepCopyInto 

func (in *KafkaCluster) DeepCopyInto(out *KafkaCluster)

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

func (*KafkaCluster) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type KafkaClusterList 

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

KafkaClusterList contains a list of KafkaCluster

func (*KafkaClusterList) DeepCopy 

func (in *KafkaClusterList) DeepCopy() *KafkaClusterList

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

func (*KafkaClusterList) DeepCopyInto 

func (in *KafkaClusterList) DeepCopyInto(out *KafkaClusterList)

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

func (*KafkaClusterList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type KafkaClusterSpec 

type KafkaClusterSpec struct {
	HeadlessServiceEnabled bool                    `json:"headlessServiceEnabled"`
	ListenersConfig        ListenersConfig         `json:"listenersConfig"`
	ZKAddresses            []string                `json:"zkAddresses"`
	RackAwareness          *RackAwareness          `json:"rackAwareness,omitempty"`
	ClusterImage           string                  `json:"clusterImage,omitempty"`
	ReadOnlyConfig         string                  `json:"readOnlyConfig,omitempty"`
	ClusterWideConfig      string                  `json:"clusterWideConfig,omitempty"`
	BrokerConfigGroups     map[string]BrokerConfig `json:"brokerConfigGroups,omitempty"`
	Brokers                []Broker                `json:"brokers"`
	RollingUpgradeConfig   RollingUpgradeConfig    `json:"rollingUpgradeConfig"`
	OneBrokerPerNode       bool                    `json:"oneBrokerPerNode"`
	CruiseControlConfig    CruiseControlConfig     `json:"cruiseControlConfig"`
	EnvoyConfig            EnvoyConfig             `json:"envoyConfig,omitempty"`
	MonitoringConfig       MonitoringConfig        `json:"monitoringConfig,omitempty"`
}

KafkaClusterSpec defines the desired state of KafkaCluster

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 KafkaClusterStatus 

type KafkaClusterStatus struct {
	BrokersState             map[string]BrokerState   `json:"brokersState,omitempty"`
	CruiseControlTopicStatus CruiseControlTopicStatus `json:"cruiseControlTopicStatus,omitempty"`
	State                    ClusterState             `json:"state"`
	RollingUpgrade           RollingUpgradeStatus     `json:"rollingUpgradeStatus,omitempty"`
	AlertCount               int                      `json:"alertCount"`
}

KafkaClusterStatus defines the observed state of KafkaCluster

func (*KafkaClusterStatus) DeepCopy 

func (in *KafkaClusterStatus) DeepCopy() *KafkaClusterStatus

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

func (*KafkaClusterStatus) DeepCopyInto 

func (in *KafkaClusterStatus) DeepCopyInto(out *KafkaClusterStatus)

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

type ListenersConfig 

type ListenersConfig struct {
	ExternalListeners []ExternalListenerConfig `json:"externalListeners,omitempty"`
	InternalListeners []InternalListenerConfig `json:"internalListeners"`
	SSLSecrets        *SSLSecrets              `json:"sslSecrets,omitempty"`
}

ListenersConfig defines the Kafka listener types

func (*ListenersConfig) DeepCopy 

func (in *ListenersConfig) DeepCopy() *ListenersConfig

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

func (*ListenersConfig) DeepCopyInto 

func (in *ListenersConfig) DeepCopyInto(out *ListenersConfig)

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

type MonitoringConfig 

type MonitoringConfig struct {
	JmxImage               string `json:"jmxImage"`
	PathToJar              string `json:"pathToJar"`
	KafkaJMXExporterConfig string `json:"kafkaJMXExporterConfig,omitempty"`
	CCJMXExporterConfig    string `json:"cCJMXExporterConfig,omitempty"`
}

MonitoringConfig defines the config for monitoring Kafka and Cruise Control

func (*MonitoringConfig) DeepCopy 

func (in *MonitoringConfig) DeepCopy() *MonitoringConfig

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

func (*MonitoringConfig) DeepCopyInto 

func (in *MonitoringConfig) DeepCopyInto(out *MonitoringConfig)

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

func (*MonitoringConfig) GetCCJMXExporterConfig 

func (mConfig *MonitoringConfig) GetCCJMXExporterConfig() string

GetCCJMXExporterConfig returns the config for CC Prometheus JMX exporter

func (*MonitoringConfig) GetImage 

func (mConfig *MonitoringConfig) GetImage() string

GetImage returns the used image for Prometheus JMX exporter

func (*MonitoringConfig) GetKafkaJMXExporterConfig 

func (mConfig *MonitoringConfig) GetKafkaJMXExporterConfig() string

GetKafkaJMXExporterConfig returns the config for Kafka Prometheus JMX exporter

func (*MonitoringConfig) GetPathToJar 

func (mConfig *MonitoringConfig) GetPathToJar() string

GetPathToJar returns the path in the used Image for Prometheus JMX exporter

type RackAwareness 

type RackAwareness struct {
	Labels []string `json:"labels"`
}

RackAwareness defines the required fields to enable kafka's rack aware feature

func (*RackAwareness) DeepCopy 

func (in *RackAwareness) DeepCopy() *RackAwareness

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

func (*RackAwareness) DeepCopyInto 

func (in *RackAwareness) DeepCopyInto(out *RackAwareness)

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

type RackAwarenessState 

type RackAwarenessState string

RackAwarenessState stores info about rack awareness status

type RollingUpgradeConfig 

type RollingUpgradeConfig struct {
	FailureThreshold int `json:"failureThreshold"`
}

RollingUpgradeConfig defines the desired config of the RollingUpgrade

func (*RollingUpgradeConfig) DeepCopy 

func (in *RollingUpgradeConfig) DeepCopy() *RollingUpgradeConfig

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

func (*RollingUpgradeConfig) DeepCopyInto 

func (in *RollingUpgradeConfig) DeepCopyInto(out *RollingUpgradeConfig)

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

type RollingUpgradeStatus 

type RollingUpgradeStatus struct {
	LastSuccess string `json:"lastSuccess"`
	ErrorCount  int    `json:"errorCount"`
}

RollingUpgradeStatus defines status of rolling upgrade

func (*RollingUpgradeStatus) DeepCopy 

func (in *RollingUpgradeStatus) DeepCopy() *RollingUpgradeStatus

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

func (*RollingUpgradeStatus) DeepCopyInto 

func (in *RollingUpgradeStatus) DeepCopyInto(out *RollingUpgradeStatus)

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

type SSLSecrets 

type SSLSecrets struct {
	TLSSecretName   string `json:"tlsSecretName"`
	JKSPasswordName string `json:"jksPasswordName"`
	Create          bool   `json:"create,omitempty"`
}

SSLSecrets defines the Kafka SSL secrets

func (*SSLSecrets) DeepCopy 

func (in *SSLSecrets) DeepCopy() *SSLSecrets

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

func (*SSLSecrets) DeepCopyInto 

func (in *SSLSecrets) DeepCopyInto(out *SSLSecrets)

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

type StorageConfig 

type StorageConfig struct {
	MountPath string                            `json:"mountPath"`
	PVCSpec   *corev1.PersistentVolumeClaimSpec `json:"pvcSpec"`
}

StorageConfig defines the broker storage configuration

func (*StorageConfig) DeepCopy 

func (in *StorageConfig) DeepCopy() *StorageConfig

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

func (*StorageConfig) DeepCopyInto 

func (in *StorageConfig) DeepCopyInto(out *StorageConfig)

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.