manager

package module

Go to main page

Versions in this module

v0

v0.4.5

Feb 2, 2024

Changes in this version

+ var ErrLSMNotSupported = errors.New("LSM is not supported on this kernel, need kernel version >= 5.7.0")

+ type InstructionPatcherFunc func(m *Manager) error

type Manager

+ InstructionPatchers []InstructionPatcherFunc

type Probe

+ LinkPinPath string

v0.4.4

Nov 10, 2023

Changes in this version

+ var ErrRingbufNotSupported = errors.New("ringbuf is not supported on this kernel, need kernel version >= 5.8.0")

type Manager

+ RingbufMaps []*RingbufMap

+ type RingbufMap struct

+ func (m *RingbufMap) Init(manager *Manager) error

+ func (m *RingbufMap) Start() error

+ func (m *RingbufMap) Stop(cleanup MapCleanupType) error

+ type RingbufMapOptions struct

+ DataHandler func(CPU int, data []byte, perfMap *RingbufMap, manager *Manager)

+ DumpHandler func(perfMap *PerfMap, manager *Manager) string

+ PerfErrChan chan error

+ PerfMapStats *PerfMapStats

+ Watermark int

v0.4.3

May 19, 2023

v0.4.2

Apr 29, 2023

Changes in this version

type Probe

+ UAddress uint64

v0.4.1

Feb 5, 2023

Changes in this version

+ const Egress

+ const Ingress

+ const ProbeType

+ const RetProbeType

+ const UnknownProbeType

+ var ErrCloneProbeRequired = errors.New("use CloneProbe to load 2 instances of the same program")

+ var ErrIdentificationPairInUse = errors.New("the provided identification pair already exists")

+ var ErrInterfaceNotSet = errors.New("interface not provided: at least one of Ifindex and Ifname must be set")

+ var ErrKprobeIDNotExist = errors.New("kprobe id file doesn't exist")

+ var ErrLoopbackDisabled = errors.New("loopback is disabled")

+ var ErrManagerNotInitialized = errors.New("the manager must be initialized first")

+ var ErrManagerNotStarted = errors.New("the manager must be started first")

+ var ErrManagerRunning = errors.New("the manager is already running")

+ var ErrMapInitialized = errors.New("map already initialized")

+ var ErrMapNameInUse = errors.New("the provided map name is already taken")

+ var ErrMapNotInitialized = errors.New("the map must be initialized first")

+ var ErrMapNotRunning = errors.New("the map is not running")

+ var ErrMissingEditorFlags = errors.New("missing editor flags in map editor")

+ var ErrPinnedObjectNotFound = errors.New("pinned object not found")

+ var ErrProbeNotInitialized = errors.New("the probe must be initialized first")

+ var ErrSectionFormat = errors.New("invalid section format")

+ var ErrSymbolNotFound = errors.New("symbol not found")

+ var ErrUnknownMap = errors.New("unknown bpf map")

+ var ErrUnknownMatchFuncName = errors.New("unknown EbpfFuncName")

+ var ErrUnknownMatchFuncSpec = errors.New("unknown MatchFuncSpec")

+ var ErrUnknownSection = errors.New("unknown section")

+ var ErrUprobeIDNotExist = errors.New("uprobe id file doesn't exist")

+ func ConcatErrors(err1, err2 error) error

+ func FindFilterFunction(funcName string) (string, error)

+ func FindSymbolOffsets(path string, pattern *regexp.Regexp) ([]elf.Symbol, error)

+ func GenerateEventName(probeType, funcName, UID string, attachPID int) (string, error)

+ func GetSyscallFnName(name string) (string, error)

+ func GetSyscallFnNameWithSymFile(name string, symFile string) (string, error)

+ func IsUnreferencedSymbol(err error) bool

+ func OpenAndListSymbols(path string) (*elf.File, []elf.Symbol, error)

+ func SanitizeUprobeAddresses(f *elf.File, syms []elf.Symbol)

+ type AllOf struct

+ Selectors []ProbesSelector

+ func (ao *AllOf) EditProbeIdentificationPair(old ProbeIdentificationPair, new ProbeIdentificationPair)

+ func (ao *AllOf) GetProbesIdentificationPairList() []ProbeIdentificationPair

+ func (ao *AllOf) RunValidator(manager *Manager) error

+ func (ao *AllOf) String() string

+ type BestEffort struct

+ Selectors []ProbesSelector

+ func (be *BestEffort) EditProbeIdentificationPair(old ProbeIdentificationPair, new ProbeIdentificationPair)

+ func (be *BestEffort) GetProbesIdentificationPairList() []ProbeIdentificationPair

+ func (be *BestEffort) RunValidator(manager *Manager) error

+ func (be *BestEffort) String() string

+ type ConstantEditor struct

+ FailOnMissing bool

+ Name string

+ ProbeIdentificationPairs []ProbeIdentificationPair

+ Value interface{}

+ type Editor struct

+ ReferenceOffsets map[string][]int

+ func Edit(insns *asm.Instructions) *Editor

+ func (ed *Editor) RewriteConstant(symbol string, value uint64) error

+ type Manager struct

+ Maps []*Map

+ PerfMaps []*PerfMap

+ Probes []*Probe

+ func (m *Manager) AddHook(UID string, newProbe *Probe) error

+ func (m *Manager) CloneMap(name string, newName string, options MapOptions) (*ebpf.Map, error)

+ func (m *Manager) ClonePerfRing(name string, newName string, options MapOptions, perfMapOptions PerfMapOptions) (*ebpf.Map, error)

+ func (m *Manager) CloneProgram(UID string, newProbe *Probe, constantsEditors []ConstantEditor, ...) error

+ func (m *Manager) DetachHook(section string, UID string) error

+ func (m *Manager) DumpMaps(maps ...string) (string, error)

+ func (m *Manager) GetMap(name string) (*ebpf.Map, bool, error)

+ func (m *Manager) GetMapSpec(name string) (*ebpf.MapSpec, bool, error)

+ func (m *Manager) GetPerfMap(name string) (*PerfMap, bool)

+ func (m *Manager) GetProbe(id ProbeIdentificationPair) (*Probe, bool)

+ func (m *Manager) GetProgram(id ProbeIdentificationPair) ([]*ebpf.Program, bool, error)

+ func (m *Manager) GetProgramSpec(id ProbeIdentificationPair) ([]*ebpf.ProgramSpec, bool, error)

+ func (m *Manager) Init(elf io.ReaderAt) error

+ func (m *Manager) InitWithOptions(elf io.ReaderAt, options Options) error

+ func (m *Manager) NewMap(spec ebpf.MapSpec, options MapOptions) (*ebpf.Map, error)

+ func (m *Manager) NewPerfRing(spec ebpf.MapSpec, options MapOptions, perfMapOptions PerfMapOptions) (*ebpf.Map, error)

+ func (m *Manager) Start() error

+ func (m *Manager) Stop(cleanup MapCleanupType) error

+ func (m *Manager) UpdateActivatedProbes(selectors []ProbesSelector) error

+ func (m *Manager) UpdateMapRoutes(router ...MapRoute) error

+ func (m *Manager) UpdateTailCallRoutes(router ...TailCallRoute) error

+ type Map struct

+ Contents []ebpf.MapKV

+ Freeze bool

+ Name string

+ func (m *Map) Close(cleanup MapCleanupType) error

+ func (m *Map) Init(manager *Manager) error

+ type MapCleanupType int

+ const CleanAll

+ const CleanExternal

+ const CleanExternalEdited

+ const CleanExternalPinned

+ const CleanExternalPinnedAndEdited

+ const CleanInternal

+ const CleanInternalNotPinned

+ const CleanInternalPinned

+ type MapOptions struct

+ AlwaysCleanup bool

+ DumpHandler func(currentMap *Map, manager *Manager) string

+ PinPath string

+ type MapRoute struct

+ Key interface{}

+ Map *ebpf.Map

+ RoutedName string

+ RoutingMapName string

+ type MapSpecEditor struct

+ EditorFlag MapSpecEditorFlag

+ Flags uint32

+ InnerMap *ebpf.MapSpec

+ MaxEntries uint32

+ Type ebpf.MapType

+ type MapSpecEditorFlag uint

+ const EditFlags

+ const EditInnerMap

+ const EditMaxEntries

+ const EditType

+ type OneOf struct

+ Selectors []ProbesSelector

+ func (oo *OneOf) EditProbeIdentificationPair(old ProbeIdentificationPair, new ProbeIdentificationPair)

+ func (oo *OneOf) GetProbesIdentificationPairList() []ProbeIdentificationPair

+ func (oo *OneOf) RunValidator(manager *Manager) error

+ func (oo *OneOf) String() string

+ type Options struct

+ ActivatedProbes []ProbesSelector

+ ConstantEditors []ConstantEditor

+ DefaultKProbeMaxActive int

+ DefaultPerfRingBufferSize int

+ DefaultProbeRetry uint

+ DefaultProbeRetryDelay time.Duration

+ DefaultWatermark int

+ ExcludedEbpfFuncs []string

+ ExcludedSections []string

+ KeepKernelBTF bool

+ MapEditors map[string]*ebpf.Map

+ MapRouter []MapRoute

+ MapSpecEditors map[string]MapSpecEditor

+ RLimit *unix.Rlimit

+ SymFile string

+ TailCallRouter []TailCallRoute

+ VerifierOptions ebpf.CollectionOptions

+ type PerfMap struct

+ func (m *PerfMap) Init(manager *Manager) error

+ func (m *PerfMap) Pause() error

+ func (m *PerfMap) Resume() error

+ func (m *PerfMap) Start() error

+ func (m *PerfMap) Stop(cleanup MapCleanupType) error

+ type PerfMapOptions struct

+ DataHandler func(CPU int, data []byte, perfMap *PerfMap, manager *Manager)

+ DumpHandler func(perfMap *PerfMap, manager *Manager) string

+ LostHandler func(CPU int, count uint64, perfMap *PerfMap, manager *Manager)

+ PerfErrChan chan error

+ PerfMapStats *PerfMapStats

+ PerfRingBufferSize int

+ Watermark int

+ type PerfMapStats struct

+ LostSamples map[int]uint64

+ RawSamples map[int]uint64

+ ReadErrors uint64

+ func NewPerfMapStats() *PerfMapStats

+ func (new *PerfMapStats) Diff(old *PerfMapStats) (diff *PerfMapStats)

+ type Probe struct

+ AttachPID int

+ AttachToFuncName string

+ BinaryPath string

+ CGroupPath string

+ CopyProgram bool

+ EbpfFuncName string

+ Enabled bool

+ Ifindex int32

+ IfindexNetns uint64

+ Ifname string

+ KProbeMaxActive int

+ NetworkDirection TrafficType

+ PinPath string

+ ProbeRetry uint

+ ProbeRetryDelay time.Duration

+ Section string

+ SkipLoopback bool

+ SocketFD int

+ TCCleanupQDisc bool

+ TCFilterHandle uint32

+ TCFilterPrio uint16

+ TCFilterProtocol uint16

+ UID string

+ UprobeOffset uint64

+ XDPAttachMode XdpAttachMode

+ func (p *Probe) Attach() error

+ func (p *Probe) Benchmark(in []byte, repeat int, reset func()) (uint32, time.Duration, error)

+ func (p *Probe) Copy() *Probe

+ func (p *Probe) Detach() error

+ func (p *Probe) GetIdentificationPair() ProbeIdentificationPair

+ func (p *Probe) GetLastError() error

+ func (p *Probe) IdentificationPairMatches(id ProbeIdentificationPair) bool

+ func (p *Probe) Init(manager *Manager) error

+ func (p *Probe) InitWithOptions(manager *Manager, manualLoadNeeded bool, checkPin bool) error

+ func (p *Probe) IsInitialized() bool

+ func (p *Probe) IsRunning() bool

+ func (p *Probe) Program() *ebpf.Program

+ func (p *Probe) Stop() error

+ func (p *Probe) Test(in []byte) (uint32, []byte, error)

+ type ProbeIdentificationPair struct

+ EbpfFuncName string

+ UID string

+ func (pip ProbeIdentificationPair) Matches(id ProbeIdentificationPair) bool

+ func (pip ProbeIdentificationPair) String() string

+ type ProbeSelector struct

+ func (ps *ProbeSelector) EditProbeIdentificationPair(old ProbeIdentificationPair, new ProbeIdentificationPair)

+ func (ps *ProbeSelector) GetProbesIdentificationPairList() []ProbeIdentificationPair

+ func (ps *ProbeSelector) RunValidator(manager *Manager) error

+ type ProbesSelector interface

+ EditProbeIdentificationPair func(old ProbeIdentificationPair, new ProbeIdentificationPair)

+ GetProbesIdentificationPairList func() []ProbeIdentificationPair

+ RunValidator func(manager *Manager) error

+ type TailCallRoute struct

+ Key uint32

+ ProbeIdentificationPair ProbeIdentificationPair

+ ProgArrayName string

+ Program *ebpf.Program

+ type TrafficType uint16

+ func (tt TrafficType) String() string

+ type XdpAttachMode int

+ const DefaultTCFilterPriority

+ const XdpAttachModeDrv

+ const XdpAttachModeHw

+ const XdpAttachModeNone

+ const XdpAttachModeSkb

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