stream_parser

package

v1.4.4-alpha1202-diff-... Latest Latest Go to latest Published: Dec 2, 2025 License: AGPL-3.0 Imports: 15 Imported by: 4

Details

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

Repository

github.com/yaklang/yaklang

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AnyToInt64(d any) int64
func AnyToUint64(d any) uint64
func CalcNodeResultLength(node *base.Node) uint64
func ConvertToBytes(v any, length uint64, endian string) ([]byte, error)
func ConvertToVar(v []byte, length uint64, endian, typeName string) any
func ExecInput(node *base.Node) (res any, err error)
func ExecOperator(node *base.Node, code string, ...) error
func ExecOut(node *base.Node) (res *base.NodeValue, err error)
func ExecParser(node *base.Node) (res any, err error)
func GetBytesByNode(node *base.Node) []byte
func GetNodePath(node *base.Node) string
func GetNodeResult(node *base.Node) any
func GetNodeResultPos(node *base.Node) [2]uint64
func GetParentLengthCache(parentNode *base.Node, childName string) (uint64, bool)
func GetParentNode(node *base.Node) *base.Node
func GetResultByNode(node *base.Node) any
func GetSubNodes(node *base.Node) []*base.Node
func InitNode(node *base.Node) error
func IsNumber(d any) bool
func ListNodeNewElement(node *base.Node) (*base.Node, error)
func NewNodeByType(node *base.Node, typeName string) (*base.Node, error)
func NodeHasResult(node *base.Node) bool
func NodeIsDelimiter(node *base.Node) bool
func NodeIsTerminal(node *base.Node) bool
func ParseRefNode(node *base.Node) (*base.Node, error)
func SetParentLengthCache(parentNode *base.Node, childName string, l uint64)
func ToMap(node *base.Node) (*base.NodeValue, error)
type DefParser
- func (d *DefParser) Generate(data any, node *base.Node) error
- func (d *DefParser) OnRoot(node *base.Node) error
- func (d *DefParser) Operate(operator *Operator, node *base.Node) error
- func (d *DefParser) Parse(data *base.BitReader, node *base.Node) error
- func (d *DefParser) Result(node *base.Node) (*base.NodeValue, error)
type Operator
type YakNode
- func ConvertToYakNode(node *base.Node, operator func(node *base.Node) (func(bool), error)) *YakNode

Constants ¶

View Source

const (
	CfgIsTerminal          = "isTerminal"
	CfgIsList              = "list"
	CfgIsTempRoot          = "temp root"
	CfgLength              = "length"
	CfgUnit                = "unit"
	CfgType                = "type"
	CfgGetResult           = "get result"
	CfgRawResult           = "raw result"
	CfgRootMap             = "rootNodeMap"
	CfgEndian              = "endian"
	CfgOperator            = "operator"
	CfgInList              = "inList"
	CfgParent              = "parent"
	CfgDel                 = "del"
	CfgDelimiter           = "delimiter"
	CfgImport              = "import"
	CfgNodeResult          = "node result"
	CfgLastNode            = "last node"
	CfgElementIndex        = "element index"
	CfgExceptionPlan       = "exception-plan"
	CtxGenReaders          = "readers in generator"
	CfgIsRefType           = "is ref type"
	CfgRefType             = "ref-type"
	CfgLengthFromField     = "length-from-field"
	CfgLengthForStartField = "length-for-start-field"
	CfgLengthForField      = "length-for-field"
	CfgStopValue           = "stop-value"
	CfgLengthCacheMap      = "length-cache-map"
)

View Source

const (
	ParserMode    = "parser"
	GeneratorMode = "geneartor"
)

Variables ¶

This section is empty.

Functions ¶

func AnyToInt64 ¶

func AnyToInt64(d any) int64

func AnyToUint64 ¶

func AnyToUint64(d any) uint64

func CalcNodeResultLength ¶

func CalcNodeResultLength(node *base.Node) uint64

func ConvertToBytes ¶

func ConvertToBytes(v any, length uint64, endian string) ([]byte, error)

func ConvertToVar ¶

func ConvertToVar(v []byte, length uint64, endian, typeName string) any

func ExecInput ¶

func ExecInput(node *base.Node) (res any, err error)

func ExecOperator ¶

func ExecOperator(node *base.Node, code string, operator func(node *base.Node) (func(bool), error)) error

func ExecOut ¶

func ExecOut(node *base.Node) (res *base.NodeValue, err error)

func ExecParser ¶

func ExecParser(node *base.Node) (res any, err error)

func GetBytesByNode ¶

func GetBytesByNode(node *base.Node) []byte

func GetNodePath ¶

func GetNodePath(node *base.Node) string

func GetNodeResult ¶

func GetNodeResult(node *base.Node) any

func GetNodeResultPos ¶

func GetNodeResultPos(node *base.Node) [2]uint64

func GetParentLengthCache ¶ added in v1.3.2

func GetParentLengthCache(parentNode *base.Node, childName string) (uint64, bool)

func GetParentNode ¶

func GetParentNode(node *base.Node) *base.Node

func GetResultByNode ¶

func GetResultByNode(node *base.Node) any

func GetSubNodes ¶

func GetSubNodes(node *base.Node) []*base.Node

func InitNode ¶

func InitNode(node *base.Node) error

func IsNumber ¶

func IsNumber(d any) bool

func ListNodeNewElement ¶

func ListNodeNewElement(node *base.Node) (*base.Node, error)

func NewNodeByType ¶

func NewNodeByType(node *base.Node, typeName string) (*base.Node, error)

func NodeHasResult ¶

func NodeHasResult(node *base.Node) bool

func NodeIsDelimiter ¶

func NodeIsDelimiter(node *base.Node) bool

func NodeIsTerminal ¶

func NodeIsTerminal(node *base.Node) bool

func ParseRefNode ¶

func ParseRefNode(node *base.Node) (*base.Node, error)

func SetParentLengthCache ¶ added in v1.3.2

func SetParentLengthCache(parentNode *base.Node, childName string, l uint64)

func ToMap ¶

func ToMap(node *base.Node) (*base.NodeValue, error)

Types ¶

type DefParser ¶

type DefParser struct {
	base.BaseParser
	// contains filtered or unexported fields
}

func (*DefParser) Generate ¶

func (d *DefParser) Generate(data any, node *base.Node) error

func (*DefParser) OnRoot ¶

func (d *DefParser) OnRoot(node *base.Node) error

OnRoot 设置了Ctx: root、rootNodeMap; Cfg：parent、lastNode,writer,buffer、isTerminal

func (*DefParser) Operate ¶

func (d *DefParser) Operate(operator *Operator, node *base.Node) error

func (*DefParser) Parse ¶

func (d *DefParser) Parse(data *base.BitReader, node *base.Node) error

func (*DefParser) Result ¶

func (d *DefParser) Result(node *base.Node) (*base.NodeValue, error)

type Operator ¶

type Operator struct {
	ParseStruct   func(node *base.Node) (bool, error)
	ParseTerminal func(node *base.Node) error
	NodeParse     func(node *base.Node) error
	Mode          string
	Backup        func() error
	Recovery      func() error
	PopBackup     func() error
}

type YakNode ¶

type YakNode struct {
	Process              func() any
	Result               func() any
	Name                 string
	SetCfg               func(k string, v any)
	GetCfg               func(k string) any
	AppendNode           func(d *YakNode)
	ForEachChild         func(f func(child *YakNode))
	GetParent            func() *YakNode
	GetSubNode           func(name string) *YakNode
	GetRemainingSpace    func() uint64
	CalcNodeResultLength func() uint64
	NewElement           func() *YakNode

	SetChildren       func([]*YakNode)
	GetChildren       func() []*YakNode
	Length            func(uint ...string) uint64
	SetMaxLength      func(l uint64, uint ...string)
	GetMaxLength      func(uint ...string) uint64
	NewSubNode        func(datas ...any) *YakNode
	NewUnknownNode    func(name ...string) *YakNode
	NewEmptyNode      func(name ...string) *YakNode
	ProcessSubNode    func(name string) any
	TryProcessSubNode func(name string) (any, map[string]any)
	ProcessByType     func(datas ...any) any
	TryProcessByType  func(datas ...string) (any, map[string]any)
	AddInfo           func(key string, v any)
	GetInfo           func(key string) any
	// contains filtered or unexported fields
}

func ConvertToYakNode ¶

func ConvertToYakNode(node *base.Node, operator func(node *base.Node) (func(bool), error)) *YakNode

Source Files ¶

View all Source files

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