plan

Documentation

Index

• Variables
• func CRD() (*crd.CRD, error)
• func DigestStatus(plan *upgradeapiv1.Plan, secretCache corectlv1.SecretCache) (upgradeapiv1.PlanStatus, error)
• func MungeVersion(version string) string
• func NodeSelector(plan *upgradeapiv1.Plan) (labels.Selector, error)
• func ResolveChannel(ctx context.Context, url, latestVersion, clusterID string) (string, error)
• func SelectConcurrentNodes(plan *upgradeapiv1.Plan, nodeCache corectlv1.NodeCache) ([]*corev1.Node, error)
• func Validate(plan *upgradeapiv1.Plan) error

Variables

var (
	ErrDrainDeleteConflict           = fmt.Errorf("spec.drain cannot specify both deleteEmptydirData and deleteLocalData")
	ErrDrainPodSelectorNotSelectable = fmt.Errorf("spec.drain.podSelector is not selectable")

	PollingInterval = func(defaultValue time.Duration) time.Duration {
		if str, ok := os.LookupEnv("SYSTEM_UPGRADE_PLAN_POLLING_INTERVAL"); ok {
			if d, err := time.ParseDuration(str); err != nil {
				logrus.Errorf("failed to parse $%s: %v", "SYSTEM_UPGRADE_PLAN_POLLING_INTERVAL", err)
			} else if d > time.Minute {
				return d
			}
		}
		return defaultValue
	}(defaultPollingInterval)
)

Functions

func CRD

func CRD() (*crd.CRD, error)

func DigestStatus

func DigestStatus(plan *upgradeapiv1.Plan, secretCache corectlv1.SecretCache) (upgradeapiv1.PlanStatus, error)

func MungeVersion

func MungeVersion(version string) string

func NodeSelector

func NodeSelector(plan *upgradeapiv1.Plan) (labels.Selector, error)

func ResolveChannel

func ResolveChannel(ctx context.Context, url, latestVersion, clusterID string) (string, error)

func SelectConcurrentNodes

func SelectConcurrentNodes(plan *upgradeapiv1.Plan, nodeCache corectlv1.NodeCache) ([]*corev1.Node, error)

func Validate

func Validate(plan *upgradeapiv1.Plan) error

Validate performs validation of the plan spec, raising errors for any conflicting or invalid settings.