v1beta1

package

Go to main page

Versions in this module

v0

v0.28.8

Aug 30, 2023

Changes in this version

type BrokerConfig

+ func (bConfig *BrokerConfig) GetKafkaPerfJvmOpts() string

v0.28.7

Jul 27, 2023

Changes in this version

type RollingUpgradeConfig

+ ConcurrentBrokerRestartCountPerRack int

v0.28.6

Jul 20, 2023

v0.28.5

Jul 12, 2023

Changes in this version

+ const DefaultCruiseControlImage

+ const DefaultKafkaImage

v0.28.4

Jul 12, 2023

v0.28.3

Jun 15, 2023

Changes in this version

+ const DefaultIngressControllerTargetPort

type ExternalListenerConfig

+ IngressControllerTargetPort *int32

+ func (c ExternalListenerConfig) GetIngressControllerTargetPort() int32

v0.28.2

Jun 9, 2023

v0.28.1

Jun 1, 2023

v0.28.0

May 19, 2023

v0.27.0

May 12, 2023

v0.26.0

Apr 24, 2023

Changes in this version

type CruiseControlConfig

+ Affinity *corev1.Affinity

+ func (cConfig *CruiseControlConfig) GetAffinity() *corev1.Affinity

v0.25.0

Apr 4, 2023

Changes in this version

type EnvoyConfig

+ PodSecurityContext *corev1.PodSecurityContext

+ func (eConfig *EnvoyConfig) GetPodSecurityContext() *corev1.PodSecurityContext

v0.24.0

Mar 29, 2023

Changes in this version

type KafkaClusterSpec

+ RemoveUnusedIngressResources bool

v0.23.2

Mar 1, 2023

Changes in this version

type BrokerConfig

+ NodePortNodeAddressType corev1.NodeAddressType

v0.23.1

Feb 17, 2023

v0.23.0

Feb 7, 2023

Changes in this version

type KafkaClusterSpec

+ AdditionalPorts []corev1.ContainerPort

v0.22.0

Oct 13, 2022

Changes in this version

+ const GracefulDiskRebalanceCompletedWithError

+ const GracefulDiskRebalancePaused

+ const GracefulDiskRebalanceScheduled

+ const GracefulDownscaleCompletedWithError

+ const GracefulDownscalePaused

+ const GracefulDownscaleScheduled

+ const GracefulUpscaleCompletedWithError

+ const GracefulUpscalePaused

+ const GracefulUpscaleScheduled

type CruiseControlConfig

+ CruiseControlOperationSpec *CruiseControlOperationSpec

+ type CruiseControlOperationSpec struct

+ TTLSecondsAfterFinished *int

+ func (c *CruiseControlOperationSpec) GetTTLSecondsAfterFinished() *int

+ func (in *CruiseControlOperationSpec) DeepCopy() *CruiseControlOperationSpec

+ func (in *CruiseControlOperationSpec) DeepCopyInto(out *CruiseControlOperationSpec)

type CruiseControlState

+ func (r CruiseControlState) IsSucceeded() bool

type CruiseControlVolumeState

+ func (r CruiseControlVolumeState) IsSucceeded() bool

+ func (s CruiseControlVolumeState) IsRequiredState() bool

type GracefulActionState

+ CruiseControlOperationReference *corev1.LocalObjectReference

type VolumeState

+ CruiseControlOperationReference *corev1.LocalObjectReference

v0.21.0

Sep 16, 2022

Changes in this version

type BrokerConfig

+ PriorityClassName string

+ func (bConfig *BrokerConfig) GetPriorityClassName() string

type CruiseControlConfig

+ PriorityClassName string

+ func (cConfig *CruiseControlConfig) GetPriorityClassName() string

type EnvoyConfig

+ EnableHealthCheckHttp10 bool

+ PriorityClassName string

+ func (eConfig *EnvoyConfig) GetPriorityClassName() string

v0.20.0

Jul 29, 2022

Changes in this version

+ const AppLabelKey

+ const BrokerIdLabelKey

+ const KafkaCRLabelKey

v0.19.0

Jul 15, 2022

Changes in this version

type BrokerState

+ ConfigurationBackup string

type IstioIngressConfig

+ LoadBalancerSourceRanges []string

+ func (iIConfig *IstioIngressConfig) GetLoadBalancerSourceRanges() []string

type StorageConfig

+ EmptyDir *corev1.EmptyDirVolumeSource

v0.18.0

May 17, 2022

v0.17.0

May 6, 2022

Changes in this version

+ const SSLClientAuthRequired

type BrokerConfig

+ BrokerLabels map[string]string

+ func (bConfig *BrokerConfig) GetBrokerLabels(kafkaClusterName string, brokerId int32) map[string]string

type CommonListenerSpec

+ SSLClientAuth SSLClientAuthentication

type CruiseControlState

+ func (r CruiseControlState) IsActive() bool

type CruiseControlVolumeState

+ func (s CruiseControlVolumeState) IsActive() bool

+ func (s CruiseControlVolumeState) IsRunningState() bool

+ type SSLClientAuthentication string

v0.16.0

Jan 19, 2022

Changes in this version

+ type IstioControlPlaneReference struct

+ Name string

+ Namespace string

+ func (in *IstioControlPlaneReference) DeepCopy() *IstioControlPlaneReference

+ func (in *IstioControlPlaneReference) DeepCopyInto(out *IstioControlPlaneReference)

type KafkaClusterSpec

+ IstioControlPlane *IstioControlPlaneReference

v0.15.0

Dec 15, 2021

Changes in this version

+ const DefaultBrokerTerminationGracePeriod

type BrokerConfig

+ TerminationGracePeriod *int64

+ func (bConfig *BrokerConfig) GetTerminationGracePeriod() int64

type CommonListenerSpec

+ ServerSSLCertSecret *corev1.LocalObjectReference

+ func (c *CommonListenerSpec) GetServerSSLCertSecretName() string

+ type EnvoyCommandLineArgs struct

+ Concurrency int32

+ func (in *EnvoyCommandLineArgs) DeepCopy() *EnvoyCommandLineArgs

+ func (in *EnvoyCommandLineArgs) DeepCopyInto(out *EnvoyCommandLineArgs)

type EnvoyConfig

+ CommandLineArgs *EnvoyCommandLineArgs

+ func (eConfig *EnvoyConfig) GetConcurrency() int32

type KafkaClusterSpec

+ ClientSSLCertSecret *corev1.LocalObjectReference

+ func (k *KafkaClusterSpec) GetClientSSLCertSecretName() string

+ func (k *KafkaClusterSpec) IsClientSSLSecretPresent() bool

v0.14.0

Nov 25, 2021

Changes in this version

type BrokerConfig

+ MetricsReporterImage string

type KafkaClusterSpec

+ ClusterMetricsReporterImage string

+ func (kSpec *KafkaClusterSpec) GetClusterMetricsReporterImage() string

v0.13.0

Oct 25, 2021

Changes in this version

+ const DefaultEnvoyHealthCheckPort

type EnvoyConfig

+ HealthCheckPort *int32

+ TopologySpreadConstraints []corev1.TopologySpreadConstraint

+ func (eConfig *EnvoyConfig) GetEnvoyHealthCheckPort() int32

+ func (eConfig *EnvoyConfig) GetTopologySpreadConstaints() []corev1.TopologySpreadConstraint

v0.12.1

Sep 16, 2021

Changes in this version

+ const ConfigInSync

+ const ConfigOutOfSync

+ const Configured

+ const CruiseControlTaskActive

+ const CruiseControlTaskCompleted

+ const CruiseControlTaskCompletedWithError

+ const CruiseControlTaskInExecution

+ const CruiseControlTaskNotFound

+ const CruiseControlTopicNotReady

+ const CruiseControlTopicReady

+ const DefaultAnyCastPort

+ const DefaultEnvoyAdminPort

+ const DefaultServiceAccountName

+ const GracefulDiskRebalanceRequired

+ const GracefulDiskRebalanceRunning

+ const GracefulDiskRebalanceSucceeded

+ const GracefulDownscaleRequired

+ const GracefulDownscaleRunning

+ const GracefulDownscaleSucceeded

+ const GracefulUpscaleRequired

+ const GracefulUpscaleRunning

+ const GracefulUpscaleSucceeded

+ const KafkaClusterReconciling

+ const KafkaClusterRollingUpgrading

+ const KafkaClusterRunning

+ const PerBrokerConfigError

+ const PerBrokerConfigInSync

+ const PerBrokerConfigOutOfSync

+ const SecurityProtocolPlaintext

+ const SecurityProtocolSSL

+ const SecurityProtocolSaslPlaintext

+ const SecurityProtocolSaslSSL

+ const WaitingForRackAwareness

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ type AlertManagerConfig struct

+ DownScaleLimit int

+ UpScaleLimit int

+ func (in *AlertManagerConfig) DeepCopy() *AlertManagerConfig

+ func (in *AlertManagerConfig) DeepCopyInto(out *AlertManagerConfig)

+ type Broker struct

+ BrokerConfig *BrokerConfig

+ BrokerConfigGroup string

+ Id int32

+ ReadOnlyConfig string

+ func (b *Broker) GetBrokerConfig(kafkaClusterSpec KafkaClusterSpec) (*BrokerConfig, error)

+ func (in *Broker) DeepCopy() *Broker

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

+ type BrokerConfig struct

+ Affinity *corev1.Affinity

+ BrokerAnnotations map[string]string

+ BrokerIngressMapping []string

+ Config string

+ Containers []corev1.Container

+ Envs []corev1.EnvVar

+ Image string

+ ImagePullSecrets []corev1.LocalObjectReference

+ InitContainers []corev1.Container

+ KafkaHeapOpts string

+ KafkaJVMPerfOpts string

+ Log4jConfig string

+ NetworkConfig *NetworkConfig

+ NodePortExternalIP map[string]string

+ NodeSelector map[string]string

+ PodSecurityContext *corev1.PodSecurityContext

+ Resources *corev1.ResourceRequirements

+ SecurityContext *corev1.SecurityContext

+ ServiceAccountName string

+ StorageConfigs []StorageConfig

+ Tolerations []corev1.Toleration

+ VolumeMounts []corev1.VolumeMount

+ Volumes []corev1.Volume

+ func (bConfig *BrokerConfig) GetBrokerAnnotations() map[string]string

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

+ func (bConfig *BrokerConfig) GetKafkaHeapOpts() string

+ func (bConfig *BrokerConfig) GetKafkaPerfJmvOpts() string

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

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

+ func (bConfig *BrokerConfig) GetServiceAccount() string

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

+ func (in *BrokerConfig) DeepCopy() *BrokerConfig

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

+ type BrokerState struct

+ ConfigurationState ConfigurationState

+ ExternalListenerConfigNames ExternalListenerConfigNames

+ GracefulActionState GracefulActionState

+ Image string

+ PerBrokerConfigurationState PerBrokerConfigurationState

+ RackAwarenessState RackAwarenessState

+ Version string

+ func (in *BrokerState) DeepCopy() *BrokerState

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

+ type ClusterState string

+ type CommonListenerSpec struct

+ ContainerPort int32

+ Name string

+ Type SecurityProtocol

+ func (in *CommonListenerSpec) DeepCopy() *CommonListenerSpec

+ func (in *CommonListenerSpec) DeepCopyInto(out *CommonListenerSpec)

+ func (lP *CommonListenerSpec) GetListenerServiceName() string

+ type Config struct

+ DefaultIngressConfig string

+ IngressConfig map[string]IngressConfig

+ func (in *Config) DeepCopy() *Config

+ func (in *Config) DeepCopyInto(out *Config)

+ type ConfigurationState string

+ type CruiseControlConfig struct

+ CapacityConfig string

+ ClusterConfig string

+ Config string

+ CruiseControlAnnotations map[string]string

+ CruiseControlEndpoint string

+ CruiseControlTaskSpec CruiseControlTaskSpec

+ Image string

+ ImagePullSecrets []corev1.LocalObjectReference

+ InitContainers []corev1.Container

+ Log4jConfig string

+ NodeSelector map[string]string

+ PodSecurityContext *corev1.PodSecurityContext

+ Resources *corev1.ResourceRequirements

+ SecurityContext *corev1.SecurityContext

+ ServiceAccountName string

+ Tolerations []corev1.Toleration

+ TopicConfig *TopicConfig

+ VolumeMounts []corev1.VolumeMount

+ Volumes []corev1.Volume

+ func (cConfig *CruiseControlConfig) GetCCImage() string

+ func (cConfig *CruiseControlConfig) GetCCLog4jConfig() string

+ func (cConfig *CruiseControlConfig) GetCruiseControlAnnotations() map[string]string

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

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

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

+ func (cConfig *CruiseControlConfig) GetServiceAccount() string

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

+ func (in *CruiseControlConfig) DeepCopy() *CruiseControlConfig

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

+ type CruiseControlState string

+ func (r CruiseControlState) Complete() CruiseControlState

+ func (r CruiseControlState) IsDownscale() bool

+ func (r CruiseControlState) IsRequiredState() bool

+ func (r CruiseControlState) IsRunningState() bool

+ func (r CruiseControlState) IsUpscale() bool

+ type CruiseControlTaskSpec struct

+ RetryDurationMinutes int

+ func (cTaskSpec *CruiseControlTaskSpec) GetDurationMinutes() float64

+ func (in *CruiseControlTaskSpec) DeepCopy() *CruiseControlTaskSpec

+ func (in *CruiseControlTaskSpec) DeepCopyInto(out *CruiseControlTaskSpec)

+ type CruiseControlTopicStatus string

+ type CruiseControlUserTaskState string

+ type CruiseControlVolumeState string

+ type DisruptionBudget struct

+ Budget string

+ Create bool

+ func (in *DisruptionBudget) DeepCopy() *DisruptionBudget

+ func (in *DisruptionBudget) DeepCopyInto(out *DisruptionBudget)

+ type DisruptionBudgetWithStrategy struct

+ DisruptionBudget DisruptionBudget

+ Stategy string

+ func (in *DisruptionBudgetWithStrategy) DeepCopy() *DisruptionBudgetWithStrategy

+ func (in *DisruptionBudgetWithStrategy) DeepCopyInto(out *DisruptionBudgetWithStrategy)

+ type EnvoyConfig struct

+ AdminPort *int32

+ Affinity *corev1.Affinity

+ Annotations map[string]string

+ DisruptionBudget *DisruptionBudgetWithStrategy

+ Image string

+ ImagePullSecrets []corev1.LocalObjectReference

+ LoadBalancerIP string

+ LoadBalancerSourceRanges []string

+ NodeSelector map[string]string

+ Replicas int32

+ Resources *corev1.ResourceRequirements

+ ServiceAccountName string

+ Tolerations []corev1.Toleration

+ func (eConfig *EnvoyConfig) GetAffinity() *corev1.Affinity

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

+ func (eConfig *EnvoyConfig) GetDistruptionBudget() DisruptionBudgetWithStrategy

+ func (eConfig *EnvoyConfig) GetEnvoyAdminPort() int32

+ func (eConfig *EnvoyConfig) GetEnvoyImage() string

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

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

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

+ func (eConfig *EnvoyConfig) GetReplicas() int32

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

+ func (eConfig *EnvoyConfig) GetServiceAccount() string

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

+ func (in *EnvoyConfig) DeepCopy() *EnvoyConfig

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

+ type ExternalListenerConfig struct

+ AccessMethod corev1.ServiceType

+ AnyCastPort *int32

+ Config *Config

+ ExternalStartingPort int32

+ func (c ExternalListenerConfig) GetAccessMethod() corev1.ServiceType

+ func (c ExternalListenerConfig) GetAnyCastPort() int32

+ func (in *ExternalListenerConfig) DeepCopy() *ExternalListenerConfig

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

+ type ExternalListenerConfigNames []string

+ func (in ExternalListenerConfigNames) DeepCopy() ExternalListenerConfigNames

+ func (in ExternalListenerConfigNames) DeepCopyInto(out *ExternalListenerConfigNames)

+ type GracefulActionState struct

+ CruiseControlState CruiseControlState

+ CruiseControlTaskId string

+ ErrorMessage string

+ TaskStarted string

+ VolumeStates map[string]VolumeState

+ func (in *GracefulActionState) DeepCopy() *GracefulActionState

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

+ type IngressConfig struct

+ EnvoyConfig *EnvoyConfig

+ IstioIngressConfig *IstioIngressConfig

+ func (in *IngressConfig) DeepCopy() *IngressConfig

+ func (in *IngressConfig) DeepCopyInto(out *IngressConfig)

+ type IngressServiceSettings struct

+ ExternalTrafficPolicy corev1.ServiceExternalTrafficPolicyType

+ HostnameOverride string

+ ServiceAnnotations map[string]string

+ ServiceType corev1.ServiceType

+ func (c IngressServiceSettings) GetServiceAnnotations() map[string]string

+ func (c IngressServiceSettings) GetServiceType() corev1.ServiceType

+ func (in *IngressServiceSettings) DeepCopy() *IngressServiceSettings

+ func (in *IngressServiceSettings) DeepCopyInto(out *IngressServiceSettings)

+ type InternalListenerConfig struct

+ UsedForControllerCommunication bool

+ UsedForInnerBrokerCommunication bool

+ func (in *InternalListenerConfig) DeepCopy() *InternalListenerConfig

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

+ type IstioIngressConfig struct

+ Annotations map[string]string

+ Envs []corev1.EnvVar

+ NodeSelector map[string]string

+ Replicas int32

+ Resources *corev1.ResourceRequirements

+ TLSOptions *v1alpha3.TLSOptions

+ Tolerations []corev1.Toleration

+ VirtualServiceAnnotations map[string]string

+ func (iIConfig *IstioIngressConfig) GetAnnotations() map[string]string

+ func (iIConfig *IstioIngressConfig) GetReplicas() int32

+ func (iIConfig *IstioIngressConfig) GetResources() *corev1.ResourceRequirements

+ func (iIConfig *IstioIngressConfig) GetVirtualServiceAnnotations() map[string]string

+ func (in *IstioIngressConfig) DeepCopy() *IstioIngressConfig

+ func (in *IstioIngressConfig) DeepCopyInto(out *IstioIngressConfig)

+ type KafkaCluster struct

+ Spec KafkaClusterSpec

+ Status KafkaClusterStatus

+ func (in *KafkaCluster) DeepCopy() *KafkaCluster

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

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

+ type KafkaClusterList struct

+ Items []KafkaCluster

+ func (in *KafkaClusterList) DeepCopy() *KafkaClusterList

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

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

+ type KafkaClusterSpec struct

+ AlertManagerConfig *AlertManagerConfig

+ BrokerConfigGroups map[string]BrokerConfig

+ Brokers []Broker

+ ClusterImage string

+ ClusterWideConfig string

+ CruiseControlConfig CruiseControlConfig

+ DisruptionBudget DisruptionBudget

+ EnvoyConfig EnvoyConfig

+ Envs []corev1.EnvVar

+ HeadlessServiceEnabled bool

+ IngressController string

+ IstioIngressConfig IstioIngressConfig

+ KubernetesClusterDomain string

+ ListenersConfig ListenersConfig

+ MonitoringConfig MonitoringConfig

+ OneBrokerPerNode bool

+ PropagateLabels bool

+ RackAwareness *RackAwareness

+ ReadOnlyConfig string

+ RollingUpgradeConfig RollingUpgradeConfig

+ VaultConfig VaultConfig

+ ZKAddresses []string

+ ZKPath string

+ func (in *KafkaClusterSpec) DeepCopy() *KafkaClusterSpec

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

+ func (kSpec *KafkaClusterSpec) GetClusterImage() string

+ func (kSpec *KafkaClusterSpec) GetIngressController() string

+ func (kSpec *KafkaClusterSpec) GetKubernetesClusterDomain() string

+ func (kSpec *KafkaClusterSpec) GetZkPath() string

+ type KafkaClusterStatus struct

+ AlertCount int

+ BrokersState map[string]BrokerState

+ CruiseControlTopicStatus CruiseControlTopicStatus

+ ListenerStatuses ListenerStatuses

+ RollingUpgrade RollingUpgradeStatus

+ State ClusterState

+ func (in *KafkaClusterStatus) DeepCopy() *KafkaClusterStatus

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

+ type KafkaVersion struct

+ Image string

+ Version string

+ func (in *KafkaVersion) DeepCopy() *KafkaVersion

+ func (in *KafkaVersion) DeepCopyInto(out *KafkaVersion)

+ type ListenerStatus struct

+ Address string

+ Name string

+ func (in *ListenerStatus) DeepCopy() *ListenerStatus

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

+ type ListenerStatusList []ListenerStatus

+ func (in ListenerStatusList) DeepCopy() ListenerStatusList

+ func (in ListenerStatusList) DeepCopyInto(out *ListenerStatusList)

+ func (l ListenerStatusList) Len() int

+ func (l ListenerStatusList) Less(i, j int) bool

+ func (l ListenerStatusList) Swap(i, j int)

+ type ListenerStatuses struct

+ ExternalListeners map[string]ListenerStatusList

+ InternalListeners map[string]ListenerStatusList

+ func (in *ListenerStatuses) DeepCopy() *ListenerStatuses

+ func (in *ListenerStatuses) DeepCopyInto(out *ListenerStatuses)

+ type ListenersConfig struct

+ ExternalListeners []ExternalListenerConfig

+ InternalListeners []InternalListenerConfig

+ SSLSecrets *SSLSecrets

+ ServiceAnnotations map[string]string

+ func (c ListenersConfig) GetServiceAnnotations() map[string]string

+ func (in *ListenersConfig) DeepCopy() *ListenersConfig

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

+ type MonitoringConfig struct

+ CCJMXExporterConfig string

+ JmxImage string

+ KafkaJMXExporterConfig string

+ PathToJar string

+ func (in *MonitoringConfig) DeepCopy() *MonitoringConfig

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

+ func (mConfig *MonitoringConfig) GetCCJMXExporterConfig() string

+ func (mConfig *MonitoringConfig) GetImage() string

+ func (mConfig *MonitoringConfig) GetKafkaJMXExporterConfig() string

+ func (mConfig *MonitoringConfig) GetPathToJar() string

+ type NetworkConfig struct

+ IncomingNetworkThroughPut string

+ OutgoingNetworkThroughPut string

+ func (in *NetworkConfig) DeepCopy() *NetworkConfig

+ func (in *NetworkConfig) DeepCopyInto(out *NetworkConfig)

+ type PKIBackend string

+ const PKIBackendCertManager

+ const PKIBackendK8sCSR

+ const PKIBackendProvided

+ const PKIBackendVault

+ type PerBrokerConfigurationState string

+ type RackAwareness struct

+ Labels []string

+ func (in *RackAwareness) DeepCopy() *RackAwareness

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

+ type RackAwarenessState string

+ type RollingUpgradeConfig struct

+ FailureThreshold int

+ func (in *RollingUpgradeConfig) DeepCopy() *RollingUpgradeConfig

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

+ type RollingUpgradeStatus struct

+ ErrorCount int

+ LastSuccess string

+ func (in *RollingUpgradeStatus) DeepCopy() *RollingUpgradeStatus

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

+ type SSLSecrets struct

+ Create bool

+ IssuerRef *cmmeta.ObjectReference

+ JKSPasswordName string

+ PKIBackend PKIBackend

+ TLSSecretName string

+ func (in *SSLSecrets) DeepCopy() *SSLSecrets

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

+ type SecurityProtocol string

+ func (r SecurityProtocol) Equal(s SecurityProtocol) bool

+ func (r SecurityProtocol) IsPlaintext() bool

+ func (r SecurityProtocol) IsSSL() bool

+ func (r SecurityProtocol) IsSasl() bool

+ func (r SecurityProtocol) ToUpperString() string

+ type StorageConfig struct

+ MountPath string

+ PvcSpec *corev1.PersistentVolumeClaimSpec

+ func (in *StorageConfig) DeepCopy() *StorageConfig

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

+ type TopicConfig struct

+ Partitions int32

+ ReplicationFactor int32

+ func (in *TopicConfig) DeepCopy() *TopicConfig

+ func (in *TopicConfig) DeepCopyInto(out *TopicConfig)

+ type VaultConfig struct

+ AuthRole string

+ IssuePath string

+ PKIPath string

+ UserStore string

+ func (in *VaultConfig) DeepCopy() *VaultConfig

+ func (in *VaultConfig) DeepCopyInto(out *VaultConfig)

+ type VolumeState struct

+ CruiseControlTaskId string

+ CruiseControlVolumeState CruiseControlVolumeState

+ ErrorMessage string

+ TaskStarted string

+ func (in *VolumeState) DeepCopy() *VolumeState

+ func (in *VolumeState) DeepCopyInto(out *VolumeState)

v0.12.1-dev.0

Sep 15, 2021

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL