volcano

Documentation

Index

• func New() (schedulerinterface.BatchScheduler, error)
• type VolcanoBatchScheduler
  • func (v *VolcanoBatchScheduler) Name() string
  • func (v *VolcanoBatchScheduler) Schedule(cluster *v1beta1.FlinkCluster, state *model.DesiredClusterState) error

Functions

func New

func New() (schedulerinterface.BatchScheduler, error)

Create volcano BatchScheduler

Types

type VolcanoBatchScheduler

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

volcano scheduler implements the BatchScheduler interface.

func (*VolcanoBatchScheduler) Name

func (v *VolcanoBatchScheduler) Name() string

Name returns the current scheduler name.

func (*VolcanoBatchScheduler) Schedule

func (v *VolcanoBatchScheduler) Schedule(cluster *v1beta1.FlinkCluster, state *model.DesiredClusterState) error

Schedule reconciles batch scheduling