cluster

func Apply ¶

func Apply(ctx context.Context, cfg *config.Config, dryRun bool) error

Apply iterates over all nodes in the cluster, gracefully rolling updates to VM configurations (CPUs, Memory) one at a time to ensure zero downtime.

func Backup ¶

func Backup(ctx context.Context, cfg *config.Config, outputDir string) error

Backup creates an etcd snapshot on the init node and downloads it locally.

func Destroy ¶

func Destroy(ctx context.Context, cfg *config.Config, force, dryRun bool) error

Destroy tears down the entire cluster.

func Init ¶

func Init(ctx context.Context, cfg *config.Config, opts InitOptions) error

Init bootstraps a new cluster from scratch. It is idempotent.

func Join ¶

func Join(ctx context.Context, cfg *config.Config, dryRun bool) error

Join adds nodes that are in the config but not yet in the cluster.

func Reconcile ¶ added in v0.53.0

func Reconcile(ctx context.Context, cfg *config.Config, dryRun bool) error

Reconcile converges already-provisioned nodes to the current desired baseline without rebuilding them. Today that means ensuring the standard node package set (lima.NodePackages — notably socat, which kubectl port-forward and devx bridge need to carry traffic on Docker-runtime k3s nodes) is installed inside every node's Lima VM.

Unlike Init/Join it does not touch K3s or VM lifecycle — it only installs packages on nodes that already exist, so a cluster that predates a new node-level requirement can adopt it without a destroy/recreate. It is safe to run repeatedly: apt-get install is idempotent and already-satisfied nodes are fast no-ops. Nodes are reconciled in parallel.

func Remove ¶

func Remove(ctx context.Context, cfg *config.Config, hostName string, dryRun bool) error

Remove drains and removes a specific node from the cluster.

func Restore ¶

func Restore(ctx context.Context, cfg *config.Config, snapshotPath string) error

Restore restores etcd from a snapshot file.

func Status ¶

func Status(ctx context.Context, cfg *config.Config) error

Status displays the current state of all configured nodes.

func Upgrade ¶

func Upgrade(ctx context.Context, cfg *config.Config, dryRun bool) error

Upgrade performs a rolling upgrade of K3s across all nodes. Agents are upgraded first, then servers one at a time to maintain quorum.