memory

Mar 27, 2024

Changes in this version

type SchemaReader

+ func (r *SchemaReader) ReadSchemaString(_ context.Context, tenantID, version string) (definitions []string, err error)

Feb 23, 2024

Changes in this version

type SchemaReader

+ func (r *SchemaReader) ListSchemas(_ context.Context, tenantID string, pagination database.Pagination) (schemas []*base.SchemaList, ct database.EncodedContinuousToken, err error)

Nov 30, 2023

Changes in this version

+ type BundleReader struct

+ func NewBundleReader(database *db.Memory) *BundleReader

+ func (b *BundleReader) Read(_ context.Context, _, _ string) (bundle *base.DataBundle, err error)

+ type BundleWriter struct

+ func NewBundleWriter(database *db.Memory) *BundleWriter

+ func (b *BundleWriter) Delete(_ context.Context, _, _ string) (err error)

+ func (b *BundleWriter) Write(_ context.Context, _ string, _ []*base.DataBundle) (names []string, err error)

type DataWriter

+ func (r *DataWriter) RunBundle(_ context.Context, _ string, _ map[string]string, _ *base.DataBundle) (token token.EncodedSnapToken, err error)

Sep 12, 2023

Changes in this version

+ const AttributesTable

+ type DataReader struct

+ func NewDataReader(database *db.Memory, logger logger.Interface) *DataReader

+ func (r *DataReader) HeadSnapshot(_ context.Context, _ string) (token.SnapToken, error)

+ func (r *DataReader) QueryAttributes(_ context.Context, tenantID string, filter *base.AttributeFilter, _ string) (iterator *database.AttributeIterator, err error)

+ func (r *DataReader) QueryRelationships(_ context.Context, tenantID string, filter *base.TupleFilter, _ string) (it *database.TupleIterator, err error)

+ func (r *DataReader) QuerySingleAttribute(_ context.Context, tenantID string, filter *base.AttributeFilter, _ string) (attribute *base.Attribute, err error)

+ func (r *DataReader) QueryUniqueEntities(_ context.Context, tenantID, name, _ string, _ database.Pagination) (ids []string, ct database.EncodedContinuousToken, err error)

+ func (r *DataReader) QueryUniqueSubjectReferences(_ context.Context, tenantID string, subjectReference *base.RelationReference, ...) ([]string, database.EncodedContinuousToken, error)

+ func (r *DataReader) ReadAttributes(_ context.Context, tenantID string, filter *base.AttributeFilter, _ string, ...) (collection *database.AttributeCollection, ct database.EncodedContinuousToken, ...)

+ func (r *DataReader) ReadRelationships(_ context.Context, tenantID string, filter *base.TupleFilter, _ string, ...) (collection *database.TupleCollection, ct database.EncodedContinuousToken, ...)

+ type DataWriter struct

+ func NewDataWriter(database *db.Memory, logger logger.Interface) *DataWriter

+ func (r *DataWriter) Delete(_ context.Context, tenantID string, tupleFilter *base.TupleFilter, ...) (token.EncodedSnapToken, error)

+ func (r *DataWriter) Write(_ context.Context, tenantID string, tupleCollection *database.TupleCollection, ...) (token.EncodedSnapToken, error)

type SchemaReader

+ func (r *SchemaReader) ReadEntityDefinition(_ context.Context, tenantID, entityName, version string) (definition *base.EntityDefinition, v string, err error)

+ func (r *SchemaReader) ReadRuleDefinition(_ context.Context, tenantID, ruleName, version string) (definition *base.RuleDefinition, v string, err error)

Jun 1, 2023

Changes in this version

+ type Watch struct

+ func NewWatcher(database *db.Memory, logger logger.Interface) *Watch

+ func (r *Watch) Watch(_ context.Context, _ string, _ string) (<-chan *base.TupleChanges, <-chan error)

May 4, 2023

Changes in this version

+ const RelationTuplesTable

+ const SchemaDefinitionsTable

+ const TenantsTable

+ type RelationshipReader struct

+ func NewRelationshipReader(database *db.Memory, logger logger.Interface) *RelationshipReader

+ func (r *RelationshipReader) HeadSnapshot(ctx context.Context, _ string) (token.SnapToken, error)

+ func (r *RelationshipReader) QueryRelationships(ctx context.Context, tenantID string, filter *base.TupleFilter, _ string) (it *database.TupleIterator, err error)

+ func (r *RelationshipReader) ReadRelationships(ctx context.Context, tenantID string, filter *base.TupleFilter, _ string, ...) (collection *database.TupleCollection, ct database.EncodedContinuousToken, ...)

+ type RelationshipWriter struct

+ func NewRelationshipWriter(database *db.Memory, logger logger.Interface) *RelationshipWriter

+ func (r *RelationshipWriter) DeleteRelationships(ctx context.Context, tenantID string, filter *base.TupleFilter) (token.EncodedSnapToken, error)

+ func (r *RelationshipWriter) WriteRelationships(ctx context.Context, tenantID string, collection *database.TupleCollection) (token.EncodedSnapToken, error)

+ type SchemaReader struct

+ func NewSchemaReader(database *db.Memory, logger logger.Interface) *SchemaReader

+ func (r *SchemaReader) HeadVersion(ctx context.Context, tenantID string) (string, error)

+ func (r *SchemaReader) ReadSchema(ctx context.Context, tenantID, version string) (sch *base.SchemaDefinition, err error)

+ func (r *SchemaReader) ReadSchemaDefinition(ctx context.Context, tenantID, entityType, version string) (definition *base.EntityDefinition, v string, err error)

+ type SchemaWriter struct

+ func NewSchemaWriter(database *db.Memory, logger logger.Interface) *SchemaWriter

+ func (w *SchemaWriter) WriteSchema(ctx context.Context, definitions []storage.SchemaDefinition) error

+ type TenantReader struct

+ func NewTenantReader(database *db.Memory, logger logger.Interface) *TenantReader

+ func (r *TenantReader) ListTenants(ctx context.Context, pagination database.Pagination) (tenants []*base.Tenant, ct database.EncodedContinuousToken, err error)

+ type TenantWriter struct

+ func NewTenantWriter(database *db.Memory, logger logger.Interface) *TenantWriter

+ func (w *TenantWriter) CreateTenant(ctx context.Context, id, name string) (result *base.Tenant, err error)

+ func (w *TenantWriter) DeleteTenant(ctx context.Context, tenantID string) (result *base.Tenant, err error)