watcher

Documentation

Index

• Constants
• type BPFWatchInfo
• type Event
• type EventType
• type Watcher
  • func New(cfg *pipe.Config, events chan<- Event) *Watcher
  • func (p *Watcher) AddCloser(c ...io.Closer)
  • func (p *Watcher) BpfObjects() any
  • func (p *Watcher) KProbes() map[string]ebpfcommon.FunctionPrograms
  • func (p *Watcher) Load() (*ebpf.CollectionSpec, error)
  • func (p *Watcher) Run(ctx context.Context)

Constants

const (
	Ready = EventType(iota)
	NewPort
)

Types

type BPFWatchInfo

type BPFWatchInfo bpfWatchInfoT

type Event

type Event struct {
	Type    EventType
	Payload uint32 // this will be either port or pid
}

type EventType

type EventType int

type Watcher

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

func New

func New(cfg *pipe.Config, events chan<- Event) *Watcher

func (*Watcher) AddCloser

func (p *Watcher) AddCloser(c ...io.Closer)

func (*Watcher) BpfObjects

func (p *Watcher) BpfObjects() any

func (*Watcher) KProbes

func (p *Watcher) KProbes() map[string]ebpfcommon.FunctionPrograms

func (*Watcher) Load

func (p *Watcher) Load() (*ebpf.CollectionSpec, error)

func (*Watcher) Run

func (p *Watcher) Run(ctx context.Context)