create

Documentation

Index

• Constants
• type Distribution
  • func NewDistribution(furyctlConf public.OnpremisesKfdV1Alpha2, kfdManifest config.KFD, ...) *Distribution
  • func (d *Distribution) Exec(rdcs reducers.Reducers, startFrom string, upgradeState *upgrade.State) error
  • func (d *Distribution) Self() *cluster.OperationPhase
  • func (d *Distribution) SetUpgrade(upgradeEnabled bool)
• type Kubernetes
  • func NewKubernetes(furyctlConf public.OnpremisesKfdV1Alpha2, kfdManifest config.KFD, ...) *Kubernetes
  • func (k *Kubernetes) Exec(startFrom string, upgradeState *upgrade.State) error
  • func (k *Kubernetes) Self() *cluster.OperationPhase
  • func (k *Kubernetes) SetUpgrade(upgradeEnabled bool)
• type PreFlight
  • func NewPreFlight(furyctlConf public.OnpremisesKfdV1Alpha2, kfdManifest config.KFD, ...) *PreFlight
  • func (p *PreFlight) CheckReducerDiffs(d r3diff.Changelog, diffChecker diffs.Checker) error
  • func (p *PreFlight) CheckStateDiffs(d r3diff.Changelog, diffChecker diffs.Checker) error
  • func (p *PreFlight) CreateDiffChecker(renderedConfig map[string]any) (diffs.Checker, error)
  • func (p *PreFlight) Exec(renderedConfig map[string]any) (*Status, error)
• type Status

Constants

const (
	LifecyclePreApply  = "pre-apply"
	LifecyclePostApply = "post-apply"
)

const FromSecondsToHalfMinuteRetries = 30

Types

type Distribution

type Distribution struct {
	*cluster.OperationPhase
	// contains filtered or unexported fields
}

func NewDistribution

func NewDistribution(
	furyctlConf public.OnpremisesKfdV1Alpha2,
	kfdManifest config.KFD,
	paths cluster.CreatorPaths,
	dryRun bool,
	upgr *upgrade.Upgrade,
) *Distribution

func (*Distribution) Exec

func (d *Distribution) Exec(rdcs reducers.Reducers, startFrom string, upgradeState *upgrade.State) error

func (*Distribution) Self

func (d *Distribution) Self() *cluster.OperationPhase

func (*Distribution) SetUpgrade

func (d *Distribution) SetUpgrade(upgradeEnabled bool)

type Kubernetes

type Kubernetes struct {
	*cluster.OperationPhase
	// contains filtered or unexported fields
}

func NewKubernetes

func NewKubernetes(
	furyctlConf public.OnpremisesKfdV1Alpha2,
	kfdManifest config.KFD,
	paths cluster.CreatorPaths,
	dryRun bool,
	upgr *upgrade.Upgrade,
	upgradeNode string,
	force []string,
	podRunningTimeout int,
) *Kubernetes

func (*Kubernetes) Exec

func (k *Kubernetes) Exec(startFrom string, upgradeState *upgrade.State) error

func (*Kubernetes) Self

func (k *Kubernetes) Self() *cluster.OperationPhase

func (*Kubernetes) SetUpgrade

func (k *Kubernetes) SetUpgrade(upgradeEnabled bool)

type PreFlight

type PreFlight struct {
	*cluster.OperationPhase
	// contains filtered or unexported fields
}

func NewPreFlight

func NewPreFlight(
	furyctlConf public.OnpremisesKfdV1Alpha2,
	kfdManifest config.KFD,
	paths cluster.CreatorPaths,
	dryRun bool,
	stateStore state.Storer,
	force []string,
	phase string,
	upgradeEnabled bool,
) *PreFlight

func (*PreFlight) CheckReducerDiffs

func (p *PreFlight) CheckReducerDiffs(d r3diff.Changelog, diffChecker diffs.Checker) error

func (*PreFlight) CheckStateDiffs

func (p *PreFlight) CheckStateDiffs(d r3diff.Changelog, diffChecker diffs.Checker) error

func (*PreFlight) CreateDiffChecker

func (p *PreFlight) CreateDiffChecker(renderedConfig map[string]any) (diffs.Checker, error)

func (*PreFlight) Exec

func (p *PreFlight) Exec(renderedConfig map[string]any) (*Status, error)

type Status

type Status struct {
	Diffs   r3diff.Changelog
	Success bool
}