Function getDrainHelper

pkg/node/node.go:743–763

(nthConfig config.Config, clientset *kubernetes.Clientset)

}

func getDrainHelper(nthConfig config.Config, clientset *kubernetes.Clientset) (*drain.Helper, error) {
	drainHelper := &drain.Helper{
		Ctx:                 context.TODO(),
		Client:              &kubernetes.Clientset{},
		Force:               true,
		GracePeriodSeconds:  nthConfig.PodTerminationGracePeriod,
		IgnoreAllDaemonSets: nthConfig.IgnoreDaemonSets,
		AdditionalFilters:   []drain.PodFilter{filterPodForDeletion(nthConfig.PodName, nthConfig.PodNamespace)},
		DeleteEmptyDirData:  nthConfig.DeleteLocalData,
		Timeout:             time.Duration(nthConfig.NodeTerminationGracePeriod) * time.Second,
		Out:                 &StdWriter{&ZerologWriter{logger: log.Logger}},
		ErrOut:              &ErrWriter{&ZerologWriter{logger: log.Logger}},
	}

	if nthConfig.DryRun {
		return drainHelper, nil
	}

	drainHelper.Client = clientset
	return drainHelper, nil
}

func jsonPatchEscape(value string) string {
	value = strings.ReplaceAll(value, "~", "~0")