flowsdecoder

Documentation

Index

• type Decoder
  • func New(options DecoderOptions) *Decoder
  • func (fd *Decoder) EthernetFrame(bs []byte) error
  • func (fd *Decoder) Flush()
  • func (fd *Decoder) IPv4Packet(bs []byte) error
  • func (fd *Decoder) IPv6Packet(bs []byte) error
  • func (fd *Decoder) LoopbackFrame(bs []byte) error
  • func (fd *Decoder) New(net, transport gopacket.Flow, tcp *layers.TCP, ac reassembly.AssemblerContext) reassembly.Stream
  • func (fd *Decoder) RAWIPFrame(bs []byte) error
  • func (fd *Decoder) SLL2Packet(bs []byte) error
  • func (fd *Decoder) SLLPacket(bs []byte) error
• type DecoderOptions
• type IPV4Reassembled
• type TCPConnection
  • func (t *TCPConnection) Accept(tcp *layers.TCP, ci gopacket.CaptureInfo, dir reassembly.TCPFlowDirection, ...) bool
  • func (t *TCPConnection) ReassembledSG(sg reassembly.ScatterGather, ac reassembly.AssemblerContext)
  • func (t *TCPConnection) ReassemblyComplete(ac reassembly.AssemblerContext) bool
• type TCPDirection
• type TCPEndpoint

Types

type Decoder

type Decoder struct {
	Options DecoderOptions

	TCPConnections  []*TCPConnection
	IPV4Reassembled []IPV4Reassembled
	// contains filtered or unexported fields
}

func New

func New(options DecoderOptions) *Decoder

func (*Decoder) EthernetFrame

func (fd *Decoder) EthernetFrame(bs []byte) error

func (*Decoder) Flush

func (fd *Decoder) Flush()

func (*Decoder) IPv4Packet

func (fd *Decoder) IPv4Packet(bs []byte) error

func (*Decoder) IPv6Packet

func (fd *Decoder) IPv6Packet(bs []byte) error

func (*Decoder) LoopbackFrame

func (fd *Decoder) LoopbackFrame(bs []byte) error

func (*Decoder) New

func (fd *Decoder) New(net, transport gopacket.Flow, tcp *layers.TCP, ac reassembly.AssemblerContext) reassembly.Stream

func (*Decoder) RAWIPFrame

func (fd *Decoder) RAWIPFrame(bs []byte) error

LinkTypeRAW IPv4 or Ipv6

func (*Decoder) SLL2Packet

func (fd *Decoder) SLL2Packet(bs []byte) error

func (*Decoder) SLLPacket

func (fd *Decoder) SLLPacket(bs []byte) error

type DecoderOptions

type DecoderOptions struct {
	CheckTCPOptions bool
}

type IPV4Reassembled

type IPV4Reassembled struct {
	SourceIP      net.IP
	DestinationIP net.IP
	Datagram      []byte
}

type TCPConnection

type TCPConnection struct {
	Client *TCPDirection
	Server *TCPDirection
	// contains filtered or unexported fields
}

func (*TCPConnection) Accept

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

func (*TCPConnection) ReassembledSG

func (t *TCPConnection) ReassembledSG(sg reassembly.ScatterGather, ac reassembly.AssemblerContext)

func (*TCPConnection) ReassemblyComplete

func (t *TCPConnection) ReassemblyComplete(ac reassembly.AssemblerContext) bool

type TCPDirection

type TCPDirection struct {
	Endpoint     TCPEndpoint
	HasStart     bool
	HasEnd       bool
	Buffer       *bytes.Buffer
	SkippedBytes uint64
}

type TCPEndpoint

type TCPEndpoint struct {
	IP   net.IP
	Port int
}