query

Documentation

Index

• type DataType
• type Record
  • func NewRecord(vals []*RecordVals) *Record
  • func (r *Record) Release()
• type RecordProducer
• type RecordVals
  • func NewRecordVals(dataType DataType, rawData []byte) *RecordVals
  • func (rv *RecordVals) Decoded() any
  • func (rv *RecordVals) RawData() []byte
  • func (rv *RecordVals) Release()
• type Summary

Types

type DataType

type DataType byte

const (
	DataTypeBytes DataType = iota
	DataTypeSeqID
	DataTypeDocument
	DataTypeString
	DataTypeUint32
	DataTypeUint64
	DataTypeInt32
	DataTypeInt64
	DataTypeFloat64
	DataTypeFloat64Array
	DataTypeStringArray
)

type Record

type Record struct {
	Vals []*RecordVals
}

executors make use of val's index, executor's parameters has colIdx field

func NewRecord

func NewRecord(vals []*RecordVals) *Record

func (*Record) Release

func (r *Record) Release()

type RecordProducer

type RecordProducer interface {
	// Next returns the next record, or nil when the stream is exhausted. Errors
	// that occur during production are not returned here; they are accumulated
	// internally and reported via Finalize.
	Next() *Record
	// Finalize releases resources held by the producer and returns the final
	// summary gathered during the stream. It must be called exactly once after the
	// producer is exhausted.
	Finalize() *Summary
}

type RecordVals

type RecordVals struct {
	Type DataType
	// contains filtered or unexported fields
}

Executors make use of val's index. the plan knows which executors use which col indexes

func NewRecordVals

func NewRecordVals(dataType DataType, rawData []byte) *RecordVals

func (*RecordVals) Decoded

func (rv *RecordVals) Decoded() any

func (*RecordVals) RawData

func (rv *RecordVals) RawData() []byte

func (*RecordVals) Release

func (rv *RecordVals) Release()

Release returns the insaneJSON decoder (allocated for DataTypeDocument in ensureDecoded) back to the library's internal pool. It is idempotent: after the first call rv.decoded is cleared, so repeated calls are a no-op. Calling it on a non-document val or a not-yet-decoded val is also a no-op. Safe to invoke from every executor that has touched the val — the first caller wins.

type Summary

type Summary struct {
	Err   error
	Total uint64
}