util

Documentation

Index

• func EnrichSpecWithLogger(logger *log.Entry, cluster spec.Kafkacluster) *log.Entry
• func GetBrokerAdressess(cluster spec.Kafkacluster) []string
• type ClientUtil
  • func (c *ClientUtil) CreateDirectBrokerService(cluster spec.Kafkacluster) error

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