resource

Documentation

Index

• type Scheduler
  • func NewScheduler(ctx context.Context, hardware *hardware.Hardware) *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) GetFree() (*sonm.AskPlanResources, error)
  • func (m *Scheduler) GetUsage() (*sonm.AskPlanResources, error)
  • func (m *Scheduler) PollConsume(askPlan *sonm.AskPlan) error
  • func (m *Scheduler) Release(askPlanID string) error
  • func (m *Scheduler) ReleaseTask(taskID string) error

Types

type Scheduler

type Scheduler struct {
	OS *hardware.Hardware
	// contains filtered or unexported fields
}

func NewScheduler

func NewScheduler(ctx context.Context, hardware *hardware.Hardware) *Scheduler

func (*Scheduler) AskPlanIDByTaskID

func (m *Scheduler) AskPlanIDByTaskID(taskID string) (string, error)

TODO: rework needed — looks like it should not be here

func (*Scheduler) Consume

func (m *Scheduler) Consume(askPlan *sonm.AskPlan) error

Consume tries to consume the specified resource usage from the pool.

Does nothing on error.

func (*Scheduler) ConsumeTask

func (m *Scheduler) ConsumeTask(askPlanID string, taskID string, resources *sonm.AskPlanResources) error

func (*Scheduler) GetFree

func (m *Scheduler) GetFree() (*sonm.AskPlanResources, error)

func (*Scheduler) GetUsage

func (m *Scheduler) GetUsage() (*sonm.AskPlanResources, error)

func (*Scheduler) PollConsume

func (m *Scheduler) PollConsume(askPlan *sonm.AskPlan) error

func (*Scheduler) Release

func (m *Scheduler) Release(askPlanID string) error

func (*Scheduler) ReleaseTask

func (m *Scheduler) ReleaseTask(taskID string) error