nodepool_controller

Documentation

Index

• Constants
• Variables
• type GCPMachineState
• type GCPServiceAccount
• type GCPWorkerValues
• type JobVars
• type Reconciler
  • func (r *Reconciler) AwsJobValuesJson(obj *clustersv1.NodePool, nodesMap map[string]clustersv1.NodeProps) (string, error)
  • func (r *Reconciler) GCPJobValuesJson(obj *clustersv1.NodePool, nodesMap map[string]clustersv1.NodeProps) (string, error)
  • func (r *Reconciler) GetName() string
  • func (r *Reconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
  • func (r *Reconciler) SetupWithManager(mgr ctrl.Manager, logger logging.Logger) error

Constants

const (
	GCPMachineStateOn  = "on"
	GCPMachineStateOff = "off"
)

Variables

var DeleteChecklist = []rApi.CheckMeta{
	{Name: deletingNodepool, Title: "Deleting Nodepool"},
}

Types

type GCPMachineState

type GCPMachineState string

type GCPServiceAccount

type GCPServiceAccount struct {
	Enabled bool     `json:"enabled"`
	Email   *string  `json:"email,omitempty"`
	Scopes  []string `json:"scopes,omitempty"`
}

type GCPWorkerValues

type GCPWorkerValues struct {
	GCPProjectID       string `json:"gcp_project_id"`
	GCPRegion          string `json:"gcp_region"`
	GCPCredentialsJSON string `json:"gcp_credentials_json"`

	NamePrefix   string `json:"name_prefix"`
	NodepoolName string `json:"nodepool_name"`

	ProvisionMode string `json:"provision_mode"`

	AvailabilityZone string `json:"availability_zone"`

	Network        string `json:"network"`
	BootVolumeType string `json:"bootvolume_type"`
	BootVolumeSize int    `json:"bootvolume_size"`

	ServiceAccount GCPServiceAccount `json:"service_account"`

	Nodes map[string]any `json:"nodes"`

	NodeLabels   map[string]string `json:"node_labels"`
	MachineType  string            `json:"machine_type"`
	MachineState GCPMachineState   `json:"machine_state"`

	K3sServerPublicDNSHost string   `json:"k3s_server_public_dns_host"`
	K3sJoinToken           string   `json:"k3s_join_token"`
	K3sExtraAgentArgs      []string `json:"k3s_extra_agent_args"`

	K3sDownloadURL             string `json:"k3s_download_url"`
	KloudliteRunnerDownloadURL string `json:"kloudlite_runner_download_url"`

	ClusterInternalDNSHost   string            `json:"cluster_internal_dns_host"`
	SaveSSHKeyToPath         string            `json:"save_ssh_key_to_path"`
	KloudliteRelease         string            `json:"kloudlite_release"`
	LabelCloudproviderRegion string            `json:"label_cloudprovider_region"`
	Labels                   map[string]string `json:"labels"`

	AllowIncomingHttpTraffic bool `json:"allow_incoming_http_traffic"`
	AllowSSH                 bool `json:"allow_ssh"`
}

type JobVars

type JobVars struct {
	JobName         string
	JobNamespace    string
	JobNodeSelector map[string]string

	IACJobImage string
	Labels      map[string]string
	Annotations map[string]string

	OwnerRefs []metav1.OwnerReference

	NodepoolName           string
	TfStateSecretNamespace string

	ValuesJson string
}

type Reconciler

type Reconciler struct {
	client.Client
	Scheme *runtime.Scheme
	Env    *env.Env

	Name string
	// contains filtered or unexported fields
}

func (*Reconciler) AwsJobValuesJson

func (r *Reconciler) AwsJobValuesJson(obj *clustersv1.NodePool, nodesMap map[string]clustersv1.NodeProps) (string, error)

func (*Reconciler) GCPJobValuesJson

func (r *Reconciler) GCPJobValuesJson(obj *clustersv1.NodePool, nodesMap map[string]clustersv1.NodeProps) (string, error)

func (*Reconciler) GetName

func (r *Reconciler) GetName() string

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

func (*Reconciler) SetupWithManager

func (r *Reconciler) SetupWithManager(mgr ctrl.Manager, logger logging.Logger) error