Interface EntityStore

packages/db/src/types.ts:48–68

}

export interface EntityStore {
  applyChanges(
    tx: KVStoreTransaction,
    buffer: DBChanges,
    options: ApplyChangesOptions
  ): Promise<DBChanges>;
  getEntity(
    storage: KVStoreOrTransaction,
    collection: string,
    id: string
    // TODO: make this null
  ): Promise<DBEntity | undefined>;
  getEntitiesInCollection(
    storage: KVStoreOrTransaction,
    collection: CollectionName
  ): AsyncIterable<DBEntity>;
  getCollectionStats(
    storage: KVStoreOrTransaction,
    knownCollections?: CollectionName[]
  ): Promise<Map<string, number>>;
}

export interface WriteBuffer {
  clear(tx: KVStoreTransaction): Promise<void>;