Documentation
¶
Index ¶
- Constants
- func AreStringSlicesIdentical(a, b []string) bool
- func BoolPointer(b bool) *bool
- func ConstructEListenerLabelName(ingressConfigName, eListenerName string) string
- func ConvertConfigEntryListToProperties(config []sarama.ConfigEntry) (*properties.Properties, error)
- func ConvertPropertiesToMapStringPointer(pp *properties.Properties) map[string]*string
- func ConvertStringToInt32(s string) int32
- func CreateLogger(debug bool, development bool) logr.Logger
- func GenerateEnvoyResourceName(resourceNameFormat string, resourceNameWithScopeFormat string, ...) string
- func GetBrokerIdsFromStatusAndSpec(brokerStatuses map[string]v1beta1.BrokerState, brokers []v1beta1.Broker, ...) []int
- func GetBrokerImage(brokerConfig *v1beta1.BrokerConfig, clusterImage string) string
- func GetIngressConfigs(kafkaClusterSpec v1beta1.KafkaClusterSpec, ...) (map[string]v1beta1.IngressConfig, string, error)
- 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 IsIngressConfigInUse(iConfigName, defaultConfigName string, cluster *v1beta1.KafkaCluster, ...) bool
- 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 QuantityPointer(q resource.Quantity) *resource.Quantity
- func ShouldIncludeBroker(brokerConfig *v1beta1.BrokerConfig, status v1beta1.KafkaClusterStatus, ...) bool
- func StringPointer(s string) *string
- func StringSliceContains(list []string, s string) bool
- func StringSliceRemove(list []string, s string) []string
Constants ¶
const (
IngressConfigGlobalName = "globalConfig"
)
Variables ¶
This section is empty.
Functions ¶
func ConstructEListenerLabelName ¶ added in v0.15.0
ConstructEListenerLabelName construct an eListener label name based on ingress config name and listener name
func ConvertConfigEntryListToProperties ¶ added in v0.15.0
func ConvertConfigEntryListToProperties(config []sarama.ConfigEntry) (*properties.Properties, error)
ConvertConfigEntryListToProperties function takes []sarama.ConfigEntry and coverts it to Properties object
func ConvertPropertiesToMapStringPointer ¶ added in v0.15.0
func ConvertPropertiesToMapStringPointer(pp *properties.Properties) map[string]*string
ConvertPropertiesToMapStringPointer converts a Properties object to map[string]*string
func ConvertStringToInt32 ¶
ConvertStringToInt32 converts the given string to int32
func GenerateEnvoyResourceName ¶ added in v0.18.0
func GenerateEnvoyResourceName(resourceNameFormat string, resourceNameWithScopeFormat string, extListener v1beta1.ExternalListenerConfig, ingressConfig v1beta1.IngressConfig, ingressConfigName, clusterName string) string
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 GetIngressConfigs ¶ added in v0.15.0
func GetIngressConfigs(kafkaClusterSpec v1beta1.KafkaClusterSpec, eListenerConfig v1beta1.ExternalListenerConfig) (map[string]v1beta1.IngressConfig, string, error)
GetIngressConfigs compose the ingress configuration for a given externalListener
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 IsIngressConfigInUse ¶ added in v0.15.0
func IsIngressConfigInUse(iConfigName, defaultConfigName string, cluster *v1beta1.KafkaCluster, log logr.Logger) bool
IsIngressConfigInUse returns true if the provided ingressConfigName is bound to the given broker
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 QuantityPointer ¶
QuantityPointer generates Quantity pointer from Quantity
func ShouldIncludeBroker ¶ added in v0.15.0
func ShouldIncludeBroker(brokerConfig *v1beta1.BrokerConfig, status v1beta1.KafkaClusterStatus, brokerID int, defaultIngressConfigName, ingressConfigName string) bool
ShouldIncludeBroker returns true if the broker should be included as a resource on external listener resources
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