framework

type Code int

type FilterPlugin interface {
	Plugin

	Filter(ctx context.Context, QueueUnit *QueueUnitInfo) *Status
}

type Framework interface {
	// QueueSortFunc returns the function to sort pods in scheduling queue
	MultiQueueSortFunc() MultiQueueLessFunc
	QueueSortFuncMap() map[string]QueueLessFunc
	RunFilterPlugins(context.Context, *QueueUnitInfo) *Status
	RunScorePlugins(context.Context) (int64, bool)
	RunReservePluginsReserve(context.Context, *QueueUnitInfo) *Status
	RunReservePluginsUnreserve(context.Context, *QueueUnitInfo)
}

type Handle interface {
	SharedInformerFactory() informers.SharedInformerFactory
	KubeConfigPath() string
	QueueUnitClient() *versioned.Clientset
}

type MultiQueueLessFunc func(*QueueInfo, *QueueInfo) bool

type MultiQueueSortPlugin interface {
	Plugin
	MultiQueueLess(*QueueInfo, *QueueInfo) bool
}

type Plugin interface {
	Name() string
}

type QueueInfo struct {
	Name     string
	Priority int32
	Queue    *v1alpha1.Queue
}

type QueueLessFunc func(*QueueUnitInfo, *QueueUnitInfo) bool

type QueueSortPlugin interface {
	Plugin
	QueueLess(*QueueUnitInfo, *QueueUnitInfo) bool
}

type QueueUnitInfo struct {
	// Name is namespace + "/" + name
	Name string
	Unit *v1alpha1.QueueUnit
	// The time QueueUnit added to the scheduling queue.
	Timestamp time.Time
	// Number of schedule attempts before successfully scheduled.
	Attempts int
	// The time when the QueueUnit is added to the queue for the first time.
	InitialAttemptTimestamp time.Time
}

type ReservePlugin interface {
	Plugin
	Reserve(ctx context.Context, QueueUnit *QueueUnitInfo) *Status
	Unreserve(ctx context.Context, QueueUnit *QueueUnitInfo)
}

type ScorePlugin interface {
	Plugin
	Score(ctx context.Context, p *v1.Pod) (int64, bool)
}

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