tcpreassembly

Documentation

Index

• type Context
  • func (c *Context) GetCaptureInfo() gopacket.CaptureInfo
• type TcpStream
  • func (t *TcpStream) Accept(tcp *layers.TCP, ci gopacket.CaptureInfo, dir reassembly.TCPFlowDirection, ...) bool
  • func (t *TcpStream) ReassembledSG(sg reassembly.ScatterGather, ac reassembly.AssemblerContext)
  • func (t *TcpStream) ReassemblyComplete(ac reassembly.AssemblerContext) bool
• type TcpStreamFactory
  • func (factory *TcpStreamFactory) New(net, transport gopacket.Flow, tcp *layers.TCP, ac reassembly.AssemblerContext) reassembly.Stream

Types

type Context

type Context struct {
	SqlType     int
	CaptureInfo gopacket.CaptureInfo
	Storage     *storage.Storage
}

* The assembler context

func (*Context) GetCaptureInfo

func (c *Context) GetCaptureInfo() gopacket.CaptureInfo

type TcpStream

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

It's a connection (bidirectional)

func (*TcpStream) Accept

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

func (*TcpStream) ReassembledSG

func (t *TcpStream) ReassembledSG(sg reassembly.ScatterGather, ac reassembly.AssemblerContext)

func (*TcpStream) ReassemblyComplete

func (t *TcpStream) ReassemblyComplete(ac reassembly.AssemblerContext) bool

type TcpStreamFactory

type TcpStreamFactory struct {
	Queue queue.Queue
}

* The TCP factory: returns a new Stream

func (*TcpStreamFactory) New

func (factory *TcpStreamFactory) New(net, transport gopacket.Flow, tcp *layers.TCP, ac reassembly.AssemblerContext) reassembly.Stream