capture

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

type CapperPacketWrapper struct {
	*capperpb.Packet
}

type Capture interface {
	LinkType() layers.LinkType
	Start(ctx context.Context, handler PacketHandler) error
	Close()
}

type CaptureInterface struct {
	Name            string
	Index           int
	Hostname        string
	NetnsInode      uint64
	Netns           string
	LinkType        layers.LinkType
	K8sPod          string
	K8sPodNamespace string
}

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

type Config struct {
	Filter          string
	Snaplen         int
	Promisc         bool
	NumPackets      uint64
	CaptureDuration time.Duration
	BufferSize      int
	OutputFormat    capperpb.PcapOutputFormat
}

type GoPacketWrapper struct {
	gopacket.Packet
}

type NamedPacketSource struct {
	Name string
	PacketSource
}

type PacketHandler interface {
	HandlePacket(gopacket.Packet) error
	Flush() error
}

type PacketHandlerFunc func(gopacket.Packet) error

type PacketHeap []TimestampedPacket

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

type PacketSource interface {
	PacketsCtx(ctx context.Context) chan TimestampedPacket
}

type PacketSourceChan chan TimestampedPacket

type PacketWriter interface {
	WritePacket(ci gopacket.CaptureInfo, data []byte) error
	Flush() error
}

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

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

type TimestampedPacket interface {
	Timestamp() time.Time
}