util

Documentation

Index

• func BoolPointer(b bool) *bool
• func ConvertMapStringToMapStringPointer(inputMap map[string]string) map[string]*string
• func ConvertStringToInt32(s string) int32
• func GetBrokerConfig(broker v1beta1.Broker, clusterSpec v1beta1.KafkaClusterSpec) (*v1beta1.BrokerConfig, error)
• func GetBrokerImage(brokerConfig *v1beta1.BrokerConfig, clusterImage string) string
• func Int32Pointer(i int32) *int32
• func Int64Pointer(i int64) *int64
• func IntstrPointer(i int) *intstr.IntOrString
• func IsSSLEnabledForInternalCommunication(l []v1beta1.InternalListenerConfig) (enabled bool)
• func MapStringStringPointer(in map[string]string) (out map[string]*string)
• func MergeLabels(l map[string]string, l2 map[string]string) map[string]string
• func MonitoringAnnotations(port int) map[string]string
• func ParsePropertiesFormat(properties string) map[string]string
• func StringPointer(s string) *string
• func StringSliceContains(list []string, s string) bool
• func StringSliceRemove(list []string, s string) []string

Functions

func BoolPointer

func BoolPointer(b bool) *bool

BoolPointer generates bool pointer from bool

func ConvertMapStringToMapStringPointer

func ConvertMapStringToMapStringPointer(inputMap map[string]string) map[string]*string

ConvertMapStringToMapStringPointer converts a simple map[string]string to map[string]*string

func ConvertStringToInt32

func ConvertStringToInt32(s string) int32

ConvertStringToInt32 converts the given string to int32

func GetBrokerConfig

func GetBrokerConfig(broker v1beta1.Broker, clusterSpec v1beta1.KafkaClusterSpec) (*v1beta1.BrokerConfig, error)

GetBrokerConfig compose the brokerConfig for a given broker

func GetBrokerImage

func GetBrokerImage(brokerConfig *v1beta1.BrokerConfig, clusterImage string) string

GetBrokerImage returns the used broker image

func Int32Pointer

func Int32Pointer(i int32) *int32

Int32Pointer generates int32 pointer from int32

func Int64Pointer

func Int64Pointer(i int64) *int64

Int64Pointer generates int64 pointer from int64

func IntstrPointer

func IntstrPointer(i int) *intstr.IntOrString

IntstrPointer generate IntOrString pointer from int

func IsSSLEnabledForInternalCommunication

func IsSSLEnabledForInternalCommunication(l []v1beta1.InternalListenerConfig) (enabled bool)

IsSSLEnabledForInternalCommunication checks if ssl is enabled for internal communication

func MapStringStringPointer

func MapStringStringPointer(in map[string]string) (out map[string]*string)

MapStringStringPointer generates a map[string]*string

func MergeLabels

func MergeLabels(l map[string]string, l2 map[string]string) map[string]string

MergeLabels merges two given labels

func MonitoringAnnotations

func MonitoringAnnotations(port int) map[string]string

MonitoringAnnotations returns specific prometheus annotations

func ParsePropertiesFormat

func ParsePropertiesFormat(properties string) map[string]string

ParsePropertiesFormat parses the properties format configuration into map[string]string

func StringPointer

func StringPointer(s string) *string

StringPointer generates string pointer from string

func StringSliceContains

func StringSliceContains(list []string, s string) bool

StringSliceContains returns true if list contains s

func StringSliceRemove

func StringSliceRemove(list []string, s string) []string

StringSliceRemove will remove s from list