stream

Documentation

Index

• type Context
  • func (c *Context) GetCaptureInfo() gopacket.CaptureInfo
• type Packet
  • func NewPacket(proto decoder.ApplicationPortocol, t *layers.TCP) *Packet
  • func (p *Packet) Append(data []byte) int
  • func (p *Packet) Completed() bool
  • func (p *Packet) Data() []byte
• type TCPStream
  • func NewTCPStream(netFlow, tcpFlow gopacket.Flow, tcp *layers.TCP) *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()

Types

type Context

type Context struct {
	CaptureInfo gopacket.CaptureInfo
}

func (*Context) GetCaptureInfo

func (c *Context) GetCaptureInfo() gopacket.CaptureInfo

type Packet

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

func NewPacket

func NewPacket(proto decoder.ApplicationPortocol, t *layers.TCP) *Packet

func (*Packet) Append

func (p *Packet) Append(data []byte) int

func (*Packet) Completed

func (p *Packet) Completed() bool

func (*Packet) Data

func (p *Packet) Data() []byte

type TCPStream

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

func NewTCPStream

func NewTCPStream(netFlow, tcpFlow gopacket.Flow, tcp *layers.TCP) *TCPStream

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

关闭连接时调用，一般会在FlushOption时调用

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()