Documentation
¶
Index ¶
- func ExecCmd(ctx context.Context, client kubernetes.Interface, config *rest.Config, ...) error
- func GetNode(ctx context.Context, kubeClient *kubernetes.Clientset, nodeName string) *corev1.Node
- func GetVersionFromImage(image string) (string, bool)
- func IsNodeRebooted(l *zap.Logger, c kubernetes.Interface, nodeName, bootIdOld string) wait.ConditionWithContextFunc
- func IsPodCompleted(c kubernetes.Interface, podName, namespace string) wait.ConditionWithContextFunc
- func IsPodRunning(c kubernetes.Interface, podName, namespace string) wait.ConditionWithContextFunc
- func NodeVersionMatch(l *zap.Logger, c kubernetes.Interface, nodeName string, version string) wait.ConditionWithContextFunc
- type KubernetesStateful
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ExecCmd ¶
func ExecCmd(ctx context.Context, client kubernetes.Interface, config *rest.Config, pod types.NamespacedName, command string, stdin io.Reader, stdout io.Writer, stderr io.Writer) error
ExecCmd exec command on specific pod and wait the command's output.
func GetVersionFromImage ¶
func IsNodeRebooted ¶
func IsNodeRebooted(l *zap.Logger, c kubernetes.Interface, nodeName, bootIdOld string) wait.ConditionWithContextFunc
func IsPodCompleted ¶
func IsPodCompleted(c kubernetes.Interface, podName, namespace string) wait.ConditionWithContextFunc
func IsPodRunning ¶
func IsPodRunning(c kubernetes.Interface, podName, namespace string) wait.ConditionWithContextFunc
func NodeVersionMatch ¶
func NodeVersionMatch(l *zap.Logger, c kubernetes.Interface, nodeName string, version string) wait.ConditionWithContextFunc
Types ¶
type KubernetesStateful ¶
type KubernetesStateful interface {
Name() string
IsSupported(ctx context.Context) (bool, error)
IsHealthy(ctx context.Context) (bool, error)
IsDrainOk(ctx context.Context, nodeName string) (bool, error)
PreDrain(ctx context.Context, nodeName string) error
PostDrain(ctx context.Context, nodeName string) error
}
Source Files
Click to show internal directories.
Click to hide internal directories.