api

package
v0.0.0-...-8f6c52d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 17, 2025 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Pipeline

type Pipeline interface {
	// Run the scheduling pipeline with the given request.
	Run(request Request) ([]string, error)
}

type PipelineRequest

type PipelineRequest api.ExternalSchedulerRequest

func (PipelineRequest) GetPipeline

func (r PipelineRequest) GetPipeline() string

func (PipelineRequest) GetSubjects

func (r PipelineRequest) GetSubjects() []string

func (PipelineRequest) GetTraceLogArgs

func (r PipelineRequest) GetTraceLogArgs() []slog.Attr

func (PipelineRequest) GetWeights

func (r PipelineRequest) GetWeights() map[string]float64

func (PipelineRequest) WithPipeline

func (r PipelineRequest) WithPipeline(pipeline string) scheduling.PipelineRequest

type Request

type Request interface {
	// Specification of the scheduling request.
	GetSpec() any
	// Request context from Manila that contains additional meta information.
	GetContext() api.ManilaRequestContext
	// List of hosts to be considered for scheduling.
	// If the list is nil, all hosts are considered.
	GetHosts() []string
	// Map of weights to start with.
	// If the map is nil, all hosts will have the default weight starting.
	GetWeights() map[string]float64
}

Request to the Cortex scheduling pipeline.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL