collectors

type CollectorMsg struct {
	Trace NftTrace
	Err   error
}

type CountCollectNlErrMemEvent struct {
	observer.EventType
}

type CountLostSampleEvent struct {
	observer.EventType
	Cnt uint64
}

type CountOverflowQueEvent struct {
	observer.EventType
	Cnt uint64
}

type CountRcvPktEvent struct {
	observer.EventType
	Cnt uint64
}

type CountRcvSampleEvent struct {
	observer.EventType
	Cnt uint64
}

type NftTrace struct {
	TraceHash  uint32
	NetnsInum  uint32
	Table      string
	Chain      string
	JumpTarget string
	RuleHandle uint64
	Family     byte
	Type       uint32
	Id         uint32
	Iif        uint32
	Oif        uint32
	Mark       uint32
	Verdict    uint32
	Nfproto    uint32
	Policy     uint32
	Iiftype    uint16
	Oiftype    uint16
	Iifname    string
	Oifname    string
	SMacAddr   string
	DMacAddr   string
	IpVersion  uint8
	SAddr      string
	DAddr      string
	SPort      uint32
	DPort      uint32
	Length     uint32
	IpProtocol uint8
	Cnt        uint64
	ReadyMsk   bool
	Metrics    Telemetry
}

type Telemetry interface {
	// contains filtered or unexported methods
}

type TraceCollector interface {
	Collect(ctx context.Context) <-chan CollectorMsg
	Close() error
}