postgres

Documentation

Index

• func NewConnector(core Core) data.Connector
• func NewEntityManager(core Core) data.ModifiableEntityManager
• func NewFieldOperator(core Core) data.ModifiableFieldOperator
• func NewSchemaManager(core Core) data.ModifiableSchemaManager
• func NewSnapshotManager(core Core) data.ModifiableSnapshotManager
• type Config
• type Connector
  • func (me *Connector) Connect(ctx context.Context)
  • func (me *Connector) Connected() signalslots.Signal
  • func (me *Connector) Disconnect(ctx context.Context)
  • func (me *Connector) Disconnected() signalslots.Signal
  • func (me *Connector) IsConnected(ctx context.Context) bool
• type Core
  • func NewCore(config Config) Core
• type EntityManager
  • func (me *EntityManager) CreateEntity(ctx context.Context, entityType, parentId, name string) string
  • func (me *EntityManager) DeleteEntity(ctx context.Context, entityId string)
  • func (me *EntityManager) EntityExists(ctx context.Context, entityId string) bool
  • func (me *EntityManager) FindEntities(ctx context.Context, entityType string) []string
  • func (me *EntityManager) GetEntity(ctx context.Context, entityId string) data.Entity
  • func (s *EntityManager) GetEntityTypes(ctx context.Context) []string
  • func (me *EntityManager) SetFieldOperator(fieldOperator data.FieldOperator)
  • func (me *EntityManager) SetSchemaManager(schemaManager data.SchemaManager)
• type FieldOperator
  • 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) Write(ctx context.Context, requests ...data.Request)
• type SchemaManager
  • 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
  • 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)

Functions

func NewConnector

func NewConnector(core Core) data.Connector

func NewEntityManager

func NewEntityManager(core Core) data.ModifiableEntityManager

func NewFieldOperator

func NewFieldOperator(core Core) data.ModifiableFieldOperator

func NewSchemaManager

func NewSchemaManager(core Core) data.ModifiableSchemaManager

func NewSnapshotManager

func NewSnapshotManager(core Core) data.ModifiableSnapshotManager

Types

type Config

type Config struct {
	ConnectionString string
}

type Connector

type Connector struct {
	// contains filtered or unexported fields
}

func (*Connector) Connect

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

func (*Connector) Connected

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

func (*Connector) Disconnect

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

func (*Connector) Disconnected

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

func (*Connector) IsConnected

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

type Core

type Core interface {
	WithTx(ctx context.Context, fn func(context.Context, pgx.Tx))
	SetPool(pool *pgxpool.Pool)
	GetPool() *pgxpool.Pool
	SetConfig(config Config)
	GetConfig() Config
}

func NewCore

func NewCore(config Config) Core

type EntityManager

type EntityManager struct {
	// contains filtered or unexported fields
}

func (*EntityManager) CreateEntity

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

func (*EntityManager) DeleteEntity

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

func (*EntityManager) EntityExists

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

func (*EntityManager) FindEntities

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

func (*EntityManager) GetEntity

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

func (*EntityManager) GetEntityTypes

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

func (*EntityManager) SetFieldOperator

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

func (*EntityManager) SetSchemaManager

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

type FieldOperator

type FieldOperator struct {
	// contains filtered or unexported fields
}

func (*FieldOperator) Read

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

func (*FieldOperator) SetEntityManager

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

func (*FieldOperator) SetNotificationPublisher

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

func (*FieldOperator) SetSchemaManager

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

func (*FieldOperator) Write

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

type SchemaManager

type SchemaManager struct {
	// contains filtered or unexported fields
}

func (*SchemaManager) FieldExists

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

func (*SchemaManager) GetEntitySchema

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

func (*SchemaManager) GetFieldSchema

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

func (*SchemaManager) SetEntityManager

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

func (*SchemaManager) SetEntitySchema

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

func (*SchemaManager) SetFieldOperator

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

func (*SchemaManager) SetFieldSchema

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

type SnapshotManager

type SnapshotManager struct {
	// contains filtered or unexported fields
}

func (*SnapshotManager) CreateSnapshot

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

func (*SnapshotManager) RestoreSnapshot

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

func (*SnapshotManager) SetEntityManager

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

func (*SnapshotManager) SetFieldOperator

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

func (*SnapshotManager) SetSchemaManager

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