Class BaseDagEventStore<K, V, QueryExt>`Abstract`

An abstract EventStore storing events that form a DAG. One of entries or keys query functions must be overridden in subclass, as by default they refer to each other.

Type Parameters

K extends StringEquatable<K> = ContentId
V = unknown
QueryExt extends object = NonNullable<unknown>

Hierarchy

BaseMapEventStore<K, V, QueryExt>
- BaseDagEventStore
  - DagEventStore
  - IndexedEventStore

Implements

EventStore<K, V, QueryExt>

Index

Constructors

constructor

new BaseDagEventStore<K, V, QueryExt>(data, getEventMeta?, queryPageSize?): BaseDagEventStore<K, V, QueryExt>
Type Parameters
- K extends StringEquatable<K> = ContentId<number, number>
- V = unknown
- QueryExt extends object = {}
Parameters
- data: AppendOnlyAutoKeyMap<K, V> & Partial<AutoKeyMapBatch<K, V>>
- getEventMeta: ((event) => undefined | EventMeta<K>) = ...
  Returns given event metadata.
  - - (event): undefined | EventMeta<K>
    - Returns given event metadata.
      
      Parameters
      event: V
      Returns undefined | EventMeta<K>
- queryPageSize: number = DEFAULT_BATCH_SIZE
Returns BaseDagEventStore<K, V, QueryExt>
Overrides BaseMapEventStore.constructor
- Defined in collections/src/eventstore/base/dag.ts:24

Properties

`Protected` `Readonly` currentEventDeps

currentEventDeps: [K, V][] = []

Cache of event parents during a put/validate operation.

`Protected` `Readonly` data

data: AppendOnlyAutoKeyMap<K, V> & Partial<AutoKeyMapBatch<K, V>>

`Protected` `Readonly` getEventMeta

getEventMeta: ((event) => undefined | EventMeta<K>) = ...

Type declaration

- (event): undefined | EventMeta<K>
- Returns given event metadata.
  Parameters
  - event: V
  Returns undefined | EventMeta<K>

`Protected` `Readonly` queryPageSize

queryPageSize: number = DEFAULT_BATCH_SIZE

`Protected` useCache

useCache: boolean = false

Set to true to use cache.

Methods

[asyncIterator]

[asyncIterator](): AsyncIterableIterator<[K, V]>
Returns AsyncIterableIterator<[K, V]>
Inherited from BaseMapEventStore.[asyncIterator]
- Defined in collections/src/eventstore/base/base.ts:119

entries

entries(options?): SyncOrAsyncGenerator<[K, V], K[]>
Queries entries by given criteria.
Parameters
- Optional options: EventStoreQueryOptions<K> & QueryExt
Returns SyncOrAsyncGenerator<[K, V], K[]>
Implementation of EventStore.entries
Inherited from BaseMapEventStore.entries
- Defined in collections/src/eventstore/base/base.ts:84

`Protected` entriesForKeys

entriesForKeys(keys, options?): AsyncGenerator<[K, V], any, unknown>
Parameters
- keys: K[]
- Optional options: AbortOptions
Returns AsyncGenerator<[K, V], any, unknown>
Inherited from BaseMapEventStore.entriesForKeys
- Defined in collections/src/eventstore/base/base.ts:123

get

get(key, options?): MaybePromise<undefined | V>
Gets a value by key from the map.
Parameters
- key: K
- Optional options: AbortOptions
Returns MaybePromise<undefined | V>
Implementation of EventStore.get
Inherited from BaseMapEventStore.get
- Defined in collections/src/eventstore/base/base.ts:38

getKey

getKey(value, options?): MaybePromise<K>
Gets the key of given value.
Parameters
- value: V
- Optional options: AbortOptions
Returns MaybePromise<K>
Implementation of EventStore.getKey
Inherited from BaseMapEventStore.getKey
- Defined in collections/src/eventstore/base/base.ts:34

getMany

getMany(keys, options?): AsyncIterableIterator<undefined | V>
Gets the list of data identified by given keys.
Parameters
- keys: Iterable<K>
- Optional options: AbortOptions
Returns AsyncIterableIterator<undefined | V>
Implementation of EventStore.getMany
Inherited from BaseMapEventStore.getMany
- Defined in collections/src/eventstore/base/base.ts:42

has

has(key, options?): MaybePromise<boolean>
Returns whether a key exists in the map.
Parameters
- key: K
- Optional options: AbortOptions
Returns MaybePromise<boolean>
Implementation of EventStore.has
Inherited from BaseMapEventStore.has
- Defined in collections/src/eventstore/base/base.ts:46

hasMany

hasMany(keys, options?): AsyncIterableIterator<boolean>
Checks if given keys exist in the set.
Parameters
- keys: Iterable<K>
- Optional options: AbortOptions
Returns AsyncIterableIterator<boolean>
Implementation of EventStore.hasMany
Inherited from BaseMapEventStore.hasMany
- Defined in collections/src/eventstore/base/base.ts:50

keys

keys(options?): SyncOrAsyncGenerator<K, K[]>
Queries event keys by given criteria.
Parameters
- Optional options: EventStoreQueryOptions<K> & QueryExt
Returns SyncOrAsyncGenerator<K, K[]>
Implementation of EventStore.keys
Inherited from BaseMapEventStore.keys
- Defined in collections/src/eventstore/base/base.ts:101

`Protected` prePut

prePut(value, _options?): MaybePromise<V>
Hook to do extra processing before putting an event value to store.
Parameters
- value: V
- Optional _options: AbortOptions
Returns MaybePromise<V>
Inherited from BaseMapEventStore.prePut
- Defined in collections/src/eventstore/base/base.ts:23

put

put(value, options?): Promise<K>
Puts given value and returns its key.
Parameters
- value: V
- Optional options: EventStorePutOptions
Returns Promise<K>
Implementation of EventStore.put
Overrides BaseMapEventStore.put
- Defined in collections/src/eventstore/base/dag.ts:83

putMany

putMany(values, options?): AsyncIterableIterator<[key: K, error?: Error]>
Puts given list of values and returns their keys.
Parameters
- values: Iterable<V>
- Optional options: EventStorePutOptions
Returns AsyncIterableIterator<[key: K, error?: Error]>
Implementation of EventStore.putMany
Inherited from BaseMapEventStore.putMany
- Defined in collections/src/eventstore/base/base.ts:67

validate

validate(value, options?): Promise<undefined | Error>
Validates given event and returns any error.
Parameters
- value: V
- Optional options: AbortOptions
Returns Promise<undefined | Error>
Implementation of EventStore.validate
Overrides BaseMapEventStore.validate
- Defined in collections/src/eventstore/base/dag.ts:34

values

values(options?): SyncOrAsyncGenerator<V, K[]>
Queries events by given criteria.
Parameters
- Optional options: EventStoreQueryOptions<K> & QueryExt
Returns SyncOrAsyncGenerator<V, K[]>
Implementation of EventStore.values
Inherited from BaseMapEventStore.values
- Defined in collections/src/eventstore/base/base.ts:110

Class BaseDagEventStore<K, V, QueryExt>Abstract

Type Parameters

K extends StringEquatable<K> = ContentId

V = unknown

QueryExt extends object = NonNullable<unknown>

Hierarchy

Implements

Index

Constructors

Properties

Methods

Constructors

constructor

Type Parameters

K extends StringEquatable<K> = ContentId<number, number>

V = unknown

QueryExt extends object = {}

Parameters

data: AppendOnlyAutoKeyMap<K, V> & Partial<AutoKeyMapBatch<K, V>>

getEventMeta: ((event) => undefined | EventMeta<K>) = ...

Parameters

event: V

Returns undefined | EventMeta<K>

queryPageSize: number = DEFAULT_BATCH_SIZE

Returns BaseDagEventStore<K, V, QueryExt>

Properties

Protected Readonly currentEventDeps

Protected Readonly data

Protected Readonly getEventMeta

Type declaration

Parameters

event: V

Returns undefined | EventMeta<K>

Protected Readonly queryPageSize

Protected useCache

Methods

[asyncIterator]

Returns AsyncIterableIterator<[K, V]>

entries

Parameters

Optional options: EventStoreQueryOptions<K> & QueryExt

Returns SyncOrAsyncGenerator<[K, V], K[]>

Protected entriesForKeys

Parameters

keys: K[]

Optional options: AbortOptions

Returns AsyncGenerator<[K, V], any, unknown>

get

Parameters

key: K

Optional options: AbortOptions

Returns MaybePromise<undefined | V>

getKey

Parameters

value: V

Optional options: AbortOptions

Returns MaybePromise<K>

getMany

Parameters

keys: Iterable<K>

Optional options: AbortOptions

Returns AsyncIterableIterator<undefined | V>

has

Parameters

key: K

Optional options: AbortOptions

Returns MaybePromise<boolean>

hasMany

Parameters

keys: Iterable<K>

Optional options: AbortOptions

Returns AsyncIterableIterator<boolean>

keys

Parameters

Optional options: EventStoreQueryOptions<K> & QueryExt

Returns SyncOrAsyncGenerator<K, K[]>

Protected prePut

Parameters

value: V

Optional _options: AbortOptions

Class BaseDagEventStore<K, V, QueryExt>`Abstract`

`Protected` `Readonly` currentEventDeps

`Protected` `Readonly` data

`Protected` `Readonly` getEventMeta

`Protected` `Readonly` queryPageSize

`Protected` useCache

`Optional` options: EventStoreQueryOptions<K> & QueryExt

`Protected` entriesForKeys

`Optional` options: AbortOptions

`Optional` options: AbortOptions

`Optional` options: AbortOptions

`Optional` options: AbortOptions

`Optional` options: AbortOptions

`Optional` options: AbortOptions

`Optional` options: EventStoreQueryOptions<K> & QueryExt

`Protected` prePut

`Optional` _options: AbortOptions

`Optional` options: EventStorePutOptions

`Optional` options: EventStorePutOptions

`Optional` options: AbortOptions

`Optional` options: EventStoreQueryOptions<K> & QueryExt