tcpassembly

Oct 19, 2016

Changes in this version

type Assembler

+ func (a *Assembler) FlushWithOptions(opt FlushOptions) (flushed, closed int)

+ type FlushOptions struct

+ CloseAll bool

+ T time.Time

Feb 13, 2014

Changes in this version

type Assembler

+ func (a *Assembler) AssembleWithTimestamp(netFlow gopacket.Flow, t *layers.TCP, timestamp time.Time)

Oct 4, 2013

Changes in this version

+ var DefaultAssemblerOptions = AssemblerOptions

+ type Assembler struct

+ func NewAssembler(pool *StreamPool) *Assembler

+ func (a *Assembler) Assemble(netFlow gopacket.Flow, t *layers.TCP)

+ func (a *Assembler) FlushAll() (closed int)

+ func (a *Assembler) FlushOlderThan(t time.Time) (flushed, closed int)

+ type AssemblerOptions struct

+ MaxBufferedPagesPerConnection int

+ MaxBufferedPagesTotal int

+ type Reassembly struct

+ Bytes []byte

+ End bool

+ Seen time.Time

+ Skip int

+ Start bool

+ type Sequence int64

+ func (s Sequence) Add(t int) Sequence

+ func (s Sequence) Difference(t Sequence) int

+ type Stream interface

+ Reassembled func([]Reassembly)

+ ReassemblyComplete func()

+ type StreamFactory interface

+ New func(netFlow, tcpFlow gopacket.Flow) Stream

+ type StreamPool struct

+ func NewStreamPool(factory StreamFactory) *StreamPool