nova

type Cleanup struct {
	// Client for the kubernetes API.
	client.Client
	// Kubernetes scheme to use for the deschedulings.
	Scheme *runtime.Scheme
}

type CleanupOnStartup struct{ *Cleanup }

type CycleDetector interface {
	// Filter descheduling decisions to avoid cycles.
	Filter(ctx context.Context, decisions []plugins.Decision) ([]plugins.Decision, error)
}

type DeschedulingsPipelineController struct {
	// Toolbox shared between all pipeline controllers.
	lib.BasePipelineController[Pipeline]

	// Database to pass down to all steps.
	DB db.DB
	// Monitor to pass down to all pipelines.
	Monitor Monitor
	// Config for the scheduling operator.
	Conf conf.Config
	// Cycle detector to avoid descheduling loops.
	CycleDetector CycleDetector
}

type Executor struct {
	// Client for the kubernetes API.
	client.Client
	// Kubernetes scheme to use for the deschedulings.
	Scheme *runtime.Scheme

	// Nova API to execute the descheduling operations.
	NovaAPI NovaAPI
	// Configuration for the descheduler.
	Conf conf.Config
	// Monitor for tracking the descheduler execution.
	Monitor Monitor
}

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

type NovaAPI interface {
	// Initialize the Nova API with the Keystone authentication.
	Init(ctx context.Context)
	// Get a server by ID.
	Get(ctx context.Context, id string) (server, error)
	// Live migrate a server to a new host (doesnt wait for it to complete).
	LiveMigrate(ctx context.Context, id string) error
	// Get migrations for a server by ID.
	GetServerMigrations(ctx context.Context, id string) ([]migration, error)
}

type Pipeline struct {
	// Kubernetes client to create descheduling resources.
	client.Client
	// Cycle detector to avoid cycles in descheduling.
	CycleDetector CycleDetector
	// Monitor to use for tracking the pipeline.
	Monitor Monitor
	// contains filtered or unexported fields
}

type Step interface {
	// Get the VMs on their current hosts that should be considered for descheduling.
	Run() ([]plugins.Decision, error)
	// Get the name of this step, used for identification in config, logs, metrics, etc.
	GetName() string
	// Configure the step with a database and options.
	Init(db db.DB, opts conf.RawOpts) error
}

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