Versions in this module Expand all Collapse all v0 v0.1.0 Aug 26, 2026 Changes in this version + const DefaultMaxSortBufferRows + func AssertLegColumnProvenanceCensus(w io.Writer, floors *LegColumnProvenanceFloors) bool + func EvaluateScalarSubquery(ctx context.Context, plan plans.RecordQueryPlan, ...) (any, error) + func ExecutePlan(ctx context.Context, plan plans.RecordQueryPlan, ...) (recordlayer.RecordCursor[QueryResult], error) + func FormatLegColumnProvenanceCensus() string + func LegColumnProvenanceCensus() (legColumnProvenanceCounters, []string) + func LegColumnProvenanceDottedNames() []string + func PositionalTypeForDescriptor(desc protoreflect.MessageDescriptor) *values.RecordType + func PositionalTypeForRecordLayout(desc protoreflect.MessageDescriptor, storeRowVersions bool) *values.RecordType + func RowValue(qr QueryResult) any + type AggregateTypeMismatchError struct + Message string + func (e *AggregateTypeMismatchError) Error() string + type ColumnDef struct + Label string + Name string + Nullable int + TypeName string + type EvaluationContext struct + func EmptyEvaluationContext() *EvaluationContext + func (ec *EvaluationContext) BindParameter(ordinal int, name string) (any, bool) + func (ec *EvaluationContext) GetBinding(id values.CorrelationIdentifier) (any, bool) + func (ec *EvaluationContext) GetCorrelationBinding(id values.CorrelationIdentifier) (any, bool) + func (ec *EvaluationContext) GetOrCreateTempTable(id values.CorrelationIdentifier, st *recordlayer.ExecuteState) *TempTable + func (ec *EvaluationContext) GetQuantifiedBinding(view values.QuantifiedObjectValue) (any, bool, error) + func (ec *EvaluationContext) IsExplicitNullQuantifiedBinding(view values.QuantifiedObjectValue) (bool, error) + func (ec *EvaluationContext) ReleaseAllTempTableCharges() + func (ec *EvaluationContext) RowContext() *values.RowEvalContext + func (ec *EvaluationContext) RowContextPositional(pos values.OrdinalRow) *values.RowEvalContext + func (ec *EvaluationContext) Scratch() *ExecutionScratch + func (ec *EvaluationContext) StatementNow() time.Time + func (ec *EvaluationContext) WithBinding(id values.CorrelationIdentifier, val any) *EvaluationContext + func (ec *EvaluationContext) WithExecutionScratch(s *ExecutionScratch) *EvaluationContext + func (ec *EvaluationContext) WithParams(params []any) *EvaluationContext + func (ec *EvaluationContext) WithScalarSubqueries(results map[values.CorrelationIdentifier]any) *EvaluationContext + func (ec *EvaluationContext) WithStatementTime(t time.Time) *EvaluationContext + type ExecutionScratch struct + func NewExecutionScratch() *ExecutionScratch + func (s *ExecutionScratch) BeginPage() + func (s *ExecutionScratch) LiveDistinctSets() int + func (s *ExecutionScratch) MintedDistinctSets() int64 + func (s *ExecutionScratch) PeakDistinctSets() int + func (s *ExecutionScratch) SweepAfterPage(exhausted bool) + type FilteredIndexPlanError struct + IndexName string + func (e *FilteredIndexPlanError) Error() string + type IncompatiblePhysicalComparandError struct + Comparison predicates.ComparisonType + Component int + PhysicalType values.Type + ProjectedType string + func (e *IncompatiblePhysicalComparandError) Error() string + type InvalidScanComparisonShapeError struct + Component int + Detail string + func (e *InvalidScanComparisonShapeError) Error() string + type InvalidScanRangeExecutionIdentityTypeError struct + ActivePath string + Implementation string + Kind ScanIdentityTypeErrorKind + Path string + func (e *InvalidScanRangeExecutionIdentityTypeError) Error() string + type LegColumnProvenanceFloors struct + type MaterializationLimitExceededError struct + Context string + Limit int + func (e *MaterializationLimitExceededError) Error() string + type NumericRangeOverflowError struct + Column string + TypeName string + Value any + func (e *NumericRangeOverflowError) Error() string + type PositionalRow struct + Layout values.OrdinalLayout + LayoutPresence values.WindowMatchPresence + Slots []any + Type *values.RecordType + func NewLayoutPositionalRow(typ *values.RecordType, layout values.OrdinalLayout) (*PositionalRow, error) + func NewPositionalRow(typ *values.RecordType) *PositionalRow + func (r *PositionalRow) AttachOrdinalLayout(layout values.OrdinalLayout, carrierType values.Type) (*PositionalRow, error) + func (r *PositionalRow) Get(ordinal int) (any, bool) + func (r *PositionalRow) MultiLeg() bool + func (r *PositionalRow) OrdinalLayout() values.OrdinalLayout + func (r *PositionalRow) OrdinalRecordType() *values.RecordType + func (r *PositionalRow) OrdinalRowKind() values.OrdinalCarrierKind + func (r *PositionalRow) Set(ordinal int, v any) bool + func (r *PositionalRow) TypeNames() []string + type QueryResult struct + Positional *PositionalRow + PrimaryKey tuple.Tuple + Record *recordlayer.FDBStoredRecord[proto.Message] + func CollectAll(ctx context.Context, cursor recordlayer.RecordCursor[QueryResult]) ([]QueryResult, error) + func CollectAllBounded(ctx context.Context, cursor recordlayer.RecordCursor[QueryResult], ...) ([]QueryResult, int64, error) + func FromStoredRecord(rec *recordlayer.FDBStoredRecord[proto.Message]) QueryResult + type RecordLayerResultSet struct + func NewRecordLayerResultSet(ctx context.Context, cursor recordlayer.RecordCursor[QueryResult], ...) *RecordLayerResultSet + func (rs *RecordLayerResultSet) Boolean(columnIndex int) (bool, error) + func (rs *RecordLayerResultSet) BooleanByName(name string) (bool, error) + func (rs *RecordLayerResultSet) Bytes(columnIndex int) ([]byte, error) + func (rs *RecordLayerResultSet) BytesByName(name string) ([]byte, error) + func (rs *RecordLayerResultSet) Close() error + func (rs *RecordLayerResultSet) Continuation() (api.Continuation, error) + func (rs *RecordLayerResultSet) Double(columnIndex int) (float64, error) + func (rs *RecordLayerResultSet) Err() error + func (rs *RecordLayerResultSet) Float(columnIndex int) (float32, error) + func (rs *RecordLayerResultSet) GetContinuation() recordlayer.RecordCursorContinuation + func (rs *RecordLayerResultSet) GetNoNextReason() recordlayer.NoNextReason + func (rs *RecordLayerResultSet) Long(columnIndex int) (int64, error) + func (rs *RecordLayerResultSet) LongByName(name string) (int64, error) + func (rs *RecordLayerResultSet) MetaData() api.ResultSetMetaData + func (rs *RecordLayerResultSet) Next() bool + func (rs *RecordLayerResultSet) Object(columnIndex int) (any, error) + func (rs *RecordLayerResultSet) ObjectByName(name string) (any, error) + func (rs *RecordLayerResultSet) String(columnIndex int) (string, error) + func (rs *RecordLayerResultSet) StringByName(name string) (string, error) + func (rs *RecordLayerResultSet) WasNull() bool + type RecursiveCTEDepthExceededError struct + MaxDepth int + func (e *RecursiveCTEDepthExceededError) Error() string + type ScanIdentityTypeErrorKind uint8 + const ScanIdentityTypeErrorCycle + const ScanIdentityTypeErrorTypedNil + type SortBufferExceededError struct + Limit int + Rows int + func (e *SortBufferExceededError) Error() string + type SumOverflowError struct + Int32 bool + func (e *SumOverflowError) Error() string + type TempTable struct + func NewTempTable() *TempTable + func NewTempTableWithState(st *recordlayer.ExecuteState) *TempTable + func (tt *TempTable) Add(qr QueryResult) error + func (tt *TempTable) Clear() + func (tt *TempTable) GetList() []QueryResult + func (tt *TempTable) ReleaseCharges() + func (tt *TempTable) ReplaceList(rows []QueryResult) + func (tt *TempTable) Snapshot() []QueryResult + type UnknownPhysicalKeyTypeError struct + Comparison predicates.ComparisonType + Component int + func (e *UnknownPhysicalKeyTypeError) Error() string + type UnsupportedContinuationError struct + Shape string + func (e *UnsupportedContinuationError) Error() string + type UnsupportedPhysicalFloatEquivalenceError struct + Comparison predicates.ComparisonType + Component int + PhysicalType values.Type + func (e *UnsupportedPhysicalFloatEquivalenceError) Error() string + type UnsupportedPhysicalKeyTypeError struct + Comparison predicates.ComparisonType + Component int + PhysicalType values.Type + func (e *UnsupportedPhysicalKeyTypeError) Error() string + type UnsupportedPhysicalNumericProjectionError struct + Comparison predicates.ComparisonType + Component int + EquivalenceClassHigh int64 + EquivalenceClassLow int64 + PhysicalType values.Type + func (e *UnsupportedPhysicalNumericProjectionError) Error() string + type UnsupportedPhysicalStartsWithError struct + Component int + PhysicalType values.Type + func (e *UnsupportedPhysicalStartsWithError) Error() string
Go to main page