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 NotReadyTaint = "node.kubernetes.io/not-ready"
const UnreachableTaint = "node.kubernetes.io/unreachable"
const UnschedulableTaint = "node.kubernetes.io/unschedulable"
Variables ¶
This section is empty.
Functions ¶
func AwaitDaemonSetReady ¶ added in v0.27.1
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 ¶ added in v0.27.1
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 ¶ added in v0.27.1
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 IsAlreadyExists ¶ added in v0.27.2
func IsNotFoundErr ¶
func NodeInternalIP ¶ added in v0.11.0
func NodeIsMaster ¶
func NodeIsReady ¶
func RestartDaemonSet ¶ added in v0.27.1
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 ¶ added in v0.27.1
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 ¶ added in v0.27.1
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 ¶ added in v0.27.1
func ScaleAlertManager(ctx context.Context, alertClient dynamic.NamespaceableResourceInterface, replicas int64) error
ScaleAlertManager scales the prometheus operator to the given number of replicas
func ScalePrometheus ¶ added in v0.27.1
func ScalePrometheus(ctx context.Context, promClient dynamic.NamespaceableResourceInterface, replicas int64) error
ScalePrometheus scales the prometheus operator to the given number of replicas
Types ¶
This section is empty.