collector

type EbpfCfg = ebpf.Config

type EbpfCollector = *collectorImpl[EbpfCfg]

type EbpfMetrics = ebpf.Metrics

type Msg struct {
	Trace   nftrace.Trace
	Metrics collectors.Telemetry
	Err     error
}

type NetlinkCfg = netlink.Config

type NetlinkCollector = *collectorImpl[NetlinkCfg]

type NetlinkMetrics = netlink.Metrics

type TraceCollector interface {
	// Collect starts the collection process and returns a channel to receive collected messages.
	Collect(context.Context) <-chan Msg
	Close() error
}