Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

reassembly

package

Go to main page

Versions in this module

v1

v1.1.24

Jan 22, 2021

v1.1.23

Nov 10, 2020

v1.1.22

Nov 9, 2020

v1.1.22-dev

Nov 7, 2020

v1.1.21

Aug 3, 2020

Changes in this version

type Stream

+ Destroy func()

v1.1.20

Aug 2, 2020

v1.1.19

Aug 2, 2020

v1.1.16

Feb 1, 2019

v1.1.15

Sep 20, 2018

v1.1.14

Sep 28, 2017

v1.1.13

Aug 8, 2017

Changes in this version

+ const TCPStateCloseWait

+ const TCPStateClosed

+ const TCPStateEstablished

+ const TCPStateLastAck

+ const TCPStateReset

+ const TCPStateSynSent

+ var DefaultAssemblerOptions = AssemblerOptions

+ type Assembler struct

+ func NewAssembler(pool *StreamPool) *Assembler

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

+ func (a *Assembler) AssembleWithContext(netFlow gopacket.Flow, t *layers.TCP, ac AssemblerContext)

+ func (a *Assembler) Dump() string

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

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

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

+ type AssemblerContext interface

+ GetCaptureInfo func() gopacket.CaptureInfo

+ type AssemblerOptions struct

+ MaxBufferedPagesPerConnection int

+ MaxBufferedPagesTotal int

+ type FlushOptions struct

+ T time.Time

+ TC time.Time

+ type ScatterGather interface

+ CaptureInfo func(offset int) gopacket.CaptureInfo

+ Fetch func(length int) []byte

+ Info func() (direction TCPFlowDirection, start bool, end bool, skip int)

+ KeepFrom func(offset int)

+ Lengths func() (int, int)

+ Stats func() TCPAssemblyStats

+ type Sequence int64

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

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

+ type Stream interface

+ Accept func(tcp *layers.TCP, ci gopacket.CaptureInfo, dir TCPFlowDirection, ...) bool

+ ReassembledSG func(sg ScatterGather, ac AssemblerContext)

+ ReassemblyComplete func(ac AssemblerContext) bool

+ type StreamFactory interface

+ New func(netFlow, tcpFlow gopacket.Flow, tcp *layers.TCP, ac AssemblerContext) Stream

+ type StreamPool struct

+ func NewStreamPool(factory StreamFactory) *StreamPool

+ func (p *StreamPool) Dump()

+ type TCPAssemblyStats struct

+ Chunks int

+ OverlapBytes int

+ OverlapPackets int

+ Packets int

+ QueuedBytes int

+ QueuedPackets int

+ type TCPFlowDirection bool

+ const TCPDirClientToServer

+ const TCPDirServerToClient

+ func (dir TCPFlowDirection) Reverse() TCPFlowDirection

+ func (dir TCPFlowDirection) String() string

+ type TCPOptionCheck struct

+ func NewTCPOptionCheck() TCPOptionCheck

+ func (t *TCPOptionCheck) Accept(tcp *layers.TCP, ci gopacket.CaptureInfo, dir TCPFlowDirection, acked Sequence, ...) error

+ type TCPSimpleFSM struct

+ func NewTCPSimpleFSM(options TCPSimpleFSMOptions) *TCPSimpleFSM

+ func (t *TCPSimpleFSM) CheckState(tcp *layers.TCP, dir TCPFlowDirection) bool

+ func (t *TCPSimpleFSM) String() string

+ type TCPSimpleFSMOptions struct

+ SupportMissingEstablishment bool