postgres

Mar 9, 2025

Changes in this version

+ func BatchedQuery[T any](c Core, ctx context.Context, query string, args []any, batchSize int, ...) error

Mar 7, 2025

Changes in this version

type SnapshotManager

+ func (me *SnapshotManager) InitializeIfRequired(ctx context.Context)

Mar 3, 2025

Changes in this version

type EntityManager

+ func (me *EntityManager) EntityExists(ctx context.Context, entityId string) bool

Feb 25, 2025

Changes in this version

type Connector

+ func (me *Connector) Connected() signalslots.Signal

+ func (me *Connector) Disconnected() signalslots.Signal

Feb 24, 2025

Changes in this version

+ const NotificationExpiryDuration

+ func NewConnector(core Core) data.Connector

+ func NewEntityManager(core Core) data.ModifiableEntityManager

+ func NewFieldOperator(core Core) data.ModifiableFieldOperator

+ func NewNotificationConsumer(core Core) data.ModifiableNotificationConsumer

+ func NewNotificationPublisher(core Core) data.ModifiableNotificationPublisher

+ func NewSchemaManager(core Core) data.ModifiableSchemaManager

+ func NewSnapshotManager(core Core) data.ModifiableSnapshotManager

+ type Config struct

+ ConnectionString string

+ type Connector struct

+ func (me *Connector) Connect(ctx context.Context)

+ func (me *Connector) Disconnect(ctx context.Context)

+ func (me *Connector) IsConnected(ctx context.Context) bool

+ type Core interface

+ GetConfig func() Config

+ GetPool func() *pgxpool.Pool

+ SetConfig func(config Config)

+ SetPool func(pool *pgxpool.Pool)

+ WithTx func(ctx context.Context, fn func(context.Context, pgx.Tx))

+ func NewCore(config Config) Core

+ type EntityManager struct

+ func (me *EntityManager) CreateEntity(ctx context.Context, entityType, parentId, name string)

+ func (me *EntityManager) DeleteEntity(ctx context.Context, entityId string)

+ func (me *EntityManager) FindEntities(ctx context.Context, entityType string) []string

+ func (me *EntityManager) GetEntity(ctx context.Context, entityId string) data.Entity

+ func (me *EntityManager) SetEntity(ctx context.Context, e data.Entity)

+ func (me *EntityManager) SetFieldOperator(fieldOperator data.FieldOperator)

+ func (me *EntityManager) SetSchemaManager(schemaManager data.SchemaManager)

+ func (s *EntityManager) GetEntityTypes(ctx context.Context) []string

+ type FieldOperator struct

+ func (me *FieldOperator) Read(ctx context.Context, requests ...data.Request)

+ func (me *FieldOperator) SetEntityManager(entityManager data.EntityManager)

+ func (me *FieldOperator) SetNotificationPublisher(publisher data.NotificationPublisher)

+ func (me *FieldOperator) SetSchemaManager(schemaManager data.SchemaManager)

+ func (me *FieldOperator) SetTransformer(transformer data.Transformer)

+ func (me *FieldOperator) Write(ctx context.Context, requests ...data.Request)

+ type NotificationConsumer struct

+ func (me *NotificationConsumer) Notify(ctx context.Context, nc data.NotificationConfig, cb data.NotificationCallback) data.NotificationToken

+ func (me *NotificationConsumer) ProcessNotifications(ctx context.Context)

+ func (me *NotificationConsumer) SetTransformer(transformer data.Transformer)

+ func (me *NotificationConsumer) Unnotify(ctx context.Context, token string)

+ func (me *NotificationConsumer) UnnotifyCallback(ctx context.Context, token string, callback data.NotificationCallback)

+ type NotificationPublisher struct

+ func (me *NotificationPublisher) PublishNotifications(ctx context.Context, curr data.Request, prev data.Request)

+ func (me *NotificationPublisher) SetEntityManager(entityManager data.EntityManager)

+ func (me *NotificationPublisher) SetFieldOperator(fieldOperator data.FieldOperator)

+ type SchemaManager struct

+ func (me *SchemaManager) EntityExists(ctx context.Context, entityId string) bool

+ func (me *SchemaManager) FieldExists(ctx context.Context, fieldName, entityType string) bool

+ func (me *SchemaManager) GetEntitySchema(ctx context.Context, entityType string) data.EntitySchema

+ func (me *SchemaManager) GetFieldSchema(ctx context.Context, entityType, fieldName string) data.FieldSchema

+ func (me *SchemaManager) SetEntityManager(entityManager data.EntityManager)

+ func (me *SchemaManager) SetEntitySchema(ctx context.Context, schema data.EntitySchema)

+ func (me *SchemaManager) SetFieldOperator(fieldOperator data.FieldOperator)

+ func (me *SchemaManager) SetFieldSchema(ctx context.Context, entityType, fieldName string, schema data.FieldSchema)

+ type SnapshotManager struct

+ func (me *SnapshotManager) CreateSnapshot(ctx context.Context) data.Snapshot

+ func (me *SnapshotManager) RestoreSnapshot(ctx context.Context, ss data.Snapshot)

+ func (me *SnapshotManager) SetEntityManager(entityManager data.EntityManager)

+ func (me *SnapshotManager) SetFieldOperator(fieldOperator data.FieldOperator)

+ func (me *SnapshotManager) SetSchemaManager(schemaManager data.SchemaManager)