flow

Documentation

Index

• func Debug(s string, a ...interface{})
• type AssembleContext
  • func (a *AssembleContext) GetCaptureInfo() gopacket.CaptureInfo
• type Reader
• type TCPStream
  • func (s *TCPStream) Accept(tcp *layers.TCP, ci gopacket.CaptureInfo, dir reassembly.TCPFlowDirection, ...) bool
  • func (s *TCPStream) ReassembledSG(sg reassembly.ScatterGather, ac reassembly.AssemblerContext)
  • func (s *TCPStream) ReassemblyComplete(ac reassembly.AssemblerContext) bool
• type TCPStreamFactory
  • func (factory *TCPStreamFactory) New(netFlow, tcpFlow gopacket.Flow, tcp *layers.TCP, ...) reassembly.Stream

Functions

func Debug

func Debug(s string, a ...interface{})

Types

type AssembleContext

type AssembleContext struct {
	CaptureInfo gopacket.CaptureInfo
}

func (*AssembleContext) GetCaptureInfo

func (a *AssembleContext) GetCaptureInfo() gopacket.CaptureInfo

type Reader

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

type TCPStream

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

func (*TCPStream) Accept

func (s *TCPStream) Accept(tcp *layers.TCP, ci gopacket.CaptureInfo, dir reassembly.TCPFlowDirection, nextSeq reassembly.Sequence, start *bool, ac reassembly.AssemblerContext) bool

func (*TCPStream) ReassembledSG

func (s *TCPStream) ReassembledSG(sg reassembly.ScatterGather, ac reassembly.AssemblerContext)

func (*TCPStream) ReassemblyComplete

func (s *TCPStream) ReassemblyComplete(ac reassembly.AssemblerContext) bool

type TCPStreamFactory

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

func (*TCPStreamFactory) New

func (factory *TCPStreamFactory) New(netFlow, tcpFlow gopacket.Flow, tcp *layers.TCP, ac reassembly.AssemblerContext) reassembly.Stream