packet

type BufferData struct {
	Buf gopacket.SerializeBuffer
	Err error
}

type Limiter interface {
	// Take should block to make sure that the RPS is met.
	Take() time.Time
}

type Processor interface {
	ProcessPacketData(data []byte, ci *gopacket.CaptureInfo) error
}

type ReadWriter interface {
	Reader
	Writer
}

type Reader interface {
	ReadPacketData() (data []byte, ci *gopacket.CaptureInfo, err error)
}

type Receiver interface {
	ReceivePackets(ctx context.Context) <-chan error
}

type Sender interface {
	SendPackets(ctx context.Context, in <-chan *BufferData) (done <-chan interface{}, errc <-chan error)
}

type Writer interface {
	WritePacketData(pkt []byte) error
}