io

type ErrInvalidPacket struct {
	Err error
}

type NFQueuePacketIOConfig struct {
	QueueSize uint32
	Local     bool
}

type Packet interface {
	// StreamID is the ID of the stream the packet belongs to.
	StreamID() uint32
	// Data is the raw packet data, starting with the IP header.
	Data() []byte
}

type PacketCallback func(Packet, error) bool

type PacketIO interface {
	// Register registers a callback to be called for each packet received.
	// The callback should be called in one or more separate goroutines,
	// and stop when the context is cancelled.
	Register(context.Context, PacketCallback) error
	// SetVerdict sets the verdict for a packet.
	SetVerdict(Packet, Verdict, []byte) error
	// Close closes the packet IO.
	Close() error
}

type Verdict int