Documentation
¶
Index ¶
- func AreStringSlicesIdentical(a, b []string) bool
- func BoolPointer(b bool) *bool
- func ConvertMapStringToMapStringPointer(inputMap map[string]string) map[string]*string
- func ConvertStringToInt32(s string) int32
- func CreateLogger(debug bool, development bool) logr.Logger
- func GetBrokerConfig(broker v1beta1.Broker, clusterSpec v1beta1.KafkaClusterSpec) (*v1beta1.BrokerConfig, error)
- func GetBrokerIdsFromStatusAndSpec(brokerStatuses map[string]v1beta1.BrokerState, brokers []v1beta1.Broker, ...) []int
- func GetBrokerImage(brokerConfig *v1beta1.BrokerConfig, clusterImage string) string
- func GetRandomString(length int) (string, error)
- func Int32Pointer(i int32) *int32
- func Int64Pointer(i int64) *int64
- func IntPointer(i int) *int
- func IntstrPointer(i int) *intstr.IntOrString
- func IsSSLEnabledForInternalCommunication(l []v1beta1.InternalListenerConfig) (enabled bool)
- func MapStringStringPointer(in map[string]string) (out map[string]*string)
- func Max(x, y int) int
- func MergeAnnotations(annotations ...map[string]string) map[string]string
- func MergeLabels(l ...map[string]string) map[string]string
- func ParsePropertiesFormat(properties string) map[string]string
- func QuantityPointer(q resource.Quantity) *resource.Quantity
- func StringPointer(s string) *string
- func StringSliceContains(list []string, s string) bool
- func StringSliceRemove(list []string, s string) []string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConvertMapStringToMapStringPointer ¶
ConvertMapStringToMapStringPointer converts a simple map[string]string to map[string]*string
func ConvertStringToInt32 ¶
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 GetBrokerIdsFromStatusAndSpec ¶ added in v0.14.0
func GetBrokerIdsFromStatusAndSpec(brokerStatuses map[string]v1beta1.BrokerState, brokers []v1beta1.Broker, log logr.Logger) []int
returns the union of the ids of the configured (Spec.Brokers) and the running (BrokerState) brokers
func GetBrokerImage ¶
func GetBrokerImage(brokerConfig *v1beta1.BrokerConfig, clusterImage string) string
GetBrokerImage returns the used broker image
func GetRandomString ¶
getRandomString returns a random string containing uppercase, lowercase and number characters with the length given
func Int32Pointer ¶
Int32Pointer generates int32 pointer from int32
func Int64Pointer ¶
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 ¶
MapStringStringPointer generates a map[string]*string
func MergeLabels ¶
MergeLabels merges two given labels
func ParsePropertiesFormat ¶
ParsePropertiesFormat parses the properties format configuration into map[string]string
func QuantityPointer ¶
QuantityPointer generates Quantity pointer from Quantity
func StringPointer ¶
StringPointer generates string pointer from string
func StringSliceContains ¶
StringSliceContains returns true if list contains s
func StringSliceRemove ¶
StringSliceRemove will remove s from list
Types ¶
This section is empty.
Source Files
Directories