phases

func NeedMigrateRoles ¶

func NeedMigrateRoles(roles []teleservices.Role) bool

NeedMigrateRoles returns true if the provided cluster roles need to be migrated to a new format

func NewGarbageCollectPhase ¶

func NewGarbageCollectPhase(p fsm.ExecutorParams, remote fsm.Remote, logger log.FieldLogger) (fsm.PhaseExecutor, error)

NewGarbageCollectPhase returns a new executor for the garbage collection phase

func NewPhaseCoreDNS ¶

func NewPhaseCoreDNS(p fsm.ExecutorParams, operator ops.Operator, client *kubernetes.Clientset, logger log.FieldLogger) (fsm.PhaseExecutor, error)

NewPhaseCoreDNS creates an upgrade phase to add coredns rbac permissions The normal upgrade sequence is to Rolling update planet, then to update our RBAC settings in the RBAC app However, CoreDNS within planet needs these settings to function, so these settings specifically need to be created before the rolling restart of planet

func NewPhaseDrain ¶

func NewPhaseDrain(p fsm.ExecutorParams, client *kubeapi.Clientset, logger log.FieldLogger) (fsm.PhaseExecutor, error)

NewPhaseDrain returns a new executor for draining a node

func NewPhaseElectionChange ¶

func NewPhaseElectionChange(
	p fsm.ExecutorParams,
	operator ops.Operator,
	remote fsm.Remote,
	logger logrus.FieldLogger,
) (fsm.PhaseExecutor, error)

NewPhaseElectionChange is a phase for modifying cluster elections during upgrades

func NewPhaseEndpoints ¶

func NewPhaseEndpoints(p fsm.ExecutorParams, client *kubeapi.Clientset, logger log.FieldLogger) (fsm.PhaseExecutor, error)

NewPhaseEndpoints returns a new executor for waiting for endpoints

func NewPhaseKubeletPermissions ¶

func NewPhaseKubeletPermissions(p fsm.ExecutorParams, client *kubeapi.Clientset, logger log.FieldLogger) (fsm.PhaseExecutor, error)

NewPhaseKubeletPermissions returns a new executor for bootstrapping additional kubelet permissions

func NewPhaseMigrateLinks ¶

func NewPhaseMigrateLinks(plan storage.OperationPlan, backend storage.Backend, logger log.FieldLogger) (fsm.PhaseExecutor, error)

NewPhaseMigrateLinks returns a new links migration executor

func NewPhaseMigrateRoles ¶

func NewPhaseMigrateRoles(plan storage.OperationPlan, backend storage.Backend, logger log.FieldLogger) (fsm.PhaseExecutor, error)

NewPhaseMigrateRoles returns a new roles migration executor

func NewPhaseNodeHealth ¶

func NewPhaseNodeHealth(logger log.FieldLogger) (fsm.PhaseExecutor, error)

NewPhaseNodeHealth creates an upgrade phase to check whether the node is healthy

func NewPhaseTaint ¶

func NewPhaseTaint(p fsm.ExecutorParams, client *kubeapi.Clientset, logger log.FieldLogger) (fsm.PhaseExecutor, error)

NewPhaseTaint returns a new executor for adding a taint to a node

func NewPhaseUncordon ¶

func NewPhaseUncordon(p fsm.ExecutorParams, client *kubeapi.Clientset, logger log.FieldLogger) (fsm.PhaseExecutor, error)

NewPhaseUncordon returns a new executor for uncordoning a node

func NewPhaseUntaint ¶

func NewPhaseUntaint(p fsm.ExecutorParams, client *kubeapi.Clientset, logger log.FieldLogger) (fsm.PhaseExecutor, error)

NewPhaseUntaint returns a new executor for removing a taint from a node

func NewPhaseUpdateLabels ¶

func NewPhaseUpdateLabels(plan storage.OperationPlan, client *kubernetes.Clientset, logger log.FieldLogger) (fsm.PhaseExecutor, error)

NewPhaseUpdateLabels updates labels during an upgrade

func NewPhaseUpgradeEtcd ¶

func NewPhaseUpgradeEtcd(phase storage.OperationPhase, logger log.FieldLogger) (fsm.PhaseExecutor, error)

func NewPhaseUpgradeEtcdBackup ¶

func NewPhaseUpgradeEtcdBackup(logger log.FieldLogger) (fsm.PhaseExecutor, error)

func NewPhaseUpgradeEtcdRestart ¶

func NewPhaseUpgradeEtcdRestart(phase storage.OperationPhase, logger log.FieldLogger) (fsm.PhaseExecutor, error)

func NewPhaseUpgradeEtcdRestore ¶

func NewPhaseUpgradeEtcdRestore(phase storage.OperationPhase, logger log.FieldLogger) (fsm.PhaseExecutor, error)

func NewPhaseUpgradeEtcdShutdown ¶

func NewPhaseUpgradeEtcdShutdown(phase storage.OperationPhase, client *kubeapi.Clientset, logger log.FieldLogger) (fsm.PhaseExecutor, error)

NewPhaseUpgradeEtcdShutdown creates a phase for shutting down etcd across the cluster 4. Shutdown etcd (all servers) // API outage starts

func NewPhaseUpgradeGravitySiteRestart ¶

func NewPhaseUpgradeGravitySiteRestart(phase storage.OperationPhase, client *kubeapi.Clientset, logger log.FieldLogger) (fsm.PhaseExecutor, error)

func NewUpdatePhaseApp ¶

func NewUpdatePhaseApp(
	p fsm.ExecutorParams,
	operator ops.Operator,
	apps app.Applications,
	client *kubernetes.Clientset,
	logger log.FieldLogger,
) (fsm.PhaseExecutor, error)

NewUpdatePhaseApp returns a new app phase executor

func NewUpdatePhaseBeforeApp ¶

func NewUpdatePhaseBeforeApp(
	p fsm.ExecutorParams,
	apps app.Applications,
	client *kubernetes.Clientset,
	logger log.FieldLogger,
) (fsm.PhaseExecutor, error)

NewUpdatePhaseBeforeApp returns a new executor for running application pre-update hook

func NewUpdatePhaseBootstrap ¶

func NewUpdatePhaseBootstrap(
	p fsm.ExecutorParams,
	operator ops.Operator,
	backend, localBackend storage.Backend, hostLocalBackend storage.LocalBackend,
	localPackages, packages pack.PackageService,
	remote fsm.Remote,
	logger log.FieldLogger,
) (fsm.PhaseExecutor, error)

NewUpdatePhaseBootstrap creates a new bootstrap phase executor

func NewUpdatePhaseChecks ¶

func NewUpdatePhaseChecks(
	p fsm.ExecutorParams,
	operator ops.Operator,
	apps app.Applications,
	remote rpc.AgentRepository,
	logger log.FieldLogger,
) (fsm.PhaseExecutor, error)

NewUpdatePhaseChecks creates a new preflight checks phase executor

func NewUpdatePhaseConfig ¶

func NewUpdatePhaseConfig(
	p fsm.ExecutorParams,
	operator ops.Operator,
	packages pack.PackageService,
	localPackages pack.PackageService,
	remote fsm.Remote,
	logger log.FieldLogger,
) (fsm.PhaseExecutor, error)

NewUpdatePhaseConfig returns executor that pulls local configuration packages

func NewUpdatePhaseInit ¶

func NewUpdatePhaseInit(
	p fsm.ExecutorParams,
	operator ops.Operator,
	apps app.Applications,
	backend, localBackend storage.Backend,
	packages pack.PackageService,
	users users.Identity,
	client *kubernetes.Clientset,
	logger log.FieldLogger,
) (fsm.PhaseExecutor, error)

NewUpdatePhaseInit creates a new update init phase executor

func NewUpdatePhaseSELinux ¶

func NewUpdatePhaseSELinux(
	p fsm.ExecutorParams,
	operator ops.Operator,
	apps app.Applications,
	logger log.FieldLogger,
) (fsm.PhaseExecutor, error)

NewUpdatePhaseSELinux creates a new phase to configure SELinux on a node

func NewUpdatePhaseSystem ¶

func NewUpdatePhaseSystem(
	p fsm.ExecutorParams,
	remote fsm.Remote,
	backend storage.Backend,
	packages pack.PackageService,
	localPackages update.LocalPackageService,
	logger log.FieldLogger,
) (fsm.PhaseExecutor, error)

NewUpdatePhaseSystem returns a new node update phase executor