qdf

package module

Go to main page

Versions in this module

v0

v0.1.2

Jul 18, 2026

Changes in this version

+ type Batch struct

+ Rows []T

+ func UnmarshalBatch[T any](data []byte, opts ...QueryOption) (Batch[T], error)

+ func (b *Batch[T]) BytesOf(h Bytes) []byte

+ func (b *Batch[T]) Release()

+ func (b *Batch[T]) Str(h Str) string

+ func (b *Batch[T]) TimeOf(h Time) time.Time

+ type Bytes struct

type Encoder

+ func (e *Encoder) EncodeAny(v any) error

+ func (e *Encoder) Suspended() bool

+ type Str struct

+ type Time struct

+ Nsec uint32

+ Sec int64

v0.1.1

Jul 2, 2026

Changes in this version

+ func CheckColumnarBytes(n int, elemSize uintptr) error

+ func StringColumnsBeneficialHybrid(cols ...[]string) bool

+ type CmpOp uint8

+ const EQ

+ const GE

+ const GT

+ const LE

+ const LT

+ const NE

type Encoder

+ func (e *Encoder) Canonical() bool

+ func (e *Encoder) SetVectorBudget(b VectorBudget)

type Options

+ const OptLossyVec

+ const OptZoneMap

+ type Ordered interface

type QueryOption

+ func WhereCmp[T Ordered](field string, op CmpOp, val T) QueryOption

+ func WhereRange[T Ordered](field string, lo, hi T) QueryOption

+ type VectorBudget struct

+ func MaxRelError(eps float64) VectorBudget

+ func MinCosine(c float64) VectorBudget

+ func TargetSNR(db float64) VectorBudget

v0.1.0

May 29, 2026

v0.0.9

Jun 22, 2026

v0.0.8

Jun 20, 2026

Changes in this version

+ var ErrBaselineEvicted = errors.New("qdf: patch baseline not found in registry (never registered or GC-reclaimed)")

+ var ErrBaselineRequired = errors.New("qdf: patch has no base fingerprint; baseline registry requires one")

+ var ErrInvalidPatch = errors.New("qdf: invalid or truncated patch")

+ var ErrPatchBaseMismatch = errors.New("qdf: patch base fingerprint mismatch")

+ var ErrPatchSchemaMismatch = errors.New("qdf: patch schema fingerprint mismatch")

+ func AppendDiff[T any](dst []byte, old, new T, opts Options) ([]byte, error)

+ func ApplyArena[T any](base *T, patch []byte, arena *Arena) error

+ func Apply[T any](base *T, patch []byte) error

+ func DecodeNested(d *Decoder, u Unmarshaler) error

+ func Diff[T any](old, new T, opts Options) ([]byte, error)

+ func StringColumnsBeneficial(cols ...[]string) bool

+ type BaselineRegistry struct

+ func NewBaselineRegistry[T any]() *BaselineRegistry[T]

+ func (r *BaselineRegistry[T]) Apply(patch []byte) (*T, error)

+ func (r *BaselineRegistry[T]) Len() int

+ func (r *BaselineRegistry[T]) Register(v *T) uint64

type Decoder

+ func (d *Decoder) ClearColMaxLen()

+ func (d *Decoder) DecodeValue(out *any) error

+ func (d *Decoder) PeekColStruct() bool

+ func (d *Decoder) PeekHybridColStruct() bool

+ func (d *Decoder) ReadBoolColumn(n int) ([]bool, error)

+ func (d *Decoder) ReadColNullMask(n int) ([]byte, int, error)

+ func (d *Decoder) ReadColStructHeader() (int, []string, []byte, error)

+ func (d *Decoder) ReadFloat32Column(n int) ([]float32, error)

+ func (d *Decoder) ReadFloat64Column(n int) ([]float64, error)

+ func (d *Decoder) ReadHybridColStructHeader() (int, []string, []byte, error)

+ func (d *Decoder) ReadIntColumn(n int) ([]int64, error)

+ func (d *Decoder) ReadStringColumn(n int) ([]string, error)

+ func (d *Decoder) ReadStructHeader() (names []string, plainN int, shaped bool, err error)

+ func (d *Decoder) ReadTimeColumn(n int) ([]int64, []uint64, error)

+ func (d *Decoder) ReadUintColumn(n int) ([]uint64, error)

+ type DecoderUnmarshaler interface

+ DecodeQDF func(d *Decoder) error

type Encoder

+ func (e *Encoder) ScratchBool(n int) []bool

+ func (e *Encoder) ScratchFloat32(n int) []float32

+ func (e *Encoder) ScratchFloat64(n int) []float64

+ func (e *Encoder) ScratchInt(n int) []int64

+ func (e *Encoder) ScratchMask(n int) []byte

+ func (e *Encoder) ScratchString(n int) []string

+ func (e *Encoder) ScratchUint(n int) []uint64

+ func (e *Encoder) StructShape(token *byte, fieldHdrs [][]byte)

+ func (e *Encoder) WriteBoolColumn(s []bool) error

+ func (e *Encoder) WriteColNullMask(mask []byte)

+ func (e *Encoder) WriteColStructHeader(n int, names []string, kinds []byte)

+ func (e *Encoder) WriteFloat32Column(s []float32) error

+ func (e *Encoder) WriteFloat64Column(s []float64) error

+ func (e *Encoder) WriteHybridColStructHeader(n int, names []string, kinds []byte)

+ func (e *Encoder) WriteIntColumn(s []int64) error

+ func (e *Encoder) WriteStringColumn(s []string)

+ func (e *Encoder) WriteTimeColumn(secs []int64, nsec []uint64) error

+ func (e *Encoder) WriteUintColumn(s []uint64) error

type Options

+ const OptCanonical

+ const OptDeltaNoBaseFingerprint

type StreamDecoder

+ func (s *StreamDecoder) Reset(r io.Reader)

+ func (s *StreamDecoder) SetArena(a *Arena)

type StreamEncoder

+ func (s *StreamEncoder) Reset(w io.Writer)

v0.0.7

Jun 15, 2026

Changes in this version

+ func EncodeNested(e *Encoder, m Marshaler) error

+ type EncoderMarshaler interface

+ EncodeQDF func(e *Encoder) error

v0.0.6

Jun 14, 2026

Changes in this version

+ var ErrStreamBadFlags = errors.New("qdf: stream header has unsupported whole-payload flags")

+ func UnmarshalNestedArena(u Unmarshaler, src []byte, noCopy bool, a *Arena) (int, error)

+ type Arena struct

+ func NewArena() *Arena

+ func (a *Arena) Reset()

type Decoder

+ func (d *Decoder) SetArena(a *Arena)

type QueryOption

+ func WithArena(a *Arena) QueryOption

+ type UnmarshalerArena interface

+ UnmarshalQDFArena func(src []byte, noCopy bool, a *Arena) (n int, err error)

v0.0.5

Jun 11, 2026

v0.0.4

Jun 8, 2026

v0.0.3

Jun 5, 2026

Changes in this version

+ var ErrStreamDecoderBroken = errors.New("qdf: stream decoder broken by a prior mid-message error")

v0.0.2

Jun 5, 2026

Changes in this version

+ const FlagColIndex

+ const FlagRANS

+ var ErrFieldNotFound = errors.New("qdf: query predicate field not found")

+ var ErrStreamBroken = errors.New("qdf: stream encoder broken by a prior mid-message error")

+ func UnmarshalColumns(data []byte, out any, fields ...string) error

+ func UnmarshalNested(u Unmarshaler, src []byte, noCopy bool) (int, error)

type Decoder

+ func (d *Decoder) ReadTimestamp() (sec int64, nsec uint32, err error)

type Encoder

+ func (e *Encoder) WriteTimestamp(sec int64, nsec uint32)

+ type FSSTDict struct

+ func TrainFSSTDict(samples [][]byte) *FSSTDict

+ func TrainFSSTDictStrings(samples []string) *FSSTDict

+ func (d *FSSTDict) AppendMarshal(dst []byte, v any, opts Options) ([]byte, error)

+ func (d *FSSTDict) Marshal(v any, opts Options) ([]byte, error)

type Options

+ const OptColumnIndex

+ const OptFSST

+ const OptMapShape

+ const OptRANS

+ type QueryError struct

+ Err error

+ Field string

+ Got colKind

+ Op string

+ Want colKind

+ func (e *QueryError) Error() string

+ func (e *QueryError) Unwrap() error

+ type QueryOption struct

+ func And(opts ...QueryOption) QueryOption

+ func Not(opt QueryOption) QueryOption

+ func Or(opts ...QueryOption) QueryOption

+ func Select(fields ...string) QueryOption

+ func Where[T Queryable](field string, pred func(T) bool) QueryOption

+ func WithNoCopy() QueryOption

+ type Queryable interface

+ type UnmarshalerOpts interface

+ UnmarshalQDFOpts func(src []byte, noCopy bool) (n int, err error)

v0.0.1

May 28, 2026

Changes in this version

+ const DefaultMaxDepth

+ const FlagDense

+ const FlagQPack

+ const Magic0

+ const Magic1

+ const Magic2

+ const TagNil

+ const Version1

+ var ErrBadMagic = errors.New("qdf: bad magic / not a qdf stream")

+ var ErrBadTag = errors.New("qdf: unknown tag")

+ var ErrBadVersion = errors.New("qdf: unsupported wire version")

+ var ErrCycleDetected = errors.New("qdf: pointer cycle detected (max depth exceeded)")

+ var ErrInvalidLength = errors.New("qdf: invalid length prefix")

+ var ErrShortBuffer = errors.New("qdf: short buffer")

+ var ErrTypeMismatch = errors.New("qdf: type mismatch on decode")

+ var ErrUnknownStateID = errors.New("qdf: unknown state-table id")

+ var ErrUnsupported = errors.New("qdf: unsupported type")

+ func AppendMarshal(dst []byte, v any, opts Options) ([]byte, error)

+ func AppendMarshalDirect[T Marshaler](dst []byte, v T) ([]byte, error)

+ func AppendMarshalT[T any](dst []byte, v T, opts Options) ([]byte, error)

+ func Marshal(v any, opts Options) ([]byte, error)

+ func MarshalDirect[T Marshaler](v T) ([]byte, error)

+ func MarshalT[T any](v T, opts Options) ([]byte, error)

+ func Unmarshal(data []byte, out any) error

+ func UnmarshalDirect[T Unmarshaler](data []byte, out T) error

+ func UnmarshalT[T any](data []byte, out *T) error

+ type Decoder struct

+ func NewDecoder() *Decoder

+ func NewDecoderOnBuf(buf []byte) *Decoder

+ func (d *Decoder) Advance(n int)

+ func (d *Decoder) CheckLength(n int, perElem int) error

+ func (d *Decoder) InternKey(b []byte) string

+ func (d *Decoder) IsNil() (bool, error)

+ func (d *Decoder) MarkHeaderRead()

+ func (d *Decoder) PeekTag() (byte, error)

+ func (d *Decoder) Pos() int

+ func (d *Decoder) ReadArrayHeader() (int, error)

+ func (d *Decoder) ReadBool() (bool, error)

+ func (d *Decoder) ReadBytes() ([]byte, error)

+ func (d *Decoder) ReadFloat32() (float32, error)

+ func (d *Decoder) ReadFloat64() (float64, error)

+ func (d *Decoder) ReadInt() (int64, error)

+ func (d *Decoder) ReadMapHeader() (int, error)

+ func (d *Decoder) ReadNil() error

+ func (d *Decoder) ReadString() (string, error)

+ func (d *Decoder) ReadStringBytes() ([]byte, error)

+ func (d *Decoder) ReadTimestampNano() (int64, error)

+ func (d *Decoder) ReadUint() (uint64, error)

+ func (d *Decoder) Remaining() int

+ func (d *Decoder) RemainingBytes() []byte

+ func (d *Decoder) SetInput(buf []byte)

+ func (d *Decoder) SetNoCopy(v bool)

+ func (d *Decoder) Skip() error

+ type Encoder struct

+ func NewEncoder(mode Mode) *Encoder

+ func NewEncoderOnBuf(buf []byte, mode Mode) *Encoder

+ func NewEncoderWith(opts Options) *Encoder

+ func (e *Encoder) AdoptBuffer(b []byte)

+ func (e *Encoder) AppendBytes(p []byte)

+ func (e *Encoder) ApplyOpts(opts Options)

+ func (e *Encoder) Bytes() []byte

+ func (e *Encoder) EncodeValue(v any) error

+ func (e *Encoder) EnsureHeader()

+ func (e *Encoder) MarkHeaderWritten()

+ func (e *Encoder) PreIntern(strs ...string)

+ func (e *Encoder) QPack() bool

+ func (e *Encoder) Reset()

+ func (e *Encoder) SetBuffer(b []byte)

+ func (e *Encoder) SetIntern(min int, cap int)

+ func (e *Encoder) SetMaxDepth(d int)

+ func (e *Encoder) SetQPack(v bool)

+ func (e *Encoder) Take() []byte

+ func (e *Encoder) WriteArrayHeader(n int)

+ func (e *Encoder) WriteBool(v bool)

+ func (e *Encoder) WriteBytes(b []byte)

+ func (e *Encoder) WriteFloat32(v float32)

+ func (e *Encoder) WriteFloat64(v float64)

+ func (e *Encoder) WriteInt(v int64)

+ func (e *Encoder) WriteMapHeader(n int)

+ func (e *Encoder) WriteNil()

+ func (e *Encoder) WriteString(s string)

+ func (e *Encoder) WriteStringInline(s string)

+ func (e *Encoder) WriteTimestampNano(ns int64)

+ func (e *Encoder) WriteUint(v uint64)

+ type Marshaler interface

+ MarshalQDF func(dst []byte) ([]byte, error)

+ type Mode uint8

+ const Dense

+ const Fast

+ type Options uint32

+ const OptBalanced

+ const OptCompression

+ const OptDense

+ const OptGorillaFloat

+ const OptMTF

+ const OptPairPred

+ const OptQPack

+ const OptShapeIntern

+ const OptSpeed

+ func (o Options) Has(bit Options) bool

+ type StreamDecoder struct

+ func NewStreamDecoder(r io.Reader) *StreamDecoder

+ func (s *StreamDecoder) Close() error

+ func (s *StreamDecoder) Decode(out any) error

+ func (s *StreamDecoder) SetNoCopy(v bool)

+ type StreamEncoder struct

+ func NewStreamEncoder(w io.Writer, mode Mode) *StreamEncoder

+ func NewStreamEncoderWith(w io.Writer, opts Options) *StreamEncoder

+ func (s *StreamEncoder) Close() error

+ func (s *StreamEncoder) Encode(v any) error

+ func (s *StreamEncoder) Flush() error

+ type Unmarshaler interface

+ UnmarshalQDF func(src []byte) (n int, err error)

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