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() (diffs.Checker, error)
  • func (p *PreFlight) Exec() (*Status, error)
  • func (*PreFlight) GenerateDiffs(diffChecker diffs.Checker) (r3diff.Changelog, error)
• type Status

Constants

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

const SErrWrapWithStr = "%w: %s"

Variables

var (
	ErrVpcIDNotFound = errors.New("vpc_id not found in infra output")
	ErrVpcIDFromOut  = errors.New("cannot read vpc_id from infrastructure's output.json")
	ErrWritingTfVars = errors.New("error writing terraform variables file")
	ErrAbortedByUser = errors.New("aborted by user")
)

var (
	ErrAWSS3BucketNotFound                   = errors.New("AWS S3 Bucket not found")
	ErrAWSS3BucketRegionMismatch             = errors.New("AWS S3 Bucket region mismatch")
	ErrCannotCreateTerraformStateAWSS3Bucket = errors.New("cannot create terraform state aws s3 bucket")
	ErrEnsureTerraformStateAWSS3Bucket       = errors.New("cannot ensure terraform state aws s3 bucket is present")

	ErrPreflightFailed = errors.New("preflight execution failed")
)

Types

type Distribution

type Distribution struct {
	*cluster.OperationPhase
	// 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 {
	*cluster.OperationPhase
	// 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 {
	*cluster.OperationPhase
	// 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 {
	*cluster.OperationPhase
	// 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,
) (*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() (diffs.Checker, error)

func (*PreFlight) Exec

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

func (*PreFlight) GenerateDiffs

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

type Status

type Status struct {
	Diffs   r3diff.Changelog
	Success bool
}