Versions in this module Expand all Collapse all v3 v3.0.0 Aug 27, 2020 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 Other modules containing this package github.com/jukrut/gopacket
Go to main page