eks

Documentation

Index

• Variables
• type ClusterCreator
  • func (v *ClusterCreator) Create(skipPhase string, timeout int) error
  • func (v *ClusterCreator) SetProperties(props []cluster.CreatorProperty)
  • func (v *ClusterCreator) SetProperty(name string, value any)
• type ClusterDeleter
  • func (d *ClusterDeleter) Delete() error
  • func (d *ClusterDeleter) SetProperties(props []cluster.DeleterProperty)
  • func (d *ClusterDeleter) SetProperty(name string, value any)
• type ExtraSchemaValidator
  • func (*ExtraSchemaValidator) Validate(confPath string) error
• type ExtraToolsValidator
  • func NewExtraToolsValidator(executor execx.Executor, autoConnect bool) *ExtraToolsValidator
  • func (x *ExtraToolsValidator) Validate(confPath string) ([]string, []error)
• type VpnConnector
  • func NewVpnConnector(clusterName, certDir, binPath, faVersion string, autoconnect, skip bool, ...) (*VpnConnector, error)
  • func (v *VpnConnector) ClientName() (string, error)
  • func (v *VpnConnector) Connect() error
  • func (v *VpnConnector) GenerateCertificates() error
  • func (v *VpnConnector) GetKillMessage() (string, error)
  • func (v *VpnConnector) IsConfigured() bool

Variables

var (
	ErrUnsupportedPhase = errors.New("unsupported phase")
	ErrInfraNotPresent  = errors.New("the configuration file does not contain an infrastructure section")
	ErrTimeout          = errors.New("timeout reached")
)

var (
	ErrOpenVPNNotInstalled       = errors.New("openvpn is not installed")
	ErrAWSS3BucketNotFound       = errors.New("AWS S3 Bucket not found, please create it before running furyctl")
	ErrAWSS3BucketRegionMismatch = errors.New("AWS S3 Bucket region mismatch")
)

var (
	ErrAutoConnectWithoutVpn = errors.New("autoconnect is not supported without a VPN configuration")
	ErrReadStdin             = errors.New("error reading from stdin")
)

var ErrInvalidNodePoolSize = fmt.Errorf("invalid node pool size")

Types

type ClusterCreator

type ClusterCreator struct {
	// contains filtered or unexported fields
}

func (*ClusterCreator) Create

func (v *ClusterCreator) Create(skipPhase string, timeout int) error

func (*ClusterCreator) SetProperties

func (v *ClusterCreator) SetProperties(props []cluster.CreatorProperty)

func (*ClusterCreator) SetProperty

func (v *ClusterCreator) SetProperty(name string, value any)

type ClusterDeleter

type ClusterDeleter struct {
	// contains filtered or unexported fields
}

func (*ClusterDeleter) Delete

func (d *ClusterDeleter) Delete() error

func (*ClusterDeleter) SetProperties

func (d *ClusterDeleter) SetProperties(props []cluster.DeleterProperty)

func (*ClusterDeleter) SetProperty

func (d *ClusterDeleter) SetProperty(name string, value any)

type ExtraSchemaValidator

type ExtraSchemaValidator struct{}

func (*ExtraSchemaValidator) Validate

func (*ExtraSchemaValidator) Validate(confPath string) error

type ExtraToolsValidator

type ExtraToolsValidator struct {
	// contains filtered or unexported fields
}

func NewExtraToolsValidator

func NewExtraToolsValidator(executor execx.Executor, autoConnect bool) *ExtraToolsValidator

func (*ExtraToolsValidator) Validate

func (x *ExtraToolsValidator) Validate(confPath string) ([]string, []error)

type VpnConnector

type VpnConnector struct {
	// contains filtered or unexported fields
}

func NewVpnConnector

func NewVpnConnector(
	clusterName,
	certDir,
	binPath,
	faVersion string,
	autoconnect,
	skip bool,
	config *private.SpecInfrastructureVpn,
) (*VpnConnector, error)

func (*VpnConnector) ClientName

func (v *VpnConnector) ClientName() (string, error)

func (*VpnConnector) Connect

func (v *VpnConnector) Connect() error

func (*VpnConnector) GenerateCertificates

func (v *VpnConnector) GenerateCertificates() error

func (*VpnConnector) GetKillMessage

func (v *VpnConnector) GetKillMessage() (string, error)

func (*VpnConnector) IsConfigured

func (v *VpnConnector) IsConfigured() bool