stream

Documentation

Index

• func DecompressBody(header http.Header, reader io.ReadCloser) (io.ReadCloser, bool)
• type HTTPDirect
  • func (dir HTTPDirect) String() string
• type TCPStream
  • func (self *TCPStream) Accept(tcp *layers.TCP, ci gopacket.CaptureInfo, dir reassembly.TCPFlowDirection, ...) bool
  • func (self *TCPStream) ReassembledSG(sg reassembly.ScatterGather, ac reassembly.AssemblerContext)
  • func (self *TCPStream) ReassemblyComplete(ac reassembly.AssemblerContext) bool
• type TCPStreamFactory
  • func (self *TCPStreamFactory) New(netFlow, tcpFlow gopacket.Flow, tcp *layers.TCP, ...) reassembly.Stream
  • func (self *TCPStreamFactory) WaitGoRoutines()

Functions

func DecompressBody

func DecompressBody(header http.Header, reader io.ReadCloser) (io.ReadCloser, bool)

Types

type HTTPDirect

type HTTPDirect int

const (
	HTTPDirectUnknown  HTTPDirect = -1
	HTTPDirectRequest  HTTPDirect = 0
	HTTPDirectResopnse HTTPDirect = 1
)

Value are not really useful

func (HTTPDirect) String

func (dir HTTPDirect) String() string

type TCPStream

type TCPStream struct {

	//urls     []string
	//all      []httpGroup
	//hg sync.Mutex
	sync.Mutex
	// contains filtered or unexported fields
}

func (*TCPStream) Accept

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

每次收到包时调用

func (*TCPStream) ReassembledSG

func (self *TCPStream) ReassembledSG(sg reassembly.ScatterGather, ac reassembly.AssemblerContext)

func (*TCPStream) ReassemblyComplete

func (self *TCPStream) ReassemblyComplete(ac reassembly.AssemblerContext) bool

连接被关闭时的操作

type TCPStreamFactory

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

func (*TCPStreamFactory) New

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

func (*TCPStreamFactory) WaitGoRoutines

func (self *TCPStreamFactory) WaitGoRoutines()