volcano

Documentation

Index

• func Factory(config scheduler.Config) (scheduler.Interface, error)
• type Config
• type Scheduler
  • func (s *Scheduler) Cleanup(app *v1beta2.SparkApplication) error
  • func (s *Scheduler) Name() string
  • func (s *Scheduler) Schedule(app *v1beta2.SparkApplication) error
  • func (s *Scheduler) ShouldSchedule(_ *v1beta2.SparkApplication) bool

Functions

func Factory

func Factory(config scheduler.Config) (scheduler.Interface, error)

Factory creates a new VolcanoScheduler instance.

Types

type Config

type Config struct {
	RestConfig *rest.Config
}

Config defines the configurations of Volcano scheduler.

type Scheduler

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

Scheduler is a batch scheduler that uses Volcano to schedule Spark applications.

func (*Scheduler) Cleanup

func (s *Scheduler) Cleanup(app *v1beta2.SparkApplication) error

Cleanup implements batchscheduler.Interface.

func (*Scheduler) Name

func (s *Scheduler) Name() string

Name implements batchscheduler.Interface.

func (*Scheduler) Schedule

func (s *Scheduler) Schedule(app *v1beta2.SparkApplication) error

Schedule implements batchscheduler.Interface.

func (*Scheduler) ShouldSchedule

func (s *Scheduler) ShouldSchedule(_ *v1beta2.SparkApplication) bool

ShouldSchedule implements batchscheduler.Interface.