k8stools

Documentation

Index

• Variables
• func CompareObjectMeta(t *testing.T, got, want metav1.ObjectMeta)
• func GetTestClientWithObjects(predefinedObjects []runtime.Object) client.Client
• func HandleDeployUpdate(ctx context.Context, rclient client.Client, newDeploy *appsv1.Deployment) error
• func HandleSTSUpdate(ctx context.Context, rclient client.Client, cr STSOptions, ...) error
• func IsPDBV1APISupported() bool
• func IsPSPSupported() bool
• func MergeAnnotations(prev, current map[string]string) map[string]string
• func MergePatchContainers(base, patches []v1.Container) ([]v1.Container, error)
• func PodIsReady(pod corev1.Pod) bool
• func SanitizeVolumeName(name string) string
• func SetKubernetesVersionWithDefaults(vi *version.Info, defaultMinor, defaultMajor uint64) error
• func UpdatePodAnnotations(ctx context.Context, rclient client.Client, selector map[string]string, ...) error
• type STSOptions

Variables

var (
	ServerMajorVersion uint64
	ServerMinorVersion uint64
)

Functions

func CompareObjectMeta

func CompareObjectMeta(t *testing.T, got, want metav1.ObjectMeta)

func GetTestClientWithObjects

func GetTestClientWithObjects(predefinedObjects []runtime.Object) client.Client

func HandleDeployUpdate

func HandleDeployUpdate(ctx context.Context, rclient client.Client, newDeploy *appsv1.Deployment) error

func HandleSTSUpdate

func HandleSTSUpdate(ctx context.Context, rclient client.Client, cr STSOptions, newSts, currentSts *appsv1.StatefulSet, c *config.BaseOperatorConf) error

func IsPDBV1APISupported

func IsPDBV1APISupported() bool

IsPDBV1APISupported check if new v1 API is supported by kubernetes API server deprecated since 1.21 https://kubernetes.io/docs/reference/using-api/deprecation-guide/#poddisruptionbudget-v125

func IsPSPSupported

func IsPSPSupported() bool

IsPSPSupported check if PodSecurityPolicy is supported by kubernetes API server https://kubernetes.io/docs/reference/using-api/deprecation-guide/#psp-v125

func MergeAnnotations

func MergeAnnotations(prev, current map[string]string) map[string]string

MergeAnnotations adds annotations with kubernetes.io/ to the current map from prev It's needed for kubectl restart, correct updates such annotations managed by kubernetes controller and shouldn't be changed by operator

func MergePatchContainers

func MergePatchContainers(base, patches []v1.Container) ([]v1.Container, error)

MergePatchContainers adds patches to base using a strategic merge patch and iterating by container name, failing on the first error

func PodIsReady

func PodIsReady(pod corev1.Pod) bool

func SanitizeVolumeName

func SanitizeVolumeName(name string) string

func SetKubernetesVersionWithDefaults

func SetKubernetesVersionWithDefaults(vi *version.Info, defaultMinor, defaultMajor uint64) error

SetKubernetesVersionWithDefaults parses kubernetes version response with given default versions

func UpdatePodAnnotations

func UpdatePodAnnotations(ctx context.Context, rclient client.Client, selector map[string]string, ns string) error

UpdatePodAnnotations - updates configmap-sync-time annotation it triggers config rules reload for vmalert

Types

type STSOptions

type STSOptions struct {
	SelectorLabels func() map[string]string
	VolumeName     func() string
	UpdateStrategy func() appsv1.StatefulSetUpdateStrategyType
}