common

Documentation

Index

• Constants
• Variables
• type Distribution
  • func (d *Distribution) InjectDataPostTf(fMerger *merge.Merger) (*merge.Merger, error)
  • func (d *Distribution) InjectStoredConfig(cfg *template.Config) error
  • func (d *Distribution) PreparePostTerraform(furyctlMerger *merge.Merger, preTfMerger *merge.Merger) (*template.Config, error)
  • func (d *Distribution) PreparePreTerraform() (*merge.Merger, *merge.Merger, *template.Config, error)
• type Infrastructure
  • func (i *Infrastructure) Prepare() error
• type InjectType
• type Kubernetes
  • func (k *Kubernetes) Prepare() error
• type PreFlight
  • func (p *PreFlight) EnsureTerraformStateAWSS3Bucket() error
  • func (p *PreFlight) HandleVPN() error
  • func (p *PreFlight) IsVPNRequired() bool
  • func (p *PreFlight) Prepare() error

Constants

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")
	ErrCastingVpcIDToStr = errors.New("error casting vpc_id output to string")
	ErrVpcCIDRNotFound   = errors.New("vpc_cidr_block not found in infra output")
	ErrPvtSubnetFromOut  = errors.New("cannot read private_subnets from infrastructure's output.json")
	ErrVpcCIDRFromOut    = errors.New("cannot read vpc_cidr_block from infrastructure's output.json")
	ErrPvtSubnetNotFound = errors.New("private_subnets not found in infrastructure phase's output")
)

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

Types

type Distribution

type Distribution struct {
	*cluster.OperationPhase

	DryRun                             bool
	DistroPath                         string
	ConfigPath                         string
	InfrastructureTerraformOutputsPath string
	FuryctlConf                        private.EksclusterKfdV1Alpha2
	StateStore                         state.Storer
	TFRunner                           *terraform.Runner
}

func (*Distribution) InjectDataPostTf

func (d *Distribution) InjectDataPostTf(fMerger *merge.Merger) (*merge.Merger, error)

func (*Distribution) InjectStoredConfig

func (d *Distribution) InjectStoredConfig(cfg *template.Config) error

func (*Distribution) PreparePostTerraform

func (d *Distribution) PreparePostTerraform(
	furyctlMerger *merge.Merger,
	preTfMerger *merge.Merger,
) (*template.Config, error)

func (*Distribution) PreparePreTerraform

func (d *Distribution) PreparePreTerraform() (
	*merge.Merger,
	*merge.Merger,
	*template.Config,
	error,
)

type Infrastructure

type Infrastructure struct {
	*cluster.OperationPhase

	FuryctlConf private.EksclusterKfdV1Alpha2
	ConfigPath  string
	DistroPath  string
}

func (*Infrastructure) Prepare

func (i *Infrastructure) Prepare() error

type InjectType

type InjectType struct {
	Data private.SpecDistribution `json:"data"`
}

type Kubernetes

type Kubernetes struct {
	*cluster.OperationPhase

	FuryctlConf                        private.EksclusterKfdV1Alpha2
	FuryctlConfPath                    string
	DistroPath                         string
	KFDManifest                        config.KFD
	DryRun                             bool
	InfrastructureTerraformOutputsPath string
}

func (*Kubernetes) Prepare

func (k *Kubernetes) Prepare() error

type PreFlight

type PreFlight struct {
	*cluster.OperationPhase

	FuryctlConf                        private.EksclusterKfdV1Alpha2
	ConfigPath                         string
	AWSRunner                          *awscli.Runner
	VPNConnector                       *vpn.Connector
	TFRunnerInfra                      *terraform.Runner
	InfrastructureTerraformOutputsPath string
}

func (*PreFlight) EnsureTerraformStateAWSS3Bucket

func (p *PreFlight) EnsureTerraformStateAWSS3Bucket() error

func (*PreFlight) HandleVPN

func (p *PreFlight) HandleVPN() error

func (*PreFlight) IsVPNRequired

func (p *PreFlight) IsVPNRequired() bool

func (*PreFlight) Prepare

func (p *PreFlight) Prepare() error