scheduler

package

v2.4.0 Latest Latest Go to latest Published: Nov 17, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kubeflow/spark-operator

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config interface{}

Config defines the configuration of a batch scheduler.

type Factory ¶

type Factory func(config Config) (Interface, error)

Factory defines the factory of a batch scheduler.

type Interface ¶

type Interface interface {
	Name() string
	ShouldSchedule(app *v1beta2.SparkApplication) bool
	Schedule(app *v1beta2.SparkApplication) error
	Cleanup(app *v1beta2.SparkApplication) error
}

Interface defines the interface of a batch scheduler.

type Registry ¶

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

Registry is a registry of scheduler factories.

func GetRegistry ¶

func GetRegistry() *Registry

func (*Registry) GetRegisteredSchedulerNames ¶

func (r *Registry) GetRegisteredSchedulerNames() []string

GetRegisteredSchedulerNames gets the registered scheduler names.

func (*Registry) GetScheduler ¶

func (r *Registry) GetScheduler(name string, config Config) (Interface, error)

func (*Registry) Register ¶

func (r *Registry) Register(name string, factory Factory) error

RegisterScheduler registers a scheduler to the manager.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
kubescheduler
volcano
yunikorn
resourceusage

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