forma

Feb 17, 2026

Changes in this version

+ type EntityBatchCreator interface

+ BatchCreate func(ctx context.Context, req *BatchOperation) (*BatchResult, error)

+ type EntityBatchOperator interface

+ BatchCreate func(ctx context.Context, req *BatchOperation) (*BatchResult, error)

+ BatchDelete func(ctx context.Context, req *BatchOperation) (*BatchResult, error)

+ BatchUpdate func(ctx context.Context, req *BatchOperation) (*BatchResult, error)

+ type EntityReader interface

+ CrossSchemaSearch func(ctx context.Context, req *CrossSchemaRequest) (*QueryResult, error)

+ Get func(ctx context.Context, req *QueryRequest) (*DataRecord, error)

+ Query func(ctx context.Context, req *QueryRequest) (*QueryResult, error)

+ type EntityWriter interface

+ Create func(ctx context.Context, req *EntityOperation) (*DataRecord, error)

+ Delete func(ctx context.Context, req *EntityOperation) error

+ Update func(ctx context.Context, req *EntityOperation) (*DataRecord, error)

Feb 15, 2026

Changes in this version

type Config

+ DuckDB DuckDBConfig

+ type DuckDBConfig struct

+ CircuitBreakerThreshold float64

+ DBPath string

+ EnableParquet bool

+ EnableS3 bool

+ Enabled bool

+ Extensions []string

+ MaxConnections int

+ MaxParallelism int

+ MemoryLimitMB int

+ QueryTimeout time.Duration

+ Routing RoutingPolicy

+ S3AccessKey string

+ S3Endpoint string

+ S3Region string

+ S3SecretKey string

+ type RoutingPolicy struct

+ AllowS3Fallback bool

+ HotTTL time.Duration

+ MaxDuckDBScanRows int

+ Strategy string

type ValueType

+ const ValueTypeList

Jan 1, 2026

Changes in this version

type AttributeMetadata

+ Required bool

type TableNames

+ ChangeLog string

Dec 21, 2025

Changes in this version

type PropertySchema

+ LTBaseNote string

+ LTBaseType string

Dec 18, 2025

Changes in this version

type CrossSchemaRequest

+ Attrs []string

type QueryRequest

+ Attrs []string

type RelationSchema

+ KeyProperty string

Dec 14, 2025

Changes in this version

+ type JSONSchema struct

+ CreatedAt int64

+ ID int16

+ Name string

+ Properties map[string]*PropertySchema

+ Required []string

+ Schema string

+ Version int

+ 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 RelationSchema struct

+ Target string

+ Type string

type SchemaRegistry

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

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

Dec 5, 2025

Changes in this version

type MainColumn

+ const MainColumnCreatedAt

+ const MainColumnDeletedAt

+ const MainColumnRowID

+ const MainColumnSchemaID

+ const MainColumnUpdatedAt

Nov 29, 2025

Changes in this version

+ type AttributeMetadata struct

+ AttributeID int16

+ AttributeName string

+ ColumnBinding *MainColumnBinding

+ ValueType ValueType

+ func (m AttributeMetadata) IsInsideArray() bool

+ func (m AttributeMetadata) Location() AttributeStorageLocation

+ type AttributeStorageLocation string

+ const AttributeStorageLocationEAV

+ const AttributeStorageLocationMain

+ const AttributeStorageLocationUnknown

type Config

+ SchemaRegistry SchemaRegistry

+ 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 SchemaAttributeCache map[string]AttributeMetadata

+ type SchemaRegistry interface

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

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

+ ListSchemas func() []string

+ type ValueType string

+ const ValueTypeBigInt

+ const ValueTypeBool

+ const ValueTypeDate

+ const ValueTypeDateTime

+ const ValueTypeInteger

+ const ValueTypeNumeric

+ const ValueTypeSmallInt

+ const ValueTypeText

+ const ValueTypeUUID

Nov 28, 2025

Changes in this version

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

+ BatchSize int

+ CacheEnabled bool

+ CacheTTL time.Duration

+ EnableCascadeDelete bool

+ EnableReferenceValidation bool

+ EnableVersioning bool

+ MaxEntitySize int

+ SchemaDirectory string

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

Nov 27, 2025

Changes in this version

+ type BatchOperation struct

+ Atomic bool

+ Operations []EntityOperation

+ type BatchResult struct

+ Duration int64

+ Failed []OperationError

+ Successful []*DataRecord

+ TotalCount int

+ type CompositeCondition struct

+ Conditions []Condition

+ Logic Logic

+ func (c *CompositeCondition) IsLeaf() bool

+ func (c *CompositeCondition) UnmarshalJSON(data []byte) error

+ type Condition interface

+ IsLeaf func() bool

+ type CrossSchemaRequest struct

+ Condition Condition

+ ItemsPerPage int

+ Page int

+ SchemaNames []string

+ SearchTerm string

+ func (r *CrossSchemaRequest) UnmarshalJSON(data []byte) error

+ func (r CrossSchemaRequest) MarshalJSON() ([]byte, error)

+ type CursorQueryResult struct

+ Data []*DataRecord

+ ExecutionTime time.Duration

+ HasMore bool

+ NextCursor string

+ type DataRecord struct

+ Attributes map[string]any

+ RowID uuid.UUID

+ SchemaName string

+ type EntityIdentifier struct

+ RowID uuid.UUID

+ SchemaName string

+ type EntityManager interface

+ BatchCreate func(ctx context.Context, req *BatchOperation) (*BatchResult, error)

+ BatchDelete func(ctx context.Context, req *BatchOperation) (*BatchResult, error)

+ BatchUpdate func(ctx context.Context, req *BatchOperation) (*BatchResult, error)

+ Create func(ctx context.Context, req *EntityOperation) (*DataRecord, error)

+ CrossSchemaSearch func(ctx context.Context, req *CrossSchemaRequest) (*QueryResult, error)

+ Delete func(ctx context.Context, req *EntityOperation) error

+ Get func(ctx context.Context, req *QueryRequest) (*DataRecord, error)

+ Query func(ctx context.Context, req *QueryRequest) (*QueryResult, error)

+ Update func(ctx context.Context, req *EntityOperation) (*DataRecord, error)

+ type EntityOperation struct

+ Data map[string]any

+ Type OperationType

+ Updates map[string]any

+ type EntityUpdate struct

+ Updates any

+ type FilterField string

+ const FilterFieldAttributeName

+ const FilterFieldRowID

+ const FilterFieldSchemaName

+ const FilterFieldValueNumeric

+ const FilterFieldValueText

+ type FilterType string

+ const FilterContains

+ const FilterEquals

+ const FilterGreaterEq

+ const FilterGreaterThan

+ const FilterIn

+ const FilterLessEq

+ const FilterLessThan

+ const FilterNotEquals

+ const FilterNotIn

+ const FilterStartsWith

+ type KvCondition struct

+ Attr string

+ Value string

+ func (kv *KvCondition) IsLeaf() bool

+ func (kv *KvCondition) UnmarshalJSON(data []byte) error

+ type Logic string

+ const LogicAnd

+ const LogicOr

+ type OperationError struct

+ Code string

+ Details map[string]any

+ Error string

+ Operation EntityOperation

+ type OperationType string

+ const OperationCreate

+ const OperationDelete

+ const OperationQuery

+ const OperationRead

+ const OperationUpdate

+ type OrderBy struct

+ Attribute string

+ SortOrder SortOrder

+ type QueryRequest struct

+ Condition Condition

+ ItemsPerPage int

+ Page int

+ RowID *uuid.UUID

+ SchemaName string

+ SortBy []string

+ SortOrder SortOrder

+ func (r *QueryRequest) UnmarshalJSON(data []byte) error

+ func (r QueryRequest) MarshalJSON() ([]byte, error)

+ type QueryResult struct

+ CurrentPage int

+ Data []*DataRecord

+ ExecutionTime time.Duration

+ HasNext bool

+ HasPrevious bool

+ ItemsPerPage int

+ TotalPages int

+ TotalRecords int

+ type Reference struct

+ ReferenceType ReferenceType

+ SourceFieldName string

+ SourceRowID uuid.UUID

+ SourceSchemaName string

+ TargetRowID uuid.UUID

+ TargetSchemaName string

+ type ReferenceType string

+ const ReferenceTypeArray

+ const ReferenceTypeNested

+ const ReferenceTypeSingle

+ type SortOrder string

+ const SortOrderAsc

+ const SortOrderDesc