task

Documentation

Index

• func CheckProfilingTaskConfig(taskConfig *base.TaskConfig) 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) TaskID() string
  • func (c *Context) UpdateTime() int64
• type Manager
  • 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

Functions

func CheckProfilingTaskConfig

func CheckProfilingTaskConfig(taskConfig *base.TaskConfig) error

func NewProfilingRunner

func NewProfilingRunner(taskType base.TargetType, taskConfig *base.TaskConfig) (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) 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, processOperator process.Operator,
	profilingClient profiling_v3.EBPFProfilingServiceClient, flushInterval time.Duration, taskConfig *base.TaskConfig) (*Manager, error)

func (*Manager) BuildContext

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

func (*Manager) Shutdown

func (m *Manager) Shutdown() error

func (*Manager) Start

func (m *Manager) Start()

func (*Manager) StartTask

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

type RunningStatus

type RunningStatus uint8

const (
	NotRunning RunningStatus
	Running
	Stopped
)