util

Documentation

Index

• Constants
• func AwaitDaemonSetReady(ctx context.Context, client kubernetes.Interface, namespace string, ...) error
• func AwaitDeploymentReady(ctx context.Context, client kubernetes.Interface, namespace string, ...) error
• func AwaitStatefulSetReady(ctx context.Context, client kubernetes.Interface, namespace string, ...) error
• func FilterOutErr(err error, fns ...utilerrors.Matcher) error
• func FilterOutReasonNotFoundErr(err error) error
• func IsAlreadyExists(err error) bool
• func IsNotFoundErr(err error) bool
• func NodeInternalIP(node v1.Node) string
• func NodeIsMaster(node v1.Node) bool
• func NodeIsReady(node v1.Node) bool
• func NodeReadyCounts(nodes []v1.Node) (int, int)
• func RestartDaemonSet(ctx context.Context, client kubernetes.Interface, namespace string, ...) error
• func RestartDeployment(ctx context.Context, client kubernetes.Interface, namespace string, ...) error
• func RestartStatefulSet(ctx context.Context, client kubernetes.Interface, namespace string, ...) error
• func ScaleAlertManager(ctx context.Context, alertClient dynamic.NamespaceableResourceInterface, ...) error
• func ScalePrometheus(ctx context.Context, promClient dynamic.NamespaceableResourceInterface, ...) error

Constants

const ControlPlaneRoleLabel = "node-role.kubernetes.io/control-plane"

const MasterRoleLabel = "node-role.kubernetes.io/master"

const NetworkUnavailableTaint = "node.kubernetes.io/network-unavailable"

const NotReadyTaint = "node.kubernetes.io/not-ready"

const UnreachableTaint = "node.kubernetes.io/unreachable"

const UnschedulableTaint = "node.kubernetes.io/unschedulable"

Functions

func AwaitDaemonSetReady

func AwaitDaemonSetReady(ctx context.Context, client kubernetes.Interface, namespace string, name string) error

AwaitDaemonSetReady waits for a daemonset to have all replicas ready and available

func AwaitDeploymentReady

func AwaitDeploymentReady(ctx context.Context, client kubernetes.Interface, namespace string, name string) error

AwaitDeploymentReady waits for a deployment to have all replicas ready and available

func AwaitStatefulSetReady

func AwaitStatefulSetReady(ctx context.Context, client kubernetes.Interface, namespace string, name string) error

AwaitStatefulSetReady waits for a statefulset to have all replicas ready and available

func FilterOutErr

func FilterOutErr(err error, fns ...utilerrors.Matcher) error

func FilterOutReasonNotFoundErr

func FilterOutReasonNotFoundErr(err error) error

func IsAlreadyExists

func IsAlreadyExists(err error) bool

func IsNotFoundErr

func IsNotFoundErr(err error) bool

func NodeInternalIP

func NodeInternalIP(node v1.Node) string

func NodeIsMaster

func NodeIsMaster(node v1.Node) bool

func NodeIsReady

func NodeIsReady(node v1.Node) bool

func NodeReadyCounts

func NodeReadyCounts(nodes []v1.Node) (int, int)

func RestartDaemonSet

func RestartDaemonSet(ctx context.Context, client kubernetes.Interface, namespace string, name string) error

RestartDaemoSet restarts a daemonset by deleting all of its pods, one at a time

func RestartDeployment

func RestartDeployment(ctx context.Context, client kubernetes.Interface, namespace string, name string) error

RestartDeployment restarts a Deployment by deleting all of its pods, one at a time

func RestartStatefulSet

func RestartStatefulSet(ctx context.Context, client kubernetes.Interface, namespace string, name string) error

RestartStatefulSet restarts a StatefulSet by deleting all of its pods, one at a time

func ScaleAlertManager

func ScaleAlertManager(ctx context.Context, alertClient dynamic.NamespaceableResourceInterface, replicas int64) error

ScaleAlertManager scales the prometheus operator to the given number of replicas

func ScalePrometheus

func ScalePrometheus(ctx context.Context, promClient dynamic.NamespaceableResourceInterface, replicas int64) error

ScalePrometheus scales the prometheus operator to the given number of replicas