util

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: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func EnrichSpecWithLogger

func EnrichSpecWithLogger(logger *log.Entry, cluster spec.Kafkacluster) *log.Entry

func GetBrokerAdressess

func GetBrokerAdressess(cluster spec.Kafkacluster) []string

Types

type ClientUtil

type ClientUtil struct {
	KubernetesClient *k8sclient.Clientset
	MasterHost       string
	DefaultOption    metav1.GetOptions
}

func (*ClientUtil) CreateDirectBrokerService

func (c *ClientUtil) CreateDirectBrokerService(cluster spec.Kafkacluster) error

Jump to

Keyboard shortcuts

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