task

Documentation

Index

• func CheckProfilingTaskConfig(taskConfig *base.TaskConfig, moduleMgr *module.Manager) error
• func NewProfilingRunner(taskType base.TargetType, taskConfig *base.TaskConfig, ...) (base.ProfileTaskRunner, error)
• type Context
  • func (c *Context) BuildTaskIdentity() string
  • func (c *Context) CheckTaskRunnable() bool
  • func (c *Context) IsRunning() bool
  • func (c *Context) IsSameTask(other *Context) bool
  • func (c *Context) RunningTime() time.Time
  • func (c *Context) TaskID() string
  • func (c *Context) UpdateTime() int64
• type Manager
  • func NewManager(ctx context.Context, moduleMgr *module.Manager, taskConfig *base.TaskConfig) (*Manager, error)
  • 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) Shutdown() error
  • func (m *Manager) ShutdownAndRemoveTask(c *Context) error
  • func (m *Manager) Start()
  • func (m *Manager) StartTask(c *Context)
  • func (m *Manager) StartingWatchTask() error
• type RunningStatus

Functions

func CheckProfilingTaskConfig

func CheckProfilingTaskConfig(taskConfig *base.TaskConfig, moduleMgr *module.Manager) error

func NewProfilingRunner

func NewProfilingRunner(taskType base.TargetType, taskConfig *base.TaskConfig, moduleMgr *module.Manager) (base.ProfileTaskRunner, error)

Types

type Context

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

Context of profiling task

func (*Context) BuildTaskIdentity

func (c *Context) BuildTaskIdentity() string

BuildTaskIdentity for filter with same identity task

func (*Context) CheckTaskRunnable

func (c *Context) CheckTaskRunnable() bool

CheckTaskRunnable means checks the task could be running

func (*Context) IsRunning

func (c *Context) IsRunning() bool

func (*Context) IsSameTask

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

func (*Context) RunningTime

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

func (*Context) TaskID

func (c *Context) TaskID() string

func (*Context) UpdateTime

func (c *Context) UpdateTime() int64

UpdateTime of the profiling task

type Manager

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

func NewManager

func NewManager(ctx context.Context, moduleMgr *module.Manager, taskConfig *base.TaskConfig) (*Manager, error)

func (*Manager) BuildContextFromCommand

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

func (*Manager) BuildContextFromContinuous

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

func (*Manager) FlushProfilingData

func (m *Manager) FlushProfilingData() error

func (*Manager) Shutdown

func (m *Manager) Shutdown() error

func (*Manager) ShutdownAndRemoveTask

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

func (*Manager) Start

func (m *Manager) Start()

func (*Manager) StartTask

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

func (*Manager) StartingWatchTask

func (m *Manager) StartingWatchTask() error

type RunningStatus

type RunningStatus uint8

const (
	NotRunning RunningStatus
	Running
	Stopped
)