parser

Documentation

Index

• func Chunked(content []byte, max int) chan []byte
• func Count(content []byte, max int) int
• type MessageParser
  • func DetectProtocol(data []byte) (*MessageParser, error)
  • func NewParser(name string) (*MessageParser, error)
  • func (parser *MessageParser) ReadMessage(conn io.ReadWriteCloser, length uint32) (*implantpb.Spites, error)
  • func (parser *MessageParser) ReadPacket(conn io.ReadWriteCloser) (uint32, *implantpb.Spites, error)
  • func (parser *MessageParser) WritePacket(conn net.Conn, msg *implantpb.Spites, sid uint32) error
• type PacketParser
• type SpitesCache
  • func NewSpitesBuf() *SpitesCache
  • func (sc *SpitesCache) Append(spite *implantpb.Spite)
  • func (sc *SpitesCache) Build() *implantpb.Spites
  • func (sc *SpitesCache) BuildOrEmpty() *implantpb.Spites
  • func (sc *SpitesCache) Len() int
  • func (sc *SpitesCache) Reset()

Functions

func Chunked

func Chunked(content []byte, max int) chan []byte

func Count

func Count(content []byte, max int) int

Types

type MessageParser

type MessageParser struct {
	Implant string
	PacketParser
}

func DetectProtocol

func DetectProtocol(data []byte) (*MessageParser, error)

DetectProtocol 检测协议类型

func NewParser

func NewParser(name string) (*MessageParser, error)

func (*MessageParser) ReadMessage

func (parser *MessageParser) ReadMessage(conn io.ReadWriteCloser, length uint32) (*implantpb.Spites, error)

func (*MessageParser) ReadPacket

func (parser *MessageParser) ReadPacket(conn io.ReadWriteCloser) (uint32, *implantpb.Spites, error)

func (*MessageParser) WritePacket

func (parser *MessageParser) WritePacket(conn net.Conn, msg *implantpb.Spites, sid uint32) error

type PacketParser

type PacketParser interface {
	//PeekHeader(conn io.ReadWriteCloser) (uint32, uint32, error)
	ReadHeader(conn io.ReadWriteCloser) (uint32, uint32, error)
	Parse([]byte) (*implantpb.Spites, error)
	Marshal(*implantpb.Spites, uint32) ([]byte, error)
}

PacketParser packet parser, like malefic, beacon ...

type SpitesCache

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

func NewSpitesBuf

func NewSpitesBuf() *SpitesCache

func (*SpitesCache) Append

func (sc *SpitesCache) Append(spite *implantpb.Spite)

func (*SpitesCache) Build

func (sc *SpitesCache) Build() *implantpb.Spites

func (*SpitesCache) BuildOrEmpty

func (sc *SpitesCache) BuildOrEmpty() *implantpb.Spites

func (*SpitesCache) Len

func (sc *SpitesCache) Len() int

func (*SpitesCache) Reset

func (sc *SpitesCache) Reset()