tcp

Documentation

Index

• type Factory
  • func New(ctx context.Context, cb factory.HandleFunc) *Factory
  • func (factory *Factory) Close() (err error)
  • func (factory *Factory) New(netFlow, tcpFlow gopacket.Flow, tcp *layers.TCP, ...) reassembly.Stream
• type Stream
  • func (stream *Stream) Accept(tcp *layers.TCP, ci gopacket.CaptureInfo, dir reassembly.TCPFlowDirection, ...) bool
  • func (stream *Stream) Close()
  • func (stream *Stream) Discard()
  • func (stream *Stream) FetchRequest() (req *httpkg.Request, res *httpkg.Response, err error)
  • func (stream *Stream) ReassembledSG(sg reassembly.ScatterGather, ac reassembly.AssemblerContext)
  • func (stream *Stream) ReassemblyComplete(ac reassembly.AssemblerContext) bool

Types

type Factory

type Factory struct {
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, cb factory.HandleFunc) *Factory

func (*Factory) Close

func (factory *Factory) Close() (err error)

func (*Factory) New

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

type Stream

type Stream struct {
	// contains filtered or unexported fields
}

func (*Stream) Accept

func (stream *Stream) Accept(tcp *layers.TCP, ci gopacket.CaptureInfo, dir reassembly.TCPFlowDirection, nextSeq reassembly.Sequence, start *bool, ac reassembly.AssemblerContext) bool

func (*Stream) Close

func (stream *Stream) Close()

func (*Stream) Discard

func (stream *Stream) Discard()

func (*Stream) FetchRequest

func (stream *Stream) FetchRequest() (req *httpkg.Request, res *httpkg.Response, err error)

func (*Stream) ReassembledSG

func (stream *Stream) ReassembledSG(sg reassembly.ScatterGather, ac reassembly.AssemblerContext)

func (*Stream) ReassemblyComplete

func (stream *Stream) ReassemblyComplete(ac reassembly.AssemblerContext) bool