Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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.
Click to show internal directories.
Click to hide internal directories.