operator

func BuildImagePath ¶ added in v0.42.0

func BuildImagePath(specImage, image, version, tag, sha string) (string, error)

BuildImagePath builds a container image path based on the given parameters. Return specImage if not empty. If image contains a tag or digest then image will be returned. Otherwise, return image suffixed by either SHA, tag or version(in that order). Inspired by kubernetes code handling of image building.

func CreateConfigReloader ¶ added in v0.43.0

func CreateConfigReloader(
	config ReloaderConfig,
	reloadURL url.URL,
	listenLocal bool,
	localHost string,
	logFormat, logLevel string,
	additionalArgs []string,
	volumeMounts []v1.VolumeMount,
	shard int32,
) v1.Container

CreateConfigReloader returns the definition of the config-reloader container. No shard environment variable will be passed to the reloader container if `-1` is passed to the shards parameter.

func MakeVolumeClaimTemplate ¶ added in v0.42.0

func MakeVolumeClaimTemplate(e monitoringv1.EmbeddedPersistentVolumeClaim) *v1.PersistentVolumeClaim

func NewTLSConfig ¶ added in v0.42.0

func NewTLSConfig(logger log.Logger, certFile, keyFile, clientCAFile, minVersion string, cipherSuites []string) (*tls.Config, error)

NewTLSConfig provides new server TLS configuration.

func SanitizeSTS ¶ added in v0.42.0

func SanitizeSTS(sts *appsv1.StatefulSet)

SanitizeSTS removes values for APIVersion and Kind from the VolumeClaimTemplates. This prevents update failures due to these fields changing when applied. See https://github.com/kubernetes/kubernetes/issues/87583

func StringPtrValOrDefault ¶ added in v0.42.0

func StringPtrValOrDefault(val *string, defaultVal string) string

StringPtrValOrDefault returns the default val if the given string pointer is nil points to an empty/whitespace string. Otherwise returns the value of the string.

func StringValOrDefault ¶ added in v0.42.0

func StringValOrDefault(val, defaultVal string) string

StringValOrDefault returns the default val if the given string is empty/whitespace. Otherwise returns the value of the string..

func WaitForNamedCacheSync ¶ added in v0.43.1

func WaitForNamedCacheSync(ctx context.Context, controllerName string, logger log.Logger, inf cache.SharedIndexInformer) bool

WaitForCacheSync synchronizes the informer's cache and will log a warning every minute if the operation hasn't completed yet. Under normal circumstances, the cache sync should be fast. If it takes more than 1 minute, it means that something is stuck and the message will indicate to the admin which informer is the culprit. See https://github.com/prometheus-operator/prometheus-operator/issues/3347.