network

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 19, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewRunner

func NewRunner(config *base.TaskConfig, moduleMgr *module.Manager) (base.ProfileTaskRunner, error)

Types

type DelegateRunner

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

func (*DelegateRunner) FlushData

func (r *DelegateRunner) FlushData() ([]*v3.EBPFProfilingData, error)

func (*DelegateRunner) Init

func (r *DelegateRunner) Init(task *base.ProfilingTask, processes []api.ProcessInterface) error

func (*DelegateRunner) Run

func (*DelegateRunner) Stop

func (r *DelegateRunner) Stop() error

type Runner

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

func NewGlobalRunnerContext

func NewGlobalRunnerContext() *Runner

func (*Runner) DeleteProcesses

func (r *Runner) DeleteProcesses(processes []api.ProcessInterface) (bool, error)

func (*Runner) Start

func (r *Runner) Start(ctx context.Context, task *base.ProfilingTask, processes []api.ProcessInterface) error

func (*Runner) Stop

func (r *Runner) Stop() error

Jump to

Keyboard shortcuts

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