btf

Documentation

Index

• func GetEBPFCollectionOptionsIfNeed() *ebpf.CollectionOptions
• type EventQueue
  • func NewEventQueue(partitionCount, sizePerPartition int, contextGenerator func() PartitionContext) *EventQueue
  • func (e *EventQueue) PartitionContexts() []PartitionContext
  • func (e *EventQueue) Push(key string, data interface{})
  • func (e *EventQueue) RegisterReceiver(emap *ebpf.Map, perCPUBufferSize int, dataSupplier func() interface{}, ...)
  • func (e *EventQueue) Start(ctx context.Context, linker *Linker)
• type LinkFunc
• type Linker
  • func NewLinker() *Linker
  • func (m *Linker) AddLink(linkF LinkFunc, symbolWithPrograms map[string]*ebpf.Program)
  • func (m *Linker) AddLinkOrError(linkF LinkFunc, symbolWithPrograms map[string]*ebpf.Program) error
  • func (m *Linker) AddSysCall(call string, enter, exit *ebpf.Program)
  • func (m *Linker) AddSysCallWithKProbe(call string, linkK LinkFunc, p *ebpf.Program)
  • func (m *Linker) AddTracePoint(sys, name string, p *ebpf.Program)
  • func (m *Linker) Close() error
  • func (m *Linker) HasError() error
  • func (m *Linker) OpenUProbeExeFile(path string) *UProbeExeFile
  • func (m *Linker) ReadEventAsync(emap *ebpf.Map, reader RingBufferReader, dataSupplier func() interface{})
  • func (m *Linker) ReadEventAsyncWithBufferSize(emap *ebpf.Map, reader RingBufferReader, perCPUBuffer int, ...)
• type PartitionContext
• type RingBufferReader
• type UProbeExeFile
  • func (u *UProbeExeFile) AddGoLink(symbol string, enter, exit *ebpf.Program, elfFile *elf.File)
  • func (u *UProbeExeFile) AddGoLinkWithType(symbol string, enter bool, p *ebpf.Program, elfFile *elf.File)
  • func (u *UProbeExeFile) AddLink(symbol string, enter, exit *ebpf.Program)
  • func (u *UProbeExeFile) AddLinkWithSymbols(symbol []string, enter, exit *ebpf.Program)
  • func (u *UProbeExeFile) AddLinkWithType(symbol string, enter bool, p *ebpf.Program)

Functions

func GetEBPFCollectionOptionsIfNeed

func GetEBPFCollectionOptionsIfNeed() *ebpf.CollectionOptions

Types

type EventQueue

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

func NewEventQueue

func NewEventQueue(partitionCount, sizePerPartition int, contextGenerator func() PartitionContext) *EventQueue

func (*EventQueue) PartitionContexts

func (e *EventQueue) PartitionContexts() []PartitionContext

func (*EventQueue) Push

func (e *EventQueue) Push(key string, data interface{})

func (*EventQueue) RegisterReceiver

func (e *EventQueue) RegisterReceiver(emap *ebpf.Map, perCPUBufferSize int, dataSupplier func() interface{},
	routeGenerator func(data interface{}) string)

func (*EventQueue) Start

func (e *EventQueue) Start(ctx context.Context, linker *Linker)

type LinkFunc

type LinkFunc func(symbol string, prog *ebpf.Program, opts *link.KprobeOptions) (link.Link, error)

type Linker

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

func NewLinker

func NewLinker() *Linker

func (*Linker) AddLink

func (m *Linker) AddLink(linkF LinkFunc, symbolWithPrograms map[string]*ebpf.Program)

func (*Linker) AddLinkOrError

func (m *Linker) AddLinkOrError(linkF LinkFunc, symbolWithPrograms map[string]*ebpf.Program) error

func (*Linker) AddSysCall

func (m *Linker) AddSysCall(call string, enter, exit *ebpf.Program)

func (*Linker) AddSysCallWithKProbe

func (m *Linker) AddSysCallWithKProbe(call string, linkK LinkFunc, p *ebpf.Program)

func (*Linker) AddTracePoint

func (m *Linker) AddTracePoint(sys, name string, p *ebpf.Program)

func (*Linker) Close

func (m *Linker) Close() error

func (*Linker) HasError

func (m *Linker) HasError() error

func (*Linker) OpenUProbeExeFile

func (m *Linker) OpenUProbeExeFile(path string) *UProbeExeFile

func (*Linker) ReadEventAsync

func (m *Linker) ReadEventAsync(emap *ebpf.Map, reader RingBufferReader, dataSupplier func() interface{})

func (*Linker) ReadEventAsyncWithBufferSize

func (m *Linker) ReadEventAsyncWithBufferSize(emap *ebpf.Map, reader RingBufferReader, perCPUBuffer int, dataSupplier func() interface{})

type PartitionContext

type PartitionContext interface {
	Start(ctx context.Context)
	Consume(data interface{})
}

type RingBufferReader

type RingBufferReader func(data interface{})

type UProbeExeFile

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

func (*UProbeExeFile) AddGoLink

func (u *UProbeExeFile) AddGoLink(symbol string, enter, exit *ebpf.Program, elfFile *elf.File)

func (*UProbeExeFile) AddGoLinkWithType

func (u *UProbeExeFile) AddGoLinkWithType(symbol string, enter bool, p *ebpf.Program, elfFile *elf.File)

func (*UProbeExeFile) AddLink

func (u *UProbeExeFile) AddLink(symbol string, enter, exit *ebpf.Program)

func (*UProbeExeFile) AddLinkWithSymbols

func (u *UProbeExeFile) AddLinkWithSymbols(symbol []string, enter, exit *ebpf.Program)

func (*UProbeExeFile) AddLinkWithType

func (u *UProbeExeFile) AddLinkWithType(symbol string, enter bool, p *ebpf.Program)