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.

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.