assembly

Documentation

Index

• type Pool
  • func New(logger log.Logger, analysis *analysis.Pool, protocol model.ProtocolType, ...) *Pool
  • func (p *Pool) HandlePackets(dps []*decode.DecodedPacket) (err error)

Types

type Pool

type Pool struct {
	Logger log.Logger
	// contains filtered or unexported fields
}

Pool manages a set of workers each responsible for a set of TCP conversations (stream pairs).

func New

func New(logger log.Logger, analysis *analysis.Pool, protocol model.ProtocolType, ports []int, numWorkers int) *Pool

New creates a new pool for reassembling TCP streams.

func (*Pool) HandlePackets

func (p *Pool) HandlePackets(dps []*decode.DecodedPacket) (err error)

HandlePackets partitions packets by connection and dispatches them to assembly workers.