controllers

package

v0.0.0-...-bba01fb Latest Latest Go to latest Published: Feb 1, 2026 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation ¶

const DEFAULT_PASSWORD_LENGTH = 24

View Source

const (
	KeyProblemName = "problemName"
)

View Source

const MAX_USED_PERCENT float64 = 100.0

This section is empty.

This section is empty.

type CandidateWorker struct {
	// Name is the name of the worker.
	Name string

	// Score is the score of the worker (0..1).
	Score float64
}

type MetricsExporter struct {
	client.Client

	Log logr.Logger

	ScrapeInterval time.Duration
}

func (me *MetricsExporter) Start(ctx context.Context) error

Start implements manager.Runnable

type ProblemEnvironmentReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder

	Parameters SchedulerParameters
}

ProblemEnvironmentReconciler reconciles a ProblemEnvironment object

func (r *ProblemEnvironmentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (r *ProblemEnvironmentReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

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

ProblemReconciler reconciles a Problem object

func (r *ProblemReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (r *ProblemReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type SchedulerParameters struct {
	CPUWeight       float64
	MemoryWeight    float64
	MemoryThreshold float64
	Temperature     float64
}

type WorkerController struct {
	client.Client
	// contains filtered or unexported fields
}

func NewWorkerController(
	client client.Client,
	workerMonitorPeriod time.Duration,
	recorder record.EventRecorder,
) *WorkerController

func (wc *WorkerController) Start(ctx context.Context) error

Start implements manager.Runnable