Documentation ¶
Index ¶
- type Scheduler
- func (m *Scheduler) AskPlanIDByTaskID(taskID string) (string, error)
- func (m *Scheduler) Consume(askPlan *sonm.AskPlan) error
- func (m *Scheduler) ConsumeTask(askPlanID string, taskID string, resources *sonm.AskPlanResources) error
- func (m *Scheduler) DebugDump() *sonm.SchedulerData
- func (m *Scheduler) GetCommitedFree() (*sonm.AskPlanResources, error)
- func (m *Scheduler) MakeRoomAndCommit(askPlan *sonm.AskPlan) (ejectedAskPlans []string, err error)
- func (m *Scheduler) OnDealFinish(taskID string) error
- func (m *Scheduler) Release(askPlanID string) error
- func (m *Scheduler) ReleaseTask(taskID string) error
- func (m *Scheduler) ResourceByTask(taskID string) (*sonm.AskPlanResources, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Scheduler ¶ added in v0.4.1
func NewScheduler ¶ added in v0.4.1
func (*Scheduler) AskPlanIDByTaskID ¶ added in v0.4.1
TODO: rework needed — looks like it should not be here
func (*Scheduler) Consume ¶ added in v0.4.1
Consume tries to consume the specified resource usage from the pool.
Does nothing on error.
func (*Scheduler) ConsumeTask ¶ added in v0.4.1
func (*Scheduler) GetCommitedFree ¶ added in v0.4.13
func (*Scheduler) MakeRoomAndCommit ¶ added in v0.4.13
func (*Scheduler) OnDealFinish ¶ added in v0.4.5
func (*Scheduler) ReleaseTask ¶ added in v0.4.1
func (*Scheduler) ResourceByTask ¶ added in v0.4.11
Click to show internal directories.
Click to hide internal directories.