parser

package

v0.1.2 Latest Latest Go to latest Published: Sep 25, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/chainreactors/malice-network

Links

Open Source Insights

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)
type PacketParser
type SpitesCache
- func NewSpitesBuf() *SpitesCache

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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 ¶ added in v0.1.1

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) WithSecure ¶ added in v0.1.2

func (mp *MessageParser) WithSecure(keyPair *clientpb.KeyPair)

WithSecure 为 MessageParser 添加安全支持

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
malefic
pulse

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL