nats

Mar 7, 2025

Changes in this version

type SnapshotManager

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

Mar 7, 2025

Changes in this version

type Core

+ SetAuthProvider func(data.AuthProvider)

Mar 3, 2025

Changes in this version

type Core

+ SetSessionProvider func(data.SessionProvider)

type EntityManager

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

type KeyGenerator

+ GetDistributedNotificationGroupSubject func(serviceId string) string

+ GetNotificationRegistrationSubject func() string

Feb 25, 2025

Changes in this version

type Connector

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

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

type Core

+ Connected func() signalslots.Signal

+ Disconnected func() signalslots.Signal

type NotificationConsumer

+ func (me *NotificationConsumer) Consumed() signalslots.Signal

Feb 24, 2025

Changes in this version

type KeyGenerator

+ GetNotificationGroupSubject func(serviceId string) string

+ GetReadSubject func() string

+ GetWriteSubject func() string

Feb 24, 2025

Changes in this version

+ 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

+ Address string

+ type Connector struct

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

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

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

+ type Core interface

+ Connect func(ctx context.Context)

+ Disconnect func(ctx context.Context)

+ GetConfig func() Config

+ GetKeyGenerator func() KeyGenerator

+ IsConnected func(ctx context.Context) bool

+ Publish func(subject string, msg proto.Message) error

+ QueueSubscribe func(subject, queue string, handler func(msg *natsgo.Msg))

+ Request func(ctx context.Context, subject string, msg proto.Message) (*protobufs.ApiMessage, error)

+ SetConfig func(config Config)

+ Subscribe func(subject string, handler func(msg *natsgo.Msg))

+ func NewCore(config Config) Core

+ type EntityManager struct

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

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

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

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

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

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

+ func (e *EntityManager) SetFieldOperator(fo data.FieldOperator)

+ func (e *EntityManager) SetSchemaManager(sm data.SchemaManager)

+ type FieldOperator struct

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

+ func (f *FieldOperator) SetEntityManager(em data.EntityManager)

+ func (f *FieldOperator) SetNotificationPublisher(np data.NotificationPublisher)

+ func (f *FieldOperator) SetSchemaManager(sm data.SchemaManager)

+ func (f *FieldOperator) SetTransformer(t data.Transformer)

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

+ type KeyGenerator interface

+ GetEntityExistsSubject func() string

+ GetEntitySchemaSubject func(entityType string) string

+ GetEntitySubject func(entityId string) string

+ GetEntityTypeSubject func(entityType string) string

+ GetFieldExistsSubject func() string

+ GetFieldSubject func(fieldName, entityId string) string

+ GetNotificationQueueGroup func(serviceId string) string

+ GetNotificationRegisterSubject func() string

+ GetNotificationSubject func() string

+ GetNotificationUnregisterSubject func() string

+ GetSnapshotCreateSubject func() string

+ GetSnapshotRestoreSubject func() string

+ func NewKeyGenerator() KeyGenerator

+ type NotificationConsumer struct

+ func (n *NotificationConsumer) Notify(ctx context.Context, config data.NotificationConfig, ...) data.NotificationToken

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

+ func (n *NotificationConsumer) SetTransformer(t data.Transformer)

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

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

+ type NotificationPublisher struct

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

+ func (p *NotificationPublisher) SetEntityManager(em data.EntityManager)

+ func (p *NotificationPublisher) SetFieldOperator(fo data.FieldOperator)

+ type SchemaManager struct

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

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

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

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

+ func (s *SchemaManager) SetEntityManager(em data.EntityManager)

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

+ func (s *SchemaManager) SetFieldOperator(fo data.FieldOperator)

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

+ type SnapshotManager struct

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

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

+ func (s *SnapshotManager) SetEntityManager(em data.EntityManager)

+ func (s *SnapshotManager) SetFieldOperator(fo data.FieldOperator)

+ func (s *SnapshotManager) SetSchemaManager(sm data.SchemaManager)