utils

package

v0.0.4 Latest Latest Go to latest Published: Sep 18, 2025 License: Apache-2.0 Imports: 31 Imported by: 0

Details

View Source

const (
	LabelPrefix    = "nodedrain.k8s.slyng.dk"
	LabelComponent = LabelPrefix + "/component"
)

This section is empty.

func GetFieldOwner(managerNamespace string) string

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

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

type DrainManager struct {
	// contains filtered or unexported fields
}

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 {
	// contains filtered or unexported fields
}

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