util

Feb 27, 2024

Changes in this version

+ var SHA256 scram.HashGeneratorFcn = sha256.New

+ var SHA512 scram.HashGeneratorFcn = sha512.New

+ type XDGSCRAMClient struct

+ func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)

+ func (x *XDGSCRAMClient) Done() bool

+ func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)

Nov 3, 2023

Changes in this version

+ func LookupEnvBoolOr(key string, defaultValue bool) bool

Oct 13, 2023

Changes in this version

+ func K8sRestConfig() (*rest.Config, error)

Sep 6, 2023

Changes in this version

+ func ConnectToServer(udsSockAddr string, tcpSockAddr string, serverInfo *info.ServerInfo, ...) (*grpc.ClientConn, error)

+ func ToUDFErr(name string, err error) error

+ func WaitForServerInfo(timeout time.Duration, filePath string) (*info.ServerInfo, error)

Apr 26, 2023

Changes in this version

+ func CompareSlice(operator v1alpha1.LogicOperator, sa []string, sb []string) bool

+ func GetSASL(saslConfig *dfv1.SASL) (..., error)

Apr 3, 2023

Changes in this version

+ func GetGSSAPIConfig(config *dfv1.GSSAPI) (*sarama.GSSAPIConfig, error)

Feb 14, 2023

Changes in this version

+ func LookupEnvIntOr(key string, defaultValue int) int

Sep 20, 2022

Changes in this version

+ func GetWatermarkMaxDelay() time.Duration

Jul 8, 2022

Changes in this version

+ func IsWatermarkEnabled() bool

Jun 1, 2022

Changes in this version

+ var DefaultRetryBackoff = wait.Backoff

+ func GetConfigMapFromVolume(selector *corev1.ConfigMapKeySelector) (string, error)

+ func GetConfigMapVolumePath(selector *corev1.ConfigMapKeySelector) (string, error)

+ func GetIsbSvcEnvVars(isbSvcConfig dfv1.BufferServiceConfig) (dfv1.ISBSvcType, []corev1.EnvVar)

+ func GetSaramaConfigFromYAMLString(yaml string) (*sarama.Config, error)

+ func GetSecretFromVolume(selector *corev1.SecretKeySelector) (string, error)

+ func GetSecretVolumePath(selector *corev1.SecretKeySelector) (string, error)

+ func GetTLSConfig(config *dfv1.TLS) (*tls.Config, error)

+ func LookupEnvStringOr(key, defaultValue string) string

+ func MustHash(v interface{}) string

+ func MustJSON(in interface{}) string

+ func MustUnJSON(v interface{}, in interface{})

+ func RandomLowerCaseString(length int) string

+ func RandomString(length int) string

+ func StringSliceContains(list []string, str string) bool

+ func VolumesFromSecretsAndConfigMaps(obj interface{}) ([]corev1.Volume, []corev1.VolumeMount)