sniffer

type Consumer interface {
	On(MessageStream)
}

type ConsumerFactory interface {
	New(flow IPPortTuple) Consumer
	BPFFilter() string
}

type Context struct {
	CaptureInfo gopacket.CaptureInfo
}

type IPPortTuple struct {
	SrcIP   net.IP
	DstIP   net.IP
	SrcPort uint16
	DstPort uint16
}

type Message interface {
	Timestamp() time.Time
	Flow() IPPortTuple
	io.Reader
}

type MessageStream interface {
	Next() (Message, bool)
}

type Options struct {
	SourceType   string `long:"type" default:"pcap" description:"Packet capture mechanism (pcap, af_packet or offline)"`
	Device       string `long:"device" description:"Network interface to listen on"`
	SnapLen      int    `long:"snaplen" default:"65535" description:"Capture snapshot length"`
	BufSizeMb    int    `long:"bufsize" description:"buffer size in megabytes" default:"32"`
	FlushTimeout int    `long:"flushtimeout" description:"Time in seconds to wait before flushing buffered data for a connection" default:"5"`
	PcapFile     string `long:"pcapfile" description:"For offline packet captures, path to pcap file"`
}

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

type Stream struct {
	sync.Mutex
	// contains filtered or unexported fields
}