create

Documentation

Index

• Constants
• Variables
• type Distribution
  • func NewDistribution(paths cluster.CreatorPaths, furyctlConf public.KfddistributionKfdV1Alpha2, ...) *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)
  • 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, 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"
)

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(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)

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 []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(storedCfgStr []byte, 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
}