ekscluster

Documentation

Index

• Constants
• Variables
• type CertificatesRenewer
  • func (*CertificatesRenewer) Renew() error
  • func (*CertificatesRenewer) SetProperties(_ []cluster.CertificatesRenewerProperty)
  • func (*CertificatesRenewer) SetProperty(_ string, _ any)
• type ClusterCreator
  • func (v *ClusterCreator) Create(startFrom string, timeout, _ int) error
  • func (v *ClusterCreator) CreateAsync(phases *Phases, startFrom string, vpnConnector *vpn.Connector, ...)
  • func (*ClusterCreator) GetPhasePath(phase string) (string, error)
  • func (v *ClusterCreator) RenderConfig() (map[string]any, 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 (v *ExtraSchemaValidator) Validate(confPath string) error
• type ExtraToolsValidator
  • func NewExtraToolsValidator(executor execx.Executor, autoConnect bool) *ExtraToolsValidator
  • func (x *ExtraToolsValidator) Validate(confPath string) ([]string, []error)
• type KubeconfigGetter
  • func (k *KubeconfigGetter) Get() error
  • func (k *KubeconfigGetter) SetProperties(props []cluster.KubeconfigProperty)
  • func (k *KubeconfigGetter) SetProperty(name string, value any)
• type Phases

Constants

const (
	InfrastructurePhaseSchemaPath = ".spec.infrastructure"
	KubernetesPhaseSchemaPath     = ".spec.kubernetes"
	DistributionPhaseSchemaPath   = ".spec.distribution"
	PluginsPhaseSchemaPath        = ".spec.plugins"
	AllPhaseSchemaPath            = ""
	StartFromFlagNotSet           = ""
)

Variables

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

var (
	ErrInvalidNodePoolSize                  = errors.New("invalid node pool size")
	ErrVPNBucketNamePrefix                  = errors.New(".spec.infrastructure.vpn.bucketNamePrefix is required when cluster name is longer than 19 characters")                                   //nolint: lll // long line
	ErrIAMUserNameOverride                  = errors.New(".spec.infrastructure.vpn.iamUserNameOverride is required when cluster name is longer than 19 characters")                                //nolint: lll // long line
	ErrClusterIAMRoleNamePrefixOverride     = errors.New(".spec.kubernetes.clusterIAMRoleNamePrefixOverride is required when cluster name is longer than 40 characters")                           //nolint: lll // long line
	ErrWorkersIAMRoleNamePrefixOverride     = errors.New(".spec.kubernetes.workersIAMRoleNamePrefixOverride is required when cluster name is longer than 40 characters")                           //nolint: lll // long line
	ErrEBSCSIDriverIAMRoleNameOverride      = errors.New(".spec.distribution.modules.aws.ebsCsiDriver.overrides.iamRoleName is required when cluster name is longer than 40 characters")           //nolint: lll // long line
	ErrClusterAutoscalerIAMRoleNameOverride = errors.New(".spec.distribution.modules.aws.clusterAutoscaler.overrides.iamRoleName is required when cluster name is longer than 40 characters")      //nolint: lll // long line
	ErrLBControllerIAMRoleNameOverride      = errors.New(".spec.distribution.modules.aws.loadbalancerController.overrides.iamRoleName is required when cluster name is longer than 40 characters") //nolint: lll // long line
)

var ErrOpenVPNNotInstalled = errors.New("openvpn is not installed")

var ErrRenewNotSupported = errors.New("you can't renew certificates for EKSCluster")

Types

type CertificatesRenewer

type CertificatesRenewer struct{}

func (*CertificatesRenewer) Renew

func (*CertificatesRenewer) Renew() error

func (*CertificatesRenewer) SetProperties

func (*CertificatesRenewer) SetProperties(_ []cluster.CertificatesRenewerProperty)

func (*CertificatesRenewer) SetProperty

func (*CertificatesRenewer) SetProperty(_ string, _ any)

type ClusterCreator

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

func (*ClusterCreator) Create

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

func (*ClusterCreator) CreateAsync

func (v *ClusterCreator) CreateAsync(
	phases *Phases,
	startFrom string,
	vpnConnector *vpn.Connector,
	upgr *upgrade.Upgrade,
	errCh chan error,
	doneCh chan bool,
)

func (*ClusterCreator) GetPhasePath

func (*ClusterCreator) GetPhasePath(phase string) (string, error)

func (*ClusterCreator) RenderConfig

func (v *ClusterCreator) RenderConfig() (map[string]any, 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 (v *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 KubeconfigGetter

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

func (*KubeconfigGetter) Get

func (k *KubeconfigGetter) Get() error

func (*KubeconfigGetter) SetProperties

func (k *KubeconfigGetter) SetProperties(props []cluster.KubeconfigProperty)

func (*KubeconfigGetter) SetProperty

func (k *KubeconfigGetter) SetProperty(name string, value any)

type Phases

type Phases struct {
	*create.PreFlight
	Infrastructure upgrade.OperatorPhaseAsync
	Kubernetes     upgrade.OperatorPhaseAsync
	Distribution   upgrade.ReducersOperatorPhaseAsync[reducers.Reducers]
	*commcreate.Plugins
}