task

Jun 14, 2023

Changes in this version

type Context

+ func (c *Context) IsRunning() bool

+ func (c *Context) RunningTime() time.Time

type Manager

+ func (m *Manager) BuildContextFromCommand(command *common_v3.Command) (*Context, error)

+ func (m *Manager) BuildContextFromContinuous(processes []api.ProcessInterface, taskSetter func(task *base.ProfilingTask), ...) (*Context, error)

+ func (m *Manager) FlushProfilingData() error

+ func (m *Manager) StartingWatchTask() error

Dec 9, 2022

Changes in this version

type Manager

+ func (m *Manager) ShutdownAndRemoveTask(c *Context) error

Sep 7, 2022

Changes in this version

type Context

+ func (c *Context) IsSameTask(other *Context) bool

May 17, 2022

Changes in this version

+ func CheckProfilingTaskConfig(taskConfig *base.TaskConfig) error

+ func NewProfilingRunner(taskType base.TargetType, taskConfig *base.TaskConfig) (base.ProfileTaskRunner, error)

+ type Context struct

+ func (c *Context) BuildTaskIdentity() string

+ func (c *Context) CheckTaskRunnable() bool

+ func (c *Context) TaskID() string

+ func (c *Context) UpdateTime() int64

+ type Manager struct

+ func NewManager(ctx context.Context, processOperator process.Operator, ...) (*Manager, error)

+ func (m *Manager) BuildContext(command *common_v3.Command) (*Context, error)

+ func (m *Manager) Shutdown() error

+ func (m *Manager) Start()

+ func (m *Manager) StartTask(c *Context)

+ type RunningStatus uint8

+ const NotRunning

+ const Running

+ const Stopped