ekscluster

Documentation

Index

• Constants
• Variables
• 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 (*ExtraSchemaValidator) Validate(confPath string) error
• type ExtraToolsValidator
  • func NewExtraToolsValidator(executor execx.Executor, autoConnect bool) *ExtraToolsValidator
  • func (x *ExtraToolsValidator) Validate(confPath string) ([]string, []error)
• 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 = fmt.Errorf("invalid node pool size")

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

Types

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 (*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 Phases

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