Versions in this module Expand all Collapse all v1 v1.2.0 Mar 10, 2020 v1.1.15 Sep 20, 2018 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) AssembleWithTimestamp(netFlow gopacket.Flow, t *layers.TCP, timestamp time.Time) + func (a *Assembler) FlushAll() (closed int) + func (a *Assembler) FlushOlderThan(t time.Time) (flushed, closed int) + func (a *Assembler) FlushWithOptions(opt FlushOptions) (flushed, closed int) + type AssemblerOptions struct + MaxBufferedPagesPerConnection int + MaxBufferedPagesTotal int + type FlushOptions struct + CloseAll bool + T time.Time + 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
Go to main page