infrastructure

Documentation

Index

• Variables
• type ClusterController
  • func (r *ClusterController) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)
  • func (r *ClusterController) SetupWithManager(mgr ctrl.Manager) error
• type JobProvisioner
  • func (p *JobProvisioner) Cleanup(_ context.Context, mode RemoteMachineMode) error
  • func (p *JobProvisioner) Provision(ctx context.Context) error
• type Provisioner
• type RemoteMachineController
  • func (r *RemoteMachineController) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)
  • func (r *RemoteMachineController) SetupWithManager(mgr ctrl.Manager) error
• type RemoteMachineMode
• type SSHProvisioner
  • func (p *SSHProvisioner) Cleanup(_ context.Context, mode RemoteMachineMode) error
  • func (p *SSHProvisioner) Provision(_ context.Context) error

Variables

var ErrPooledMachineNotFound = fmt.Errorf("free pooled machine not found")

Types

type ClusterController

type ClusterController struct {
	client.Client
	Scheme *runtime.Scheme
}

func (*ClusterController) Reconcile

func (r *ClusterController) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

func (*ClusterController) SetupWithManager

func (r *ClusterController) SetupWithManager(mgr ctrl.Manager) error

type JobProvisioner

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

func (*JobProvisioner) Cleanup

func (p *JobProvisioner) Cleanup(_ context.Context, mode RemoteMachineMode) error

func (*JobProvisioner) Provision

func (p *JobProvisioner) Provision(ctx context.Context) error

type Provisioner

type Provisioner interface {
	Provision(ctx context.Context) error
	Cleanup(ctx context.Context, mode RemoteMachineMode) error
}

type RemoteMachineController

type RemoteMachineController struct {
	client.Client
	Scheme     *runtime.Scheme
	ClientSet  *kubernetes.Clientset
	RESTConfig *rest.Config
}

func (*RemoteMachineController) Reconcile

func (r *RemoteMachineController) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, err error)

func (*RemoteMachineController) SetupWithManager

func (r *RemoteMachineController) SetupWithManager(mgr ctrl.Manager) error

type RemoteMachineMode

type RemoteMachineMode int

const (
	RemoteMachineFinalizer = "remotemachine.k0smotron.io/finalizer"

	ModeController RemoteMachineMode = iota
	ModeWorker
	ModeNonK0s
)

type SSHProvisioner

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

func (*SSHProvisioner) Cleanup

func (p *SSHProvisioner) Cleanup(_ context.Context, mode RemoteMachineMode) error

Cleanup cleans up a machine The provisioning process is as follows: 1. Open SSH connection to the machine 2. Stops k0s 3. Removes node from etcd 4. Runs k0s reset

func (*SSHProvisioner) Provision

func (p *SSHProvisioner) Provision(_ context.Context) error

Provision provisions a new machine The provisioning process is as follows: 1. Open SSH connection to the machine 2. Execute the bootstrap script 3. Check sentinel file at /run/cluster-api/bootstrap-success.complete 4. success