kafka

package
v0.0.0-...-146a38b Latest Latest
Warning

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

Go to latest
Published: May 31, 2023 License: BSD-3-Clause, Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateCluster

func CreateCluster(cluster spec.Kafkacluster, client kube.Kubernetes) error

func DeleteCluster

func DeleteCluster(cluster spec.Kafkacluster, client kube.Kubernetes) error

func DownsizeCluster

func DownsizeCluster(cluster spec.Kafkacluster, client kube.Kubernetes) error

func GenerateKafkaOptions

func GenerateKafkaOptions(cluster spec.Kafkacluster) []v1.EnvVar

func GetMaxHeap

func GetMaxHeap(cluster spec.Kafkacluster) *resource.Quantity

func GetMaxHeapJavaString

func GetMaxHeapJavaString(cluster spec.Kafkacluster) string

func ReflectOptionsStruct

func ReflectOptionsStruct(v interface{}) []v1.EnvVar

func UpdateStatus

func UpdateStatus(cluster spec.Kafkacluster, client kube.Kubernetes) error

func UpsizeCluster

func UpsizeCluster(cluster spec.Kafkacluster, client kube.Kubernetes) error

Types

This section is empty.

Jump to

Keyboard shortcuts

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