Documentation ¶
Index ¶
- func Contains(list []string, s string) bool
- func GeneratePassword(n int) (string, error)
- func GetAnnotation(annotations map[string]string, key string) string
- func GetKafkaConfig(ctx context.Context, kubeClient kubernetes.Interface, namespace string, ...) (string, string, string, string, error)
- func Remove(list []string, s string) []string
- func RemoveDuplicates(elements []string) []string
- func UpdateObject(ctx context.Context, runtimeClient client.Client, obj client.Object) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GeneratePassword ¶
GeneratePassword returns a base64 encoded securely random bytes.
func GetAnnotation ¶
GetAnnotation returns the annotation value for a given key, or an empty string if not set
func GetKafkaConfig ¶
func GetKafkaConfig(ctx context.Context, kubeClient kubernetes.Interface, namespace string, name string, ) (string, string, string, string, error)
GetKafkaConfig retrieves kafka server, caCert, clientCert, clientKey from the secret
func RemoveDuplicates ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.