create

Documentation

Index

• Constants
• Variables
• type Distribution
  • func NewDistribution(paths cluster.CreatorPaths, furyctlConf private.EksclusterKfdV1Alpha2, ...) *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 Infrastructure
  • func NewInfrastructure(furyctlConf private.EksclusterKfdV1Alpha2, kfdManifest config.KFD, ...) *Infrastructure
  • func (i *Infrastructure) Exec(startFrom string, upgradeState *upgrade.State) error
  • func (i *Infrastructure) Self() *cluster.OperationPhase
  • func (i *Infrastructure) Stop() error
• type Kubernetes
  • func NewKubernetes(furyctlConf private.EksclusterKfdV1Alpha2, kfdManifest config.KFD, ...) *Kubernetes
  • func (k *Kubernetes) Exec(startFrom string, upgradeState *upgrade.State) error
  • func (k *Kubernetes) Self() *cluster.OperationPhase
  • func (k *Kubernetes) Stop() error
• type PreFlight
  • func NewPreFlight(furyctlConf private.EksclusterKfdV1Alpha2, kfdManifest config.KFD, ...) (*PreFlight, error)
  • func (p *PreFlight) CheckImmutablesDiffs(d r3diff.Changelog, diffChecker diffs.Checker) error
  • func (p *PreFlight) CheckReducersDiffs(d r3diff.Changelog, diffChecker diffs.Checker) error
  • func (p *PreFlight) CreateDiffChecker(storedCfgStr []byte) (diffs.Checker, error)
  • func (p *PreFlight) Exec() (*Status, error)
  • func (*PreFlight) GenerateDiffs(diffChecker diffs.Checker) (r3diff.Changelog, error)
  • func (p *PreFlight) GetStateFromCluster() ([]byte, error)
• type Status

Constants

const (
	LifecyclePreTf     = "pre-tf"
	LifecyclePostTf    = "post-tf"
	LifecyclePreApply  = "pre-apply"
	LifecyclePostApply = "post-apply"
)

Variables

var ErrAbortedByUser = errors.New("aborted by user")

Types

type Distribution

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

func NewDistribution

func NewDistribution(
	paths cluster.CreatorPaths,
	furyctlConf private.EksclusterKfdV1Alpha2,
	kfdManifest config.KFD,
	infraOutputsPath string,
	dryRun bool,
	phase string,
	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 Infrastructure

type Infrastructure struct {
	*common.Infrastructure
	// contains filtered or unexported fields
}

func NewInfrastructure

func NewInfrastructure(
	furyctlConf private.EksclusterKfdV1Alpha2,
	kfdManifest config.KFD,
	paths cluster.CreatorPaths,
	dryRun bool,
	upgr *upgrade.Upgrade,
) *Infrastructure

func (*Infrastructure) Exec

func (i *Infrastructure) Exec(startFrom string, upgradeState *upgrade.State) error

func (*Infrastructure) Self

func (i *Infrastructure) Self() *cluster.OperationPhase

func (*Infrastructure) Stop

func (i *Infrastructure) Stop() error

type Kubernetes

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

func NewKubernetes

func NewKubernetes(
	furyctlConf private.EksclusterKfdV1Alpha2,
	kfdManifest config.KFD,
	infraOutputsPath string,
	paths cluster.CreatorPaths,
	dryRun bool,
	upgr *upgrade.Upgrade,
) *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) Stop

func (k *Kubernetes) Stop() error

type PreFlight

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

Preflight is a phase tasked with ensuring cluster connectivity and checking for violations in the updates made on the furyctl.yaml file.

func NewPreFlight

func NewPreFlight(
	furyctlConf private.EksclusterKfdV1Alpha2,
	kfdManifest config.KFD,
	paths cluster.CreatorPaths,
	dryRun bool,
	vpnAutoConnect bool,
	skipVpn bool,
	force bool,
	infraOutputsPath string,
) (*PreFlight, error)

func (*PreFlight) CheckImmutablesDiffs

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

CheckImmutablesDiffs checks if there have been changes to immutable fields in the furyctl.yaml.

func (*PreFlight) CheckReducersDiffs

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

CheckReducersDiffs checks if the changes to the reducers are supported by the distribution. This is needed as not all from/to combinations are supported.

func (*PreFlight) CreateDiffChecker

func (p *PreFlight) CreateDiffChecker(storedCfgStr []byte) (diffs.Checker, error)

func (*PreFlight) Exec

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

func (*PreFlight) GenerateDiffs

func (*PreFlight) GenerateDiffs(diffChecker diffs.Checker) (r3diff.Changelog, error)

func (*PreFlight) GetStateFromCluster

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

type Status

type Status struct {
	Diffs   r3diff.Changelog
	Success bool
}