worker

Documentation

Index

• Constants
• Variables
• func AddToManager(ctx context.Context, mgr manager.Manager) error
• func AddToManagerWithOptions(ctx context.Context, mgr manager.Manager, opts AddOptions) error
• func NewActuator(mgr manager.Manager, gardenCluster cluster.Cluster) worker.Actuator
• func NewWorkerDelegate(client client.Client, scheme *runtime.Scheme, ...) (genericactuator.WorkerDelegate, error)
• func SanitizeGcpLabel(label string) string
• func SanitizeGcpLabelValue(value string) string
• type AddOptions
• type WorkerDelegate
  • func (w *WorkerDelegate) CleanupMachineDependencies(_ context.Context) error
  • func (w *WorkerDelegate) DeployMachineClasses(ctx context.Context) error
  • func (w *WorkerDelegate) DeployMachineDependencies(_ context.Context) error
  • func (w *WorkerDelegate) GenerateMachineDeployments(ctx context.Context) (worker.MachineDeployments, error)
  • func (w *WorkerDelegate) GetMachineClasses() []map[string]any
  • func (w *WorkerDelegate) MachineClass() client.Object
  • func (w *WorkerDelegate) MachineClassKind() string
  • func (w *WorkerDelegate) MachineClassList() client.ObjectList
  • func (w *WorkerDelegate) PostDeleteHook(_ context.Context) error
  • func (w *WorkerDelegate) PostReconcileHook(_ context.Context) error
  • func (w *WorkerDelegate) PreDeleteHook(_ context.Context) error
  • func (w *WorkerDelegate) PreReconcileHook(_ context.Context) error
  • func (w *WorkerDelegate) UpdateMachineImagesStatus(ctx context.Context) error

Constants

const (

	// ResourceGPU is the GPU resource. It should be a non-negative integer.
	ResourceGPU v1.ResourceName = "gpu"
	// VolumeTypeScratch is the gcp SCRATCH volume type
	VolumeTypeScratch = "SCRATCH"
)

Variables

var (
	// AllowedTypesIops are the volume types for which iops can be configured
	AllowedTypesIops = []string{persistentDiskExtreme, hyperDiskExtreme, hyperDiskBalanced}
	// AllowedTypesThroughput are the volume types for which throughput can be configured
	AllowedTypesThroughput = []string{hyperDiskThroughput, hyperDiskBalanced}
)

var (
	// DefaultAddOptions are the default AddOptions for AddToManager.
	DefaultAddOptions = AddOptions{}
)

var InitializeCapacity = initializeCapacity

InitializeCapacity is a handle to make the function accessible to the tests.

Functions

func AddToManager

func AddToManager(ctx context.Context, mgr manager.Manager) error

AddToManager adds a controller with the default Options.

func AddToManagerWithOptions

func AddToManagerWithOptions(ctx context.Context, mgr manager.Manager, opts AddOptions) error

AddToManagerWithOptions adds a controller with the given Options to the given manager. The opts.Reconciler is being set with a newly instantiated actuator.

func NewActuator

func NewActuator(mgr manager.Manager, gardenCluster cluster.Cluster) worker.Actuator

NewActuator creates a new Actuator that updates the status of the handled WorkerPoolConfigs.

func NewWorkerDelegate

func NewWorkerDelegate(
	client client.Client,
	scheme *runtime.Scheme,

	seedChartApplier gardener.ChartApplier,
	serverVersion string,

	worker *extensionsv1alpha1.Worker,
	cluster *extensionscontroller.Cluster,
) (genericactuator.WorkerDelegate, error)

NewWorkerDelegate creates a new context for a worker reconciliation.

func SanitizeGcpLabel

func SanitizeGcpLabel(label string) string

SanitizeGcpLabel will sanitize the label base on the gcp label Restrictions

func SanitizeGcpLabelValue

func SanitizeGcpLabelValue(value string) string

SanitizeGcpLabelValue will sanitize the value base on the gcp label Restrictions

Types

type AddOptions

type AddOptions struct {
	// GardenCluster is the garden cluster object.
	GardenCluster cluster.Cluster
	// Controller are the controller.Options.
	Controller controller.Options
	// IgnoreOperationAnnotation specifies whether to ignore the operation annotation or not.
	IgnoreOperationAnnotation bool
	// ExtensionClass defines the extension class this extension is responsible for.
	ExtensionClass extensionsv1alpha1.ExtensionClass
}

AddOptions are options to apply when adding the GCP worker controller to the manager.

type WorkerDelegate

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

WorkerDelegate handles the reconciliation of worker resources

func (*WorkerDelegate) CleanupMachineDependencies

func (w *WorkerDelegate) CleanupMachineDependencies(_ context.Context) error

CleanupMachineDependencies implements genericactuator.WorkerDelegate.

func (*WorkerDelegate) DeployMachineClasses

func (w *WorkerDelegate) DeployMachineClasses(ctx context.Context) error

DeployMachineClasses generates and creates the GCP specific machine classes.

func (*WorkerDelegate) DeployMachineDependencies

func (w *WorkerDelegate) DeployMachineDependencies(_ context.Context) error

DeployMachineDependencies implements genericactuator.WorkerDelegate.

func (*WorkerDelegate) GenerateMachineDeployments

func (w *WorkerDelegate) GenerateMachineDeployments(ctx context.Context) (worker.MachineDeployments, error)

GenerateMachineDeployments generates the configuration for the desired machine deployments.

func (*WorkerDelegate) GetMachineClasses

func (w *WorkerDelegate) GetMachineClasses() []map[string]any

GetMachineClasses returns the slice of machine classes contained inside the worker delegate. Introduced for Unit-testing.

func (*WorkerDelegate) MachineClass

func (w *WorkerDelegate) MachineClass() client.Object

MachineClass yields a newly initialized machine class object.

func (*WorkerDelegate) MachineClassKind

func (w *WorkerDelegate) MachineClassKind() string

MachineClassKind yields the name of the machine class kind used by GCP provider.

func (*WorkerDelegate) MachineClassList

func (w *WorkerDelegate) MachineClassList() client.ObjectList

MachineClassList yields a newly initialized MachineClassList object.

func (*WorkerDelegate) PostDeleteHook

func (w *WorkerDelegate) PostDeleteHook(_ context.Context) error

PostDeleteHook implements genericactuator.WorkerDelegate.

func (*WorkerDelegate) PostReconcileHook

func (w *WorkerDelegate) PostReconcileHook(_ context.Context) error

PostReconcileHook implements genericactuator.WorkerDelegate.

func (*WorkerDelegate) PreDeleteHook

func (w *WorkerDelegate) PreDeleteHook(_ context.Context) error

PreDeleteHook implements genericactuator.WorkerDelegate.

func (*WorkerDelegate) PreReconcileHook

func (w *WorkerDelegate) PreReconcileHook(_ context.Context) error

PreReconcileHook implements genericactuator.WorkerDelegate.

func (*WorkerDelegate) UpdateMachineImagesStatus

func (w *WorkerDelegate) UpdateMachineImagesStatus(ctx context.Context) error

UpdateMachineImagesStatus updates the machine image status with the used machine images for the `Worker` resource.