filter

type AFPacketInfo struct {
	// PktType corresponds to sll_pkttype in the
	// sockaddr_ll struct; see packet(7)
	// https://man7.org/linux/man-pages/man7/packet.7.html
	PktType uint8
}

type AFPacketSource struct {
	*afpacket.TPacket
	// contains filtered or unexported fields
}

type AFPacketVisitor = func(data []byte, info PacketInfo, t time.Time) error

type Option func(*packetSourceConfig)

type PacketInfo interface {
	// PacketType returns the packet direction type
	// (e.g. PacketHost, PacketOutgoing)
	PacketType() uint8
	// LinkLayerType returns the gopacket layer type for this
	// packet's link-layer encapsulation
	LinkLayerType() gopacket.LayerType
}

type PacketSource interface {
	// VisitPackets reads all new raw packets that are available, invoking the given callback for each packet.
	// If no packet is available, VisitPacket blocks until OptPollTimeout and returns.
	// The format of the packet is dependent on the implementation of PacketSource -- i.e. it may be an ethernet frame, or a IP frame.
	// The data buffer is reused between invocations of VisitPacket and thus should not be pointed to.
	// If the PacketSource is closed, VisitPackets will stop reading.
	VisitPackets(visitor func(data []byte, info PacketInfo, timestamp time.Time) error) error

	// LayerType returns the type of packet this source reads
	LayerType() gopacket.LayerType

	// Close closes the packet source. This will cancel VisitPackets if it is currently polling.
	// Close() will not return until after VisitPackets has been canceled/returned.
	Close()
}