utils

Sep 25, 2025

Changes in this version

+ 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 IsPodCompleted(c kubernetes.Interface, podName, namespace string) wait.ConditionWithContextFunc

+ func IsPodRunning(c kubernetes.Interface, podName, namespace string) wait.ConditionWithContextFunc

Sep 3, 2025

Changes in this version

+ const LabelComponent

+ const LabelPrefix

+ func GetFieldOwner(managerNamespace string) string

+ func PtrTo[T any](v T) *T

+ func Wrap(z *zap.Logger) hclog.Logger

+ type DrainManager struct

+ func NewDrainManager(ctx context.Context, client kClient.Client, restConfig *rest.Config) (*DrainManager, error)

+ func (d *DrainManager) IsClusterNodesHealthy(ctx context.Context) (bool, error)

+ func (d *DrainManager) IsDrainOk(ctx context.Context, nodeName string) (bool, error)

+ func (d *DrainManager) IsHealthy(ctx context.Context) (bool, error)

+ func (d *DrainManager) RunPostDrain(ctx context.Context, nodeName string) error

+ func (d *DrainManager) RunPreDrain(ctx context.Context, nodeName string) error

+ type Level = hclog.Level

+ type RebootManager struct

+ func NewRebootManager(l *zap.Logger, client client.Client, restConfig *rest.Config, namespace string) (*RebootManager, error)

+ func (r *RebootManager) Cleanup(ctx context.Context) error

+ func (r *RebootManager) CleanupNode(ctx context.Context, nodeName string) error

+ func (r *RebootManager) IsNodeRebooted(ctx context.Context, kubeNode *corev1.Node, oldBootId string) (bool, error)

+ func (r *RebootManager) IsRebootRequired(ctx context.Context, nodeName string) (bool, error)

+ func (r *RebootManager) RebootNode(ctx context.Context, nodeName string) error