task

package

v0.4.0 Latest Latest Go to latest Published: Dec 9, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/apache/skywalking-rover

Links

Open Source Insights

Documentation ¶

Index ¶

func CheckProfilingTaskConfig(taskConfig *base.TaskConfig, moduleMgr *module.Manager) error
func NewProfilingRunner(taskType base.TargetType, taskConfig *base.TaskConfig, ...) (base.ProfileTaskRunner, error)
type Context
type Manager
- func NewManager(ctx context.Context, moduleMgr *module.Manager, ...) (*Manager, error)
type RunningStatus

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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) IsSameTask ¶ added in v0.3.0

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

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,
	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) ShutdownAndRemoveTask ¶ added in v0.4.0

func (m *Manager) ShutdownAndRemoveTask(c *Context) 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
)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
base
network
analyze
analyze/base
analyze/layer4
analyze/layer7
analyze/layer7/protocols
analyze/layer7/protocols/base
analyze/layer7/protocols/http1
analyze/layer7/protocols/metrics
bpf
offcpu
oncpu

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL