Versions in this module Expand all Collapse all v0 v0.1.0 Mar 4, 2024 Changes in this version + type Stream interface + Closed func() bool + Recv func() <-chan []byte + type StreamConfig struct + MaxBuffered int + RecvBufferLen int + type StreamFactory interface + New func(flow string, stream Stream) + type StreamPool struct + func NewStreamPool(factory StreamFactory, cfg StreamConfig) *StreamPool + func (p *StreamPool) AssembleWithTimestamp(netFlow gopacket.Flow, t *layers.TCP, timestamp time.Time) + func (p *StreamPool) FlushOlderThan(t time.Time)
Go to main page