local

Documentation

Index

• func NewMgr(pCtx context.Context, work *types.Work) types.LocalMgr
• type Mgr
  • func (m *Mgr) ExecuteTask(req *types.LocalTaskExecuteRequest, globalWork *types.Work, ...) (*types.LocalTaskExecuteResult, error)
  • func (m *Mgr) GetPumpCache() (*analyser.FileCache, *analyser.RootCache)
  • func (m *Mgr) Init()
  • func (m *Mgr) LockSlots(usage dcSDK.JobUsage, weight int32) bool
  • func (m *Mgr) Slots() (int, int)
  • func (m *Mgr) Start()
  • func (m *Mgr) TryLockSlots(usage dcSDK.JobUsage, weight int32) (bool, error)
  • func (m *Mgr) UnlockSlots(usage dcSDK.JobUsage, weight int32)

Functions

func NewMgr

func NewMgr(pCtx context.Context, work *types.Work) types.LocalMgr

NewMgr get a new LocalMgr

Types

type Mgr

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

Mgr describe the local manager provides the local actions handler for work

func (*Mgr) ExecuteTask

func (m *Mgr) ExecuteTask(
	req *types.LocalTaskExecuteRequest,
	globalWork *types.Work,
	canUseLocalIdleResource bool,
	f types.CallbackCheckLocalResource) (*types.LocalTaskExecuteResult, error)

ExecuteTask 若是task command本身运行失败, 不作为execute失败, 将结果放在result中返回即可 只有筹备执行的过程中失败, 才作为execute失败

func (*Mgr) GetPumpCache

func (m *Mgr) GetPumpCache() (*analyser.FileCache, *analyser.RootCache)

GetPumpCache get pump cache in work

func (*Mgr) Init

func (m *Mgr) Init()

Init do the initialization for local manager

func (*Mgr) LockSlots

func (m *Mgr) LockSlots(usage dcSDK.JobUsage, weight int32) bool

LockSlots lock a local slot

func (*Mgr) Slots

func (m *Mgr) Slots() (int, int)

Slots get current total and occupied slots

func (*Mgr) Start

func (m *Mgr) Start()

Start start resource slots for local manager

func (*Mgr) TryLockSlots

func (m *Mgr) TryLockSlots(usage dcSDK.JobUsage, weight int32) (bool, error)

TryLockSlots try lock a local slot

func (*Mgr) UnlockSlots

func (m *Mgr) UnlockSlots(usage dcSDK.JobUsage, weight int32)

UnlockSlots unlock a local slot