provisioner

type ClusterHealth ¶ added in v0.3.0

type ClusterHealth struct {
	Healthy         bool
	TotalNodes      int
	ReadyNodes      int
	ControlPlanes   int
	Workers         int
	APIServerStatus string
	Nodes           []NodeHealth
	Message         string
}

ClusterHealth represents the health status of a multinode cluster

func GetClusterHealthFromEnv(log *logger.FunLogger, env *v1alpha1.Environment) (*ClusterHealth, error)

type ClusterProvisioner ¶ added in v0.3.0

type ClusterProvisioner struct {

	// SSH credentials
	KeyPath  string
	UserName string

	// Cluster information
	Environment *v1alpha1.Environment

	// JoinToken is generated after kubeadm init and used by joining nodes
	JoinToken string
	// CertificateKey is used for control-plane joins in HA mode
	CertificateKey string
	// ControlPlaneEndpoint is the API server endpoint (LB DNS or first CP IP)
	ControlPlaneEndpoint string
	// CACertHash is the CA certificate hash for secure joins
	CACertHash string
	// contains filtered or unexported fields
}

ClusterProvisioner handles provisioning of multinode Kubernetes clusters

func NewClusterProvisioner(log *logger.FunLogger, keyPath, userName string, env *v1alpha1.Environment) *ClusterProvisioner

func (cp *ClusterProvisioner) GetClusterHealth(firstCPHost string) (*ClusterHealth, error)

func (cp *ClusterProvisioner) ProvisionCluster(nodes []NodeInfo) error

type DependencyConfigurator ¶ added in v0.2.0

type DependencyConfigurator interface {
	Resolve() []ProvisionFunc
	// contains filtered or unexported methods
}

DependencyConfigurator defines methods for configuring dependencies

type DependencyResolver ¶ added in v0.2.0

type DependencyResolver struct {
	Dependencies []ProvisionFunc
	// contains filtered or unexported fields
}

DependencySolver is a struct that holds the dependency list

func NewDependencies(env *v1alpha1.Environment) *DependencyResolver

func (d *DependencyResolver) Resolve() []ProvisionFunc

func (d *DependencyResolver) SetBaseDir(dir string)

type DirectTransport ¶ added in v0.3.0

type DirectTransport = sshutil.DirectTransport

DirectTransport aliases sshutil.DirectTransport (direct TCP to host:22).

type NodeHealth ¶ added in v0.3.0

type NodeHealth struct {
	Name       string
	Role       string
	Ready      bool
	Status     string
	Version    string
	InternalIP string
}

NodeHealth represents the health status of a single node

type NodeInfo ¶ added in v0.3.0

type NodeInfo struct {
	Name        string
	PublicIP    string
	PrivateIP   string
	Role        string    // "control-plane" or "worker"
	SSHUsername string    // SSH username for this node (optional, falls back to ClusterProvisioner.UserName)
	InstanceID  string    // EC2 instance ID (used by SSMTransport for private-subnet nodes)
	Transport   Transport // Transport controls how SSH connections are established; nil falls back to DirectTransport
}

NodeInfo represents a node to be provisioned

type Option ¶ added in v0.3.0

type Option func(*Provisioner)

Option is a functional option for configuring a Provisioner.

func WithSSHConfig(cfg *v1alpha1.SSHConfig) Option

func WithTransport(t Transport) Option

type ProvisionFunc ¶

type ProvisionFunc func(tpl *bytes.Buffer, env v1alpha1.Environment) error

type Provisioner ¶

type Provisioner struct {
	Client         *ssh.Client
	SessionManager *ssm.Client

	HostUrl  string
	UserName string
	KeyPath  string
	// contains filtered or unexported fields
}

func New(log *logger.FunLogger, keyPath, userName, hostUrl string, opts ...Option) (*Provisioner, error)

func (p *Provisioner) Close() error

func (p *Provisioner) Run(env v1alpha1.Environment) (*v1alpha1.ComponentsStatus, error)

type SSMTransport ¶ added in v0.3.0

type SSMTransport struct {
	InstanceID string
	Region     string
	Profile    string
	// contains filtered or unexported fields
}

SSMTransport establishes SSH connections through AWS Systems Manager (SSM) port forwarding. This is used for cluster nodes in private subnets that do not have public IP addresses.

Known limitation (D2): There is a TOCTOU race between finding a free port and starting the SSM session. If the port is taken between these two operations, Dial() will fail with "connection refused" after SSM started. The caller should retry with a new SSMTransport instance if this occurs.

func (s *SSMTransport) Close() error

func (s *SSMTransport) DialContext(ctx context.Context) (net.Conn, error)

func (s *SSMTransport) Target() string

type Transport ¶ added in v0.3.0

type Transport = sshutil.Transport

Transport is the SSH connection transport, now owned by pkg/sshutil. The alias keeps the provisioner package's public surface stable while the single canonical Transport interface (DialContext/Target/Close) lives in sshutil.