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 ResolveChannel(ctx context.Context, url, latestVersion, clusterID string) (string, error)
• func SelectConcurrentNodeNames(plan *upgradeapiv1.Plan, nodeCache corectlv1.NodeCache) ([]string, error)

Variables

var (
	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 ResolveChannel

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

func SelectConcurrentNodeNames

func SelectConcurrentNodeNames(plan *upgradeapiv1.Plan, nodeCache corectlv1.NodeCache) ([]string, error)