framework

type Action interface {
	// The unique name of Action.
	Name() string

	// Initialize initializes the allocator plugins.
	Initialize()

	// Execute allocates the cluster's resources into each queue.
	Execute(ssn *Session)

	// UnIntialize un-initializes the allocator plugins.
	UnInitialize()
}

type Event struct {
	Task *api.TaskInfo
}

type EventHandler struct {
	AllocateFunc func(event *Event)
	EvictFunc    func(event *Event)
}

type Plugin interface {
	OnSessionOpen(ssn *Session)
	OnSessionClose(ssn *Session)
}

type PluginArgs struct {
	Name                 string
	PreemptableFnEnabled bool
	JobOrderFnEnabled    bool
	TaskOrderFnEnabled   bool
	JobReadyFnEnabled    bool
}

type PluginBuilder func(*PluginArgs) Plugin

type Session struct {
	UID types.UID

	Jobs      []*api.JobInfo
	JobIndex  map[api.JobID]*api.JobInfo
	Nodes     []*api.NodeInfo
	NodeIndex map[string]*api.NodeInfo
	Backlog   []*api.JobInfo
	// contains filtered or unexported fields
}