internal

package

Versions in this module

v0

v0.0.29

Mar 8, 2026

Changes in this version

+ func NewFileSchemaRegistryContext(ctx context.Context, pool *pgxpool.Pool, schemaTable string, schemaDir string) (forma.SchemaRegistry, error)

type DuckDBClient

+ func NewDuckDBClientContext(ctx context.Context, cfg forma.DuckDBConfig) (*DuckDBClient, error)

v0.0.28

Mar 7, 2026

v0.0.27

Mar 7, 2026

Changes in this version

+ func EmitCompactionManifestContractViolation(ctx context.Context, schemaID int16)

v0.0.26

Feb 28, 2026

v0.0.25

Feb 26, 2026

Changes in this version

+ type MergeStrategy string

+ const MergeStrategyLastWriteWins

v0.0.24

Feb 17, 2026

Changes in this version

+ func SanitizeIdentifier(name string) string

+ 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 DBPersistentRecordRepository

+ func (r *DBPersistentRecordRepository) BatchDeletePersistentRecords(ctx context.Context, tables StorageTables, keys []PersistentRecordKey) error

+ func (r *DBPersistentRecordRepository) BatchInsertPersistentRecords(ctx context.Context, tables StorageTables, records []*PersistentRecord) error

+ func (r *DBPersistentRecordRepository) BatchUpdatePersistentRecords(ctx context.Context, tables StorageTables, records []*PersistentRecord) error

+ type PersistentRecordFederatedQuerier interface

+ QueryPersistentRecordsFederated func(ctx context.Context, tables StorageTables, fq *FederatedAttributeQuery, ...) (*PersistentRecordPage, error)

+ type PersistentRecordKey struct

+ RowID uuid.UUID

+ SchemaID int16

+ 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)

+ 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 SQLGenerator

+ func (g *SQLGenerator) ToSQLClauses(condition forma.Condition, eavTable string, schemaID int16, ...) (string, []any, error)

v0.0.23

Feb 15, 2026

Changes in this version

+ var AdvancedQueryTemplateDuckDB = template.Must(...(...))

+ var ErrListInOrderBy = fmt.Errorf("LIST type attributes cannot be used in ORDER BY")

+ func AppendDirtyExclusion(baseClause string, dirtyIDs []uuid.UUID) (string, []any)

+ func BuildDuckDBQuery(tpl *template.Template, params any, q *FederatedAttributeQuery, ...) (string, []any, error)

+ func BuildListPredicate(column, operator, value string, elementType forma.ValueType) (string, any, error)

+ func CastExpression(columnOrExpr string, v forma.ValueType) string

+ func EmitLatency(ctx context.Context, stage string, ms int64)

+ func EmitPushdownEfficiency(ctx context.Context, schemaID int16, ratio float64)

+ func EmitRowCount(ctx context.Context, source string, rows int64)

+ func GenerateDuckDBWhereClause(q *FederatedAttributeQuery) (string, []any, error)

+ func GenerateDuckDBWhereClauseWithExclusions(q *FederatedAttributeQuery, dirtyIDs []uuid.UUID) (string, []any, error)

+ func IsListType(v forma.ValueType) bool

+ func MapValueTypeToDuckDBType(v forma.ValueType) string

+ func MapValueTypeToListDuckDBType(elementType forma.ValueType) string

+ func MergeTemplateParamsWithDirtyIDs(params any, dirtyIDs []uuid.UUID) any

+ func PostgresHealthCheck(ctx context.Context, dsn string, timeout time.Duration) error

+ func RegisterTelemetryEmitter(fn telemetryEmitter)

+ func RenderDirtyIDsValuesCSV(dirtyIDs []uuid.UUID) string

+ func RenderDuckDBQuery(tpl *template.Template, params any, whereArgs []any) (string, []any, error)

+ func RenderS3ParquetPath(tmpl string, schemaID int16) (string, error)

+ func RenderSQLTemplate(tpl *template.Template, data any) (string, []any, error)

+ func S3HealthCheck(ctx context.Context, cfg forma.DuckDBConfig, timeout time.Duration) error

+ func SetGlobalDuckDBCircuitBreaker(cb *CircuitBreaker)

+ func ToDuckDBParam(value any, v forma.ValueType) (any, error)

+ func ValidateDuckDBConfig(cfg forma.DuckDBConfig) error

+ func ValidateOrderByAttributesForListTypes(orderBy []AttributeOrder) error

+ func ValidateOrderByForListTypes(orderBy []forma.OrderBy, ...) error

+ func ValidatePostgresConfig(cfg forma.DatabaseConfig) error

+ func ValidateS3Config(cfg forma.DuckDBConfig) error

+ type CircuitBreaker struct

+ func GetDuckDBCircuitBreaker() *CircuitBreaker

+ func NewCircuitBreaker(threshold int, window, openDuration time.Duration) *CircuitBreaker

+ func (cb *CircuitBreaker) IsOpen() bool

+ func (cb *CircuitBreaker) RecordFailure()

+ func (cb *CircuitBreaker) RecordSuccess()

+ type DBPersistentRecordRepository struct

+ func NewDBPersistentRecordRepository(pool persistentRecordPool, metadataCache *MetadataCache, ...) *DBPersistentRecordRepository

+ func (r *DBPersistentRecordRepository) DeletePersistentRecord(ctx context.Context, tables StorageTables, schemaID int16, rowID uuid.UUID) error

+ func (r *DBPersistentRecordRepository) ExecuteDuckDBFederatedQuery(ctx context.Context, tables StorageTables, q *FederatedAttributeQuery, ...) ([]*PersistentRecord, int64, error)

+ func (r *DBPersistentRecordRepository) ExecuteFederatedPaginatedQuery(ctx context.Context, tables StorageTables, fq *FederatedAttributeQuery, ...) ([]*PersistentRecord, int64, error)

+ func (r *DBPersistentRecordRepository) FetchDirtyRowIDs(ctx context.Context, changeLogTable string, schemaID int16) ([]uuid.UUID, error)

+ func (r *DBPersistentRecordRepository) GetPersistentRecord(ctx context.Context, tables StorageTables, schemaID int16, rowID uuid.UUID) (*PersistentRecord, error)

+ func (r *DBPersistentRecordRepository) InsertPersistentRecord(ctx context.Context, tables StorageTables, record *PersistentRecord) error

+ func (r *DBPersistentRecordRepository) QueryPersistentRecords(ctx context.Context, query *PersistentRecordQuery) (*PersistentRecordPage, error)

+ func (r *DBPersistentRecordRepository) QueryPersistentRecordsFederated(ctx context.Context, tables StorageTables, fq *FederatedAttributeQuery, ...) (*PersistentRecordPage, error)

+ func (r *DBPersistentRecordRepository) StreamDuckDBFederatedQuery(ctx context.Context, tables StorageTables, q *FederatedAttributeQuery, ...) (int64, error)

+ func (r *DBPersistentRecordRepository) StreamOptimizedQuery(ctx context.Context, tables StorageTables, schemaID int16, clause string, ...) (int64, error)

+ func (r *DBPersistentRecordRepository) UpdatePersistentRecord(ctx context.Context, tables StorageTables, record *PersistentRecord) error

+ type DataSourcePlan struct

+ ActualRows int64

+ DurationMs int64

+ Engine string

+ PredicatePushdown bool

+ Reason string

+ RowEstimate int64

+ SQL string

+ Tier DataTier

+ type DataTier string

+ const DataTierCold

+ const DataTierHot

+ const DataTierWarm

+ type DualClauses struct

+ DuckArgs []any

+ DuckClause string

+ PgArgs []any

+ PgClause string

+ PgMainArgs []any

+ PgMainClause string

+ func ToDualClauses(condition forma.Condition, eavTable string, schemaID int16, ...) (DualClauses, error)

+ type DuckDBClient struct

+ DB *sql.DB

+ func NewDuckDBClient(cfg forma.DuckDBConfig) (*DuckDBClient, error)

+ func (c *DuckDBClient) Close() error

+ func (c *DuckDBClient) HealthCheck(ctx context.Context) error

+ type DuckDBRenderHints struct

+ S3ParquetPathTemplate string

+ TimeEncodingHint string

+ type ExecutionPlan struct

+ Merge MergePlan

+ Notes []string

+ Routing RoutingDecision

+ Sources []DataSourcePlan

+ Timings map[string]int64

+ type FederatedAttributeQuery struct

+ DuckDBHints *DuckDBRenderHints

+ PreferHot bool

+ PreferredTiers []DataTier

+ UseMainAsAnchor bool

+ type FederatedQueryOptions struct

+ AllowPartialDegradedMode bool

+ ExecutionPlan *ExecutionPlan

+ IncludeExecutionPlan bool

+ MaxRows int

+ Parallelism int

+ type ListOperatorMapping struct

+ DuckDBExpr string

+ Operator string

+ RequiresLambda bool

+ type MergePlan struct

+ DedupKeys []string

+ DurationMs int64

+ Notes []string

+ PreferHot bool

+ Strategy string

type PersistentRecord

+ func MergePersistentRecordsByTier(inputs map[DataTier][]*PersistentRecord, preferHot bool) ([]*PersistentRecord, error)

type PersistentRecordRepository

+ QueryPersistentRecordsFederated func(ctx context.Context, tables StorageTables, fq *FederatedAttributeQuery, ...) (*PersistentRecordPage, error)

+ type RoutingDecision struct

+ AllowS3Fallback bool

+ MaxScanRows int

+ QueryTimeout time.Duration

+ Reason string

+ Tiers []DataTier

+ UseDuckDB bool

+ func EvaluateRoutingPolicy(cfg forma.DuckDBConfig, fq *FederatedAttributeQuery, ...) RoutingDecision

+ type SQLRenderer struct

+ func NewSQLRenderer() *SQLRenderer

+ func (r *SQLRenderer) Ident(name string) string

+ func (r *SQLRenderer) Param(v any) string

+ func (r *SQLRenderer) Render(tpl *template.Template, data any) (string, []any, error)

type StorageTables

+ SchemaRegistry string

v0.0.22

Jan 2, 2026

v0.0.21

Jan 1, 2026

Changes in this version

type StorageTables

+ ChangeLog string

v0.0.20

Dec 21, 2025

v0.0.19

Dec 20, 2025

Changes in this version

+ func ToFloat64(v any) (float64, bool)

+ type DBPool interface

+ Query func(ctx context.Context, sql string, args ...any) (pgx.Rows, error)

v0.0.18

Dec 18, 2025

Changes in this version

+ func FilterAttributes(attributes map[string]any, attrs []string) map[string]any

+ func FilterDataRecord(record *forma.DataRecord, attrs []string) *forma.DataRecord

+ type RelationDescriptor struct

+ ChildPath string

+ ChildSchema string

+ ForeignKeyAttr string

+ ForeignKeyRequired bool

+ ParentIDAttr string

+ ParentPath string

+ ParentSchema string

+ type RelationIndex struct

+ func LoadRelationIndex(schemaDir string) (*RelationIndex, error)

+ func (idx *RelationIndex) Relations(schema string) []RelationDescriptor

+ func (idx *RelationIndex) StripComputedFields(schema string, data map[string]any) map[string]any

v0.0.17

Dec 15, 2025

v0.0.16

Dec 14, 2025

v0.0.15

Dec 14, 2025

Changes in this version

+ func NewFileSchemaRegistryFromDirectory(schemaDir string) (forma.SchemaRegistry, error)

v0.0.14

Dec 7, 2025

v0.0.13

Dec 7, 2025

v0.0.12

Dec 7, 2025

v0.0.11

Dec 7, 2025

v0.0.10

Dec 7, 2025

Changes in this version

type MetadataCache

+ func (mc *MetadataCache) GetSchemaCacheByID(schemaID int16) (forma.SchemaAttributeCache, bool)

v0.0.9

Dec 7, 2025

v0.0.8

Dec 6, 2025

v0.0.7

Dec 5, 2025

Changes in this version

type PersistentRecord

+ UUIDItems map[string]uuid.UUID

v0.0.6

Dec 5, 2025

v0.0.5

Dec 4, 2025

v0.0.4

Dec 2, 2025

v0.0.3

Nov 29, 2025

v0.0.2

Nov 28, 2025

Changes in this version

type EntityAttribute

+ RowID uuid.UUID

v0.0.1

Nov 27, 2025

Changes in this version

+ func DecodeBase32ToUUID(s string) (uuid.UUID, error)

+ func DecodeFromBase32(s string) ([]byte, error)

+ func EncodeToBase32(data []byte) string

+ func EncodeUUIDToBase32(id uuid.UUID) string

+ func MapKeys[K comparable, V any](m map[K]V) []K

+ func MapValues[K comparable, V any](m map[K]V) []V

+ func NewEntityManager(transformer PersistentRecordTransformer, repository PersistentRecordRepository, ...) forma.EntityManager

+ type AttributeConverter struct

+ func NewAttributeConverter(registry SchemaRegistry) *AttributeConverter

+ func (c *AttributeConverter) FromEAVRecord(record EAVRecord, valueType ValueType) (EntityAttribute, error)

+ func (c *AttributeConverter) FromEAVRecords(records []EAVRecord) ([]EntityAttribute, error)

+ func (c *AttributeConverter) ToEAVRecord(attr EntityAttribute, rowID uuid.UUID) (EAVRecord, error)

+ func (c *AttributeConverter) ToEAVRecords(attributes []EntityAttribute, rowID uuid.UUID) ([]EAVRecord, error)

+ type AttributeFallbackKind string

+ const AttributeFallbackKindBoolToDouble

+ const AttributeFallbackKindBoolToText

+ const AttributeFallbackKindDateToDouble

+ const AttributeFallbackKindDateToText

+ const AttributeFallbackKindNone

+ const AttributeFallbackKindNumericToDouble

+ type AttributeFallbackMetadata struct

+ ColumnType MainColumnType

+ Enabled bool

+ Encoding MainColumnEncoding

+ Kind AttributeFallbackKind

+ Notes string

+ type AttributeMetadata struct

+ AttributeID int16

+ AttributeName string

+ Storage *AttributeStorageMetadata

+ ValueType ValueType

+ func (m AttributeMetadata) IsInsideArray() bool

+ type AttributeOrder struct

+ AttrID int16

+ ColumnName string

+ SortOrder forma.SortOrder

+ StorageLocation AttributeStorageLocation

+ ValueType 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 AttributeStorageLocation string

+ const AttributeStorageLocationEAV

+ const AttributeStorageLocationMain

+ const AttributeStorageLocationUnknown

+ type AttributeStorageMetadata struct

+ ColumnBinding *MainColumnBinding

+ Fallback AttributeFallbackMetadata

+ Location AttributeStorageLocation

+ type BatchConfig struct

+ AttributeComplexityScore int

+ EnableBatchStreaming bool

+ EnableDynamicSizing bool

+ EnableParallelProcessing bool

+ MaxComplexityPerBatch int

+ MaxParallelWorkers int

+ OptimalChunkSize int

+ ParallelThreshold int

+ StreamingChunkSize int

+ StreamingDelay int

+ StreamingThreshold int

+ type CascadeAction string

+ const CascadeActionDelete

+ const CascadeActionNullify

+ const CascadeActionRestrict

+ const CascadeActionUpdate

+ type CascadeRule struct

+ Action CascadeAction

+ MaxDepth int

+ SourceSchema string

+ TargetSchema string

+ type Config struct

+ Database DatabaseConfig

+ Entity EntityConfig

+ Logging LoggingConfig

+ Metrics MetricsConfig

+ Performance PerformanceConfig

+ Query QueryConfig

+ Reference ReferenceConfig

+ Transaction TransactionConfig

+ func DefaultConfig() *Config

+ func (c *Config) Validate() error

+ type ConfigError struct

+ Field string

+ Message string

+ func (e *ConfigError) Error() string

+ type DatabaseConfig struct

+ ConnMaxIdleTime time.Duration

+ ConnMaxLifetime time.Duration

+ Database string

+ Host string

+ MaxConnections int

+ MaxIdleConns int

+ Password string

+ Port int

+ SSLMode string

+ TableNames TableNames

+ Timeout time.Duration

+ Username string

+ type EAVRecord struct

+ ArrayIndices string

+ AttrID int16

+ RowID uuid.UUID

+ SchemaID int16

+ ValueNumeric *float64

+ ValueText *string

+ type EntityAttribute struct

+ ArrayIndices string

+ AttrID int16

+ SchemaID int16

+ Value any

+ ValueType 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 EntityConfig struct

+ BatchSize int

+ CacheEnabled bool

+ CacheTTL time.Duration

+ EnableCascadeDelete bool

+ EnableReferenceValidation bool

+ EnableVersioning bool

+ MaxEntitySize int

+ SchemaDirectory string

+ type JSONSchema struct

+ CreatedAt int64

+ ID int16

+ Name string

+ Properties map[string]*PropertySchema

+ Required []string

+ Schema string

+ Version int

+ type LoggingConfig struct

+ EnableDetailedLogging bool

+ EnablePerformance bool

+ EnableQueryLogging bool

+ EnableStructured bool

+ Format string

+ Level string

+ LogAllOperations bool

+ LogErrors bool

+ LogPerformanceWarnings bool

+ LogQueries bool

+ LogRotation bool

+ LogSecurityEvents bool

+ LogSlowQueries bool

+ MaxLogSize int

+ SanitizeParameters bool

+ SlowQueryThreshold time.Duration

+ type MainColumn string

+ const MainColumnBigint01

+ const MainColumnBigint02

+ const MainColumnBigint03

+ const MainColumnBigint04

+ const MainColumnBigint05

+ const MainColumnDouble01

+ const MainColumnDouble02

+ const MainColumnDouble03

+ const MainColumnDouble04

+ const MainColumnDouble05

+ const MainColumnInteger01

+ const MainColumnInteger02

+ const MainColumnInteger03

+ const MainColumnSmallint01

+ const MainColumnSmallint02

+ const MainColumnText01

+ const MainColumnText02

+ const MainColumnText03

+ const MainColumnText04

+ const MainColumnText05

+ const MainColumnText06

+ const MainColumnText07

+ const MainColumnText08

+ const MainColumnText09

+ const MainColumnText10

+ const MainColumnUUID01

+ const MainColumnUUID02

+ type MainColumnBinding struct

+ ColumnName MainColumn

+ Encoding MainColumnEncoding

+ func (m *MainColumnBinding) ColumnType() MainColumnType

+ type MainColumnEncoding string

+ const MainColumnEncodingBoolInt

+ const MainColumnEncodingBoolText

+ const MainColumnEncodingDefault

+ const MainColumnEncodingISO8601

+ const MainColumnEncodingUnixMs

+ type MainColumnType string

+ const MainColumnTypeBigint

+ const MainColumnTypeDouble

+ const MainColumnTypeInteger

+ const MainColumnTypeSmallint

+ const MainColumnTypeText

+ const MainColumnTypeUUID

+ type MetadataCache struct

+ func NewMetadataCache() *MetadataCache

+ func (mc *MetadataCache) GetSchemaCache(schemaName string) (SchemaAttributeCache, bool)

+ func (mc *MetadataCache) GetSchemaID(schemaName string) (int16, bool)

+ func (mc *MetadataCache) GetSchemaName(schemaID int16) (string, bool)

+ func (mc *MetadataCache) ListSchemas() []string

+ type MetadataLoader struct

+ func NewMetadataLoader(pool *pgxpool.Pool, schemaTableName, schemaDirectory string) *MetadataLoader

+ func (ml *MetadataLoader) LoadMetadata(ctx context.Context) (*MetadataCache, error)

+ type MetricsConfig struct

+ CollectionInterval time.Duration

+ EnableCounters bool

+ EnableGauges bool

+ EnableHistograms bool

+ EnableOperationMetrics bool

+ EnablePatternMetrics bool

+ EnableTransactionMetrics bool

+ Enabled bool

+ Endpoint string

+ Labels map[string]string

+ MaxSamples int

+ Namespace string

+ Provider string

+ type PerformanceConfig struct

+ AlertingInterval time.Duration

+ Batch BatchConfig

+ BatchSize int

+ CorrelationTTL time.Duration

+ EnableAlerting bool

+ EnableCorrelationTracking bool

+ EnableMemoryMonitoring bool

+ EnableMonitoring bool

+ EnableRecommendations bool

+ MaxAlertsHistory int

+ MaxBatchSize int

+ MaxMetricsHistory int

+ MaxRecommendations int

+ MemoryThreshold int64

+ MetricsCollectionInterval time.Duration

+ RecommendationInterval time.Duration

+ SlowOperationThreshold time.Duration

+ SlowQueryThreshold time.Duration

+ 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

+ UpdatedAt int64

+ type PersistentRecordPage struct

+ CurrentPage int

+ Records []*PersistentRecord

+ TotalPages int

+ TotalRecords int64

+ type PersistentRecordQuery struct

+ AttributeOrders []AttributeOrder

+ Condition forma.Condition

+ Limit int

+ Offset int

+ SchemaID int16

+ Tables StorageTables

+ type PersistentRecordRepository interface

+ DeletePersistentRecord func(ctx context.Context, tables StorageTables, schemaID int16, rowID uuid.UUID) error

+ GetPersistentRecord func(ctx context.Context, tables StorageTables, schemaID int16, rowID uuid.UUID) (*PersistentRecord, error)

+ InsertPersistentRecord func(ctx context.Context, tables StorageTables, record *PersistentRecord) error

+ QueryPersistentRecords func(ctx context.Context, query *PersistentRecordQuery) (*PersistentRecordPage, error)

+ UpdatePersistentRecord func(ctx context.Context, tables StorageTables, record *PersistentRecord) error

+ 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)

+ func NewPersistentRecordTransformer(registry SchemaRegistry) PersistentRecordTransformer

+ type PostgresPersistentRecordRepository struct

+ func NewPostgresPersistentRecordRepository(pool *pgxpool.Pool, metadataCache *MetadataCache) *PostgresPersistentRecordRepository

+ func (r *PostgresPersistentRecordRepository) DeletePersistentRecord(ctx context.Context, tables StorageTables, schemaID int16, rowID uuid.UUID) error

+ func (r *PostgresPersistentRecordRepository) GetPersistentRecord(ctx context.Context, tables StorageTables, schemaID int16, rowID uuid.UUID) (*PersistentRecord, error)

+ func (r *PostgresPersistentRecordRepository) InsertPersistentRecord(ctx context.Context, tables StorageTables, record *PersistentRecord) error

+ func (r *PostgresPersistentRecordRepository) QueryPersistentRecords(ctx context.Context, query *PersistentRecordQuery) (*PersistentRecordPage, error)

+ func (r *PostgresPersistentRecordRepository) UpdatePersistentRecord(ctx context.Context, tables StorageTables, record *PersistentRecord) error

+ type PropertySchema struct

+ Default any

+ Enum []any

+ Format string

+ Items *PropertySchema

+ MaxLength *int

+ Maximum *float64

+ MinLength *int

+ Minimum *float64

+ Name string

+ Pattern string

+ Properties map[string]*PropertySchema

+ Relation *RelationSchema

+ Required bool

+ Storage string

+ Type string

+ type QueryConfig struct

+ CacheQueryPlans bool

+ DefaultPageSize int

+ DefaultTimeout time.Duration

+ EnableOptimization bool

+ EnableQueryPlan bool

+ MaxPageSize int

+ MaxRows int

+ QueryPlanCacheTTL time.Duration

+ type ReferenceConfig struct

+ BatchSize int

+ CacheTTL time.Duration

+ CascadeDelete bool

+ CascadeRules map[string]CascadeRule

+ CascadeUpdate bool

+ CheckIntegrity bool

+ EnableCaching bool

+ MaxCacheSize int

+ MaxCascadeDepth int

+ ValidateOnCreate bool

+ ValidateOnUpdate bool

+ type RelationSchema struct

+ Target string

+ Type string

+ type SQLGenerator struct

+ func NewSQLGenerator() *SQLGenerator

+ func (g *SQLGenerator) ToSqlClauses(condition forma.Condition, eavTable string, schemaID int16, ...) (string, []any, error)

+ type SchemaAttributeCache map[string]AttributeMetadata

+ type SchemaMetadata struct

+ Attributes []AttributeMetadata

+ SchemaID int16

+ SchemaName string

+ SchemaVersion int

+ type SchemaRegistry interface

+ GetSchemaByID func(id int16) (string, SchemaAttributeCache, error)

+ GetSchemaByName func(name string) (int16, SchemaAttributeCache, error)

+ ListSchemas func() []string

+ func NewFileSchemaRegistry(schemaDir string) (SchemaRegistry, error)

+ type Set struct

+ func NewSet[T comparable]() *Set[T]

+ func (s *Set[T]) Add(item T)

+ func (s *Set[T]) Clear()

+ func (s *Set[T]) Contains(item T) bool

+ func (s *Set[T]) Remove(item T)

+ func (s *Set[T]) Size() int

+ func (s *Set[T]) ToSlice() []T

+ type StorageTables struct

+ EAVData string

+ EntityMain string

+ type TableNames struct

+ EAVData string

+ EntityMain string

+ SchemaRegistry string

+ type TransactionConfig struct

+ DeadlockCheckInterval time.Duration

+ DeadlockMaxWaitTime time.Duration

+ DefaultTimeout time.Duration

+ EnableDeadlockDetection bool

+ IsolationLevel string

+ MaxAverageDuration time.Duration

+ MaxConnectionPoolUsage float64

+ MaxRetryAttempts int

+ MaxTimeout time.Duration

+ MinSuccessRate float64

+ RetryAttempts int

+ RetryDelay time.Duration

+ SlowTransactionThreshold time.Duration

+ type Transformer interface

+ BatchFromAttributes func(ctx context.Context, attributes []EntityAttribute) ([]map[string]any, error)

+ BatchToAttributes func(ctx context.Context, schemaID int16, jsonObjects []any) ([]EntityAttribute, error)

+ FromAttributes func(ctx context.Context, attributes []EntityAttribute) (map[string]any, error)

+ ToAttributes func(ctx context.Context, schemaID int16, rowID uuid.UUID, jsonData any) ([]EntityAttribute, error)

+ ValidateAgainstSchema func(ctx context.Context, jsonSchema any, jsonData any) error

+ func NewTransformer(registry SchemaRegistry) Transformer

+ type ValueType string

+ const ValueTypeBigInt

+ const ValueTypeBool

+ const ValueTypeDate

+ const ValueTypeDateTime

+ const ValueTypeInteger

+ const ValueTypeNumeric

+ const ValueTypeSmallInt

+ const ValueTypeText

+ const ValueTypeUUID

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