extender

Documentation

Index

• Constants
• func New(arguments framework.Arguments) framework.Plugin
• type JobEnqueueableRequest
• type JobEnqueueableResponse
• type OnSessionCloseRequest
• type OnSessionCloseResponse
• type OnSessionOpenRequest
• type OnSessionOpenResponse
• type PredicateRequest
• type PredicateResponse
• type PreemptableRequest
• type PreemptableResponse
• type PrioritizeRequest
• type PrioritizeResponse
• type QueueOverusedRequest
• type QueueOverusedResponse
• type ReclaimableRequest
• type ReclaimableResponse

Constants

const (
	// PluginName indicates name of volcano scheduler plugin.
	PluginName = "extender"

	// ExtenderURLPrefix is the key for providing extender endpoint address
	ExtenderURLPrefix = "extender.urlPrefix"
	// ExtenderHTTPTimeout is the timeout for extender http calls
	ExtenderHTTPTimeout = "extender.httpTimeout"
	// ExtenderOnSessionOpenVerb is the verb of OnSessionOpen method
	ExtenderOnSessionOpenVerb = "extender.onSessionOpenVerb"
	// ExtenderOnSessionCloseVerb is the verb of OnSessionClose method
	ExtenderOnSessionCloseVerb = "extender.onSessionCloseVerb"
	// ExtenderPredicateVerb is the verb of Predicate method
	ExtenderPredicateVerb = "extender.predicateVerb"
	// ExtenderPrioritizeVerb is the verb of Prioritize method
	ExtenderPrioritizeVerb = "extender.prioritizeVerb"
	// ExtenderPreemptableVerb is the verb of Preemptable method
	ExtenderPreemptableVerb = "extender.preemptableVerb"
	// ExtenderReclaimableVerb is the verb of Reclaimable method
	ExtenderReclaimableVerb = "extender.reclaimableVerb"
	// ExtenderQueueOverusedVerb is the verb of QueueOverused method
	ExtenderQueueOverusedVerb = "extender.queueOverusedVerb"
	// ExtenderJobEnqueueableVerb is the verb of JobEnqueueable method
	ExtenderJobEnqueueableVerb = "extender.jobEnqueueableVerb"
	// ExtenderIgnorable indicates whether the extender can ignore unexpected errors
	ExtenderIgnorable = "extender.ignorable"
)

Functions

func New

func New(arguments framework.Arguments) framework.Plugin

Types

type JobEnqueueableRequest

type JobEnqueueableRequest struct {
	Job *api.JobInfo `json:"job"`
}

type JobEnqueueableResponse

type JobEnqueueableResponse struct {
	Status int `json:"status"`
}

type OnSessionCloseRequest

type OnSessionCloseRequest struct{}

type OnSessionCloseResponse

type OnSessionCloseResponse struct{}

type OnSessionOpenRequest

type OnSessionOpenRequest struct {
	Jobs           map[api.JobID]*api.JobInfo
	Nodes          map[string]*api.NodeInfo
	Queues         map[api.QueueID]*api.QueueInfo
	NamespaceInfo  map[api.NamespaceName]*api.NamespaceInfo
	RevocableNodes map[string]*api.NodeInfo
	NodeList       []string
}

type OnSessionOpenResponse

type OnSessionOpenResponse struct{}

type PredicateRequest

type PredicateRequest struct {
	Task *api.TaskInfo `json:"task"`
	Node *api.NodeInfo `json:"node"`
}

type PredicateResponse

type PredicateResponse struct {
	ErrorMessage string `json:"errorMessage"`
}

type PreemptableRequest

type PreemptableRequest struct {
	Evictor  *api.TaskInfo   `json:"evictor"`
	Evictees []*api.TaskInfo `json:"evictees"`
}

type PreemptableResponse

type PreemptableResponse struct {
	Status  int             `json:"status"`
	Victims []*api.TaskInfo `json:"victims"`
}

type PrioritizeRequest

type PrioritizeRequest struct {
	Task  *api.TaskInfo   `json:"task"`
	Nodes []*api.NodeInfo `json:"nodes"`
}

type PrioritizeResponse

type PrioritizeResponse struct {
	NodeScore    map[string]float64 `json:"nodeScore"`
	ErrorMessage string             `json:"errorMessage"`
}

type QueueOverusedRequest

type QueueOverusedRequest struct {
	Queue *api.QueueInfo `json:"queue"`
}

type QueueOverusedResponse

type QueueOverusedResponse struct {
	Overused bool `json:"overused"`
}

type ReclaimableRequest

type ReclaimableRequest PreemptableRequest

type ReclaimableResponse

type ReclaimableResponse PreemptableResponse