controller

type ClusterInfo struct {
	// APIServer is the HTTPS endpoint of the Kubernetes API server
	// (e.g. "my-cluster-dns-abc123.hcp.eastus.azmk8s.io:443").
	APIServer string

	// CACertBase64 is the base64-encoded cluster CA certificate from the
	// kube-root-ca.crt ConfigMap in the kube-public namespace.
	CACertBase64 string

	// ClusterDNS is the ClusterIP of the kube-dns Service in kube-system.
	ClusterDNS string

	// Provider is the detected cluster provider (e.g. AKS). It is nil
	// when the provider cannot be determined.
	Provider cloudprovider.Provider

	// KubeVersion is the Kubernetes server version (e.g. "v1.34.2") obtained
	// from the API server's /version endpoint. It is used as the default
	// KUBE_VERSION for bootstrap scripts unless the Machine's
	// Spec.Kubernetes.Version overrides it.
	KubeVersion string
}

type Config struct {
	APIServerEndpoint       string        `yaml:"apiServerEndpoint"`
	MetricsAddr             string        `yaml:"metricsAddr"`
	ProbeAddr               string        `yaml:"probeAddr"`
	EnableLeaderElection    bool          `yaml:"enableLeaderElection"`
	MaxConcurrentReconciles int           `yaml:"maxConcurrentReconciles"`
	ProvisioningTimeout     time.Duration `yaml:"provisioningTimeout"`
}

type DefaultReachabilityChecker struct {
	Client  client.Reader
	Timeout time.Duration
}

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

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

type MachineProvisioner interface {
	ProvisionMachine(ctx context.Context, machine *unboundedv1alpha3.Machine, sshConfig *ssh.ClientConfig, bootstrapToken string, clusterInfo *ClusterInfo) error
}

type MachineReconciler struct {
	client.Client
	Scheme                      *runtime.Scheme
	ReachabilityChecker         ReachabilityChecker
	Provisioner                 MachineProvisioner
	ClusterInfo                 *ClusterInfo
	MaxConcurrentReconciles     int
	ProvisioningTimeoutDuration time.Duration
}

type ReachabilityChecker interface {
	CheckReachable(ctx context.Context, machine *unboundedv1alpha3.Machine) error
}