network

Documentation

Index

• func NewRunner(config *base.TaskConfig, moduleMgr *module.Manager) (base.ProfileTaskRunner, error)
• type DelegateRunner
  • func (r *DelegateRunner) FlushData() ([]*v3.EBPFProfilingData, error)
  • func (r *DelegateRunner) Init(task *base.ProfilingTask, processes []api.ProcessInterface) error
  • func (r *DelegateRunner) Run(ctx context.Context, notify base.ProfilingRunningSuccessNotify) error
  • func (r *DelegateRunner) Stop() error
• type Runner
  • func NewGlobalRunnerContext() *Runner
  • func (r *Runner) DeleteProcesses(processes []api.ProcessInterface) (bool, error)
  • func (r *Runner) Start(ctx context.Context, task *base.ProfilingTask, ...) error
  • func (r *Runner) Stop() error

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 (r *DelegateRunner) Run(ctx context.Context, notify base.ProfilingRunningSuccessNotify) error

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