Documentation ¶
Index ¶
- type Connection
- type TCPStreamFactory
- func (tsf *TCPStreamFactory) AssemblePacket(netFlow gopacket.Flow, tcp *layers.TCP)
- func (tsf *TCPStreamFactory) CreateAssembler()
- func (tsf *TCPStreamFactory) New(n, t gopacket.Flow, tcp *layers.TCP, ac reassembly.AssemblerContext) reassembly.Stream
- func (tsf *TCPStreamFactory) NewPacket(netFlow gopacket.Flow, tcp *layers.TCP)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connection ¶
type Connection struct { Timestamp time.Time UID uint64 SourceIP string SourcePort int DestinationIP string DestinationPort int TransportType string Duration float64 State string `json:",omitempty"` Payload *bytes.Buffer `json:"-"` Analyzers map[string]interface{} }
Connection is ...
func NewUDP ¶
func NewUDP(packet gopacket.Packet, ci gopacket.CaptureInfo) *Connection
NewUDP is ...
type TCPStreamFactory ¶
type TCPStreamFactory struct { Assembler *reassembly.Assembler AssemblerMutex sync.Mutex ConnTimeout int Ticker *time.Ticker Connections chan *Connection }
TCPStreamFactory is ...
func (*TCPStreamFactory) AssemblePacket ¶
func (tsf *TCPStreamFactory) AssemblePacket(netFlow gopacket.Flow, tcp *layers.TCP)
AssemblePacket is ...
func (*TCPStreamFactory) CreateAssembler ¶
func (tsf *TCPStreamFactory) CreateAssembler()
CreateAssembler is ...
func (*TCPStreamFactory) New ¶
func (tsf *TCPStreamFactory) New(n, t gopacket.Flow, tcp *layers.TCP, ac reassembly.AssemblerContext) reassembly.Stream
New is ...
Click to show internal directories.
Click to hide internal directories.