Versions in this module Expand all Collapse all v0 v0.4.0 May 5, 2022 Changes in this version + const ApproxCountDistinctRing + const Attr + const AvgRing + const Binary + const BitAndNumericRing + const BitOrRing + const BitXorRing + const CountRing + const DefaultRing + const Func + const MaxDateRing + const MaxDatetimeRing + const MaxFloat32Ring + const MaxFloat64Ring + const MaxInt16Ring + const MaxInt32Ring + const MaxInt64Ring + const MaxInt8Ring + const MaxStrRing + const MaxUInt16Ring + const MaxUInt32Ring + const MaxUInt64Ring + const MaxUInt8Ring + const MinDateRing + const MinDatetimeRing + const MinFloat32Ring + const MinFloat64Ring + const MinInt16Ring + const MinInt32Ring + const MinInt64Ring + const MinInt8Ring + const MinStrRing + const MinUInt16Ring + const MinUInt32Ring + const MinUInt64Ring + const MinUInt8Ring + const Multi + const Paren + const Star + const StarCountRing + const StdDevPopRing + const SumFloatRing + const SumIntRing + const SumUIntRing + const Unary + const Value + const VarianceRing + func DecodeBatch(data []byte) (*batch.Batch, []byte, error) + func DecodeBatchWithProcess(data []byte, proc *process.Process) (*batch.Batch, []byte, error) + func DecodeExtend(data []byte) (extend.Extend, []byte, error) + func DecodeInstruction(data []byte) (vm.Instruction, []byte, error) + func DecodeInstructions(data []byte) (vm.Instructions, []byte, error) + func DecodeRing(data []byte) (ring.Ring, []byte, error) + func DecodeRingWithProcess(data []byte, proc *process.Process) (ring.Ring, []byte, error) + func DecodeVector(data []byte) (*vector.Vector, []byte, error) + func EncodeBatch(bat *batch.Batch, buf *bytes.Buffer) error + func EncodeExtend(e extend.Extend, buf *bytes.Buffer) error + func EncodeInstruction(in vm.Instruction, buf *bytes.Buffer) error + func EncodeInstructions(ins vm.Instructions, buf *bytes.Buffer) error + func EncodeRing(r ring.Ring, buf *bytes.Buffer) error + func EncodeScope(s Scope, buf *bytes.Buffer) error + func EncodeVector(v *vector.Vector, buf *bytes.Buffer) error + func UntransferTransformArg(arg TransformArgument) *transform.Argument + type DedupArgument struct + type Field struct + Attr string + Type int8 + type JoinArgument struct + Result []string + Vars [][]string + type LimitArgument struct + Limit uint64 + Seen uint64 + type MergeArgument struct + type Node struct + Addr string + Data []byte + Id string + type OffsetArgument struct + Offset uint64 + Seen uint64 + type OplusArgument struct + Typ int + type OrderArgument struct + Fs []Field + type OutputArgument struct + Attrs []string + type PlusArgument struct + Typ int + type ProjectionArgument struct + As []string + Rs []uint64 + type RestrictArgument struct + Attrs []string + type Scope struct + DataSource Source + Ins vm.Instructions + Magic int + NodeInfo Node + PreScopes []Scope + func DecodeScope(data []byte) (Scope, []byte, error) + type Source struct + Attributes []string + IsMerge bool + RefCounts []uint64 + RelationName string + SchemaName string + type TimesArgument struct + Result []string + Vars [][]string + type TopArgument struct + Fs []Field + Limit int64 + type TransformArgument struct + BoundVars []Transformer + FreeVars []string + HasProj bool + HasRestrict bool + IsMerge bool + IsNull bool + Projection ProjectionArgument + Restrict RestrictArgument + Typ int + func TransferTransformArg(arg *transform.Argument) TransformArgument + type Transformer struct + Alias string + Name string + Op int + Ref int + type UntransformArgument struct + FreeVars []string + Type int