create

Documentation

Index

• Constants
• Variables
• type Distribution
  • func NewDistribution(paths cluster.CreatorPaths, furyctlConf public.KfddistributionKfdV1Alpha2, ...) *Distribution
  • func (d *Distribution) Exec(reducers v1alpha2.Reducers, startFrom string, upgradeState *upgrade.State) error
  • func (d *Distribution) Self() *cluster.OperationPhase
  • func (d *Distribution) Stop() error
  • func (*Distribution) SupportsLifecycle(lifecycle string) bool
• type PreFlight
  • func NewPreFlight(furyctlConf public.KfddistributionKfdV1Alpha2, 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(storedCfgStr []byte) (diffs.Checker, error)
  • func (p *PreFlight) Exec() (*Status, error)
  • func (p *PreFlight) GetStateFromCluster() ([]byte, error)
• type Status

Constants

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

Variables

var (
	ErrKubeconfigNotSet = errors.New("KUBECONFIG env variable is not set")
)

Types

type Distribution

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

func NewDistribution

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

func (*Distribution) Exec

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

func (*Distribution) Self

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

func (*Distribution) Stop

func (d *Distribution) Stop() error

func (*Distribution) SupportsLifecycle

func (*Distribution) SupportsLifecycle(lifecycle string) bool

type PreFlight

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

func NewPreFlight

func NewPreFlight(
	furyctlConf public.KfddistributionKfdV1Alpha2,
	kfdManifest config.KFD,
	paths cluster.CreatorPaths,
	dryRun bool,
	stateStore state.Storer,
	force 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(storedCfgStr []byte) (diffs.Checker, error)

func (*PreFlight) Exec

func (p *PreFlight) Exec() (*Status, error)

func (*PreFlight) GetStateFromCluster

func (p *PreFlight) GetStateFromCluster() ([]byte, error)

type Status

type Status struct {
	Diffs   r3diff.Changelog
	Success bool
}