Versions in this module Expand all Collapse all v0 v0.2.0 Aug 25, 2026 Changes in this version + const DefaultPageSize + const FederatedMaxRows + var AllowedBigintColumns = makeColumnSet(BigintColumns) + var AllowedDoubleColumns = makeColumnSet(DoubleColumns) + var AllowedIntegerColumns = makeColumnSet(IntegerColumns) + var AllowedSmallintColumns = makeColumnSet(SmallintColumns) + var AllowedTextColumns = makeColumnSet(TextColumns) + var AllowedUUIDColumns = makeColumnSet(UUIDColumns) + var BigintColumns = []string + var DoubleColumns = []string + var EntityMainColumnDescriptors = buildEntityMainColumnDescriptors() + var EntityMainProjection = func() string { ... }() + var IntegerColumns = []string + var SmallintColumns = []string + var SystemColumnDescriptors = []ColumnDescriptor + var TextColumns = []string + var UUIDColumns = []string + func CleanupEmptyMaps(record *PersistentRecord) + func ColumnKindToValueType(kind ColumnKind) forma.ValueType + func ComputeTotalPages(total int64, limit int) int + func IsMainTableColumn(name string) bool + func ParseAttributesJSON(attrsJSON []byte, record *PersistentRecord) error + type AtomicBatchPersistentRecordRepository interface + BatchDeletePersistentRecords func(ctx context.Context, tables StorageTables, keys []PersistentRecordKey) error + BatchInsertPersistentRecords func(ctx context.Context, tables StorageTables, records []*PersistentRecord) error + BatchUpdatePersistentRecords func(ctx context.Context, tables StorageTables, records []*PersistentRecord) error + type AttributeOrder struct + AttrID int16 + AttrName string + ColumnName string + SortOrder forma.SortOrder + StorageLocation forma.AttributeStorageLocation + ValueType forma.ValueType + func (ao *AttributeOrder) AttrIDInt() int + func (ao *AttributeOrder) Desc() bool + func (ao *AttributeOrder) IsMainColumn() bool + func (ao *AttributeOrder) MainColumnName() string + func (ao *AttributeOrder) ValueColumn() string + type AttributeQuery struct + AttributeOrders []AttributeOrder + Condition forma.Condition + Limit int + Offset int + OrderBy []forma.OrderBy + SchemaID int16 + type ColumnDescriptor struct + Kind ColumnKind + Name string + func GetMainColumnDescriptor(name string) *ColumnDescriptor + type ColumnKind int + const ColumnKindBigint + const ColumnKindDouble + const ColumnKindInteger + const ColumnKindSmallint + const ColumnKindText + const ColumnKindUUID + type ConsistencyMode string + const ConsistencyModeEventual + const ConsistencyModeStrict + type DataSourcePlan struct + ActualRows int64 + DurationMs int64 + Engine string + Params []string + PredicatePushdown bool + Reason string + RowEstimate int64 + SQL string + Tier DataTier + type DataTier string + const DataTierCold + const DataTierHot + const DataTierWarm + type DuckDBRenderHints struct + S3ParquetPathTemplate string + TimeEncodingHint string + type EAVRecord struct + ArrayIndices string + AttrID int16 + RowID uuid.UUID + SchemaID int16 + ValueInt64 *int64 + ValueNumeric *float64 + ValueText *string + func ParseEAVAttribute(attrObj map[string]any) (EAVRecord, error) + type EntityAttribute struct + ArrayIndices string + AttrID int16 + RowID uuid.UUID + SchemaID int16 + Value any + ValueType forma.ValueType + func (ea *EntityAttribute) BigInt() (*int64, error) + func (ea *EntityAttribute) Bool() (*bool, error) + func (ea *EntityAttribute) Date() (*time.Time, error) + func (ea *EntityAttribute) DateTime() (*time.Time, error) + func (ea *EntityAttribute) Integer() (*int32, error) + func (ea *EntityAttribute) Numeric() (*float64, error) + func (ea *EntityAttribute) SmallInt() (*int16, error) + func (ea *EntityAttribute) Text() (*string, error) + func (ea *EntityAttribute) UUID() (*uuid.UUID, error) + type ExecutionPlan struct + Merge MergePlan + Notes []string + Routing RoutingDecision + Sources []DataSourcePlan + Timings map[string]int64 + type FederatedAttributeQuery struct + DuckDBHints *DuckDBRenderHints + KeysetCursor *KeysetCursor + PreferHot bool + PreferredTiers []DataTier + UseMainAsAnchor bool + type FederatedQueryEngine interface + Query func(ctx context.Context, tables StorageTables, fq *FederatedAttributeQuery, ...) (*PersistentRecordPage, error) + type FederatedQueryOptions struct + AllowPartialDegradedMode bool + ConsistencyMode ConsistencyMode + ExecutionPlan *ExecutionPlan + IncludeExecutionPlan bool + KeysetEnabled bool + MaxRows int + Parallelism int + PartialScan *PartialScan + type KeysetColumn struct + Attribute string + Direction forma.SortOrder + type KeysetCursor struct + Columns []KeysetColumn + Mode KeysetCursorMode + Values []interface{} + type KeysetCursorMode string + const KeysetCursorModeAfter + const KeysetCursorModeBefore + type MergePlan struct + DedupKeys []string + DurationMs int64 + Notes []string + PreferHot bool + Strategy MergeStrategy + type MergeStrategy string + const MergeStrategyLastWriteWins + type PartialScan struct + ExcludedObjects []string + type PersistentRecord struct + CreatedAt int64 + DeletedAt *int64 + Float64Items map[string]float64 + Int16Items map[string]int16 + Int32Items map[string]int32 + Int64Items map[string]int64 + OtherAttributes []EAVRecord + RowID uuid.UUID + SchemaID int16 + TextItems map[string]string + UUIDItems map[string]uuid.UUID + UpdatedAt int64 + type PersistentRecordKey struct + RowID uuid.UUID + SchemaID int16 + type PersistentRecordPage struct + CurrentPage int + ExecutionPlan *ExecutionPlan + Partial *PartialScan + Records []*PersistentRecord + TotalPages int + TotalRecords int64 + type PersistentRecordQuery struct + AttributeOrders []AttributeOrder + Condition forma.Condition + Limit int + Offset int + SchemaID int16 + Tables StorageTables + type PersistentRecordReader interface + GetPersistentRecord func(ctx context.Context, tables StorageTables, schemaID int16, rowID uuid.UUID) (*PersistentRecord, error) + QueryPersistentRecords func(ctx context.Context, query *PersistentRecordQuery) (*PersistentRecordPage, error) + QueryPersistentRecordsByAttrValues func(ctx context.Context, tables StorageTables, schemaID int16, attr string, ...) (*PersistentRecordPage, error) + type PersistentRecordRepository interface + type PersistentRecordTransformer interface + FromPersistentRecord func(ctx context.Context, record *PersistentRecord) (map[string]any, error) + ToPersistentRecord func(ctx context.Context, schemaID int16, rowID uuid.UUID, jsonData any) (*PersistentRecord, error) + type PersistentRecordWriter interface + DeletePersistentRecord func(ctx context.Context, tables StorageTables, schemaID int16, rowID uuid.UUID) error + InsertPersistentRecord func(ctx context.Context, tables StorageTables, record *PersistentRecord) error + UpdatePersistentRecord func(ctx context.Context, tables StorageTables, record *PersistentRecord) error + type RoutingDecision struct + AllowS3Fallback bool + MaxScanRows int + QueryTimeout time.Duration + Reason string + Tiers []DataTier + UseDuckDB bool + type StorageTables struct + ChangeLog string + EAVData string + EntityMain string + SchemaRegistry string
Go to main page