DbClient

Defined in: packages/db/src/client.ts:411

Constructors#

Constructor#

new DbClient(options): DbClient;

Defined in: packages/db/src/client.ts:438

Parameters#

options#

DbClientOptions = {}

Returns#

DbClient

Accessors#

activeTransaction#

Get Signature#

get activeTransaction(): 
  | Transaction<Record<string, unknown>>
  | undefined;

Defined in: packages/db/src/client.ts:456

Returns#

| Transaction<Record<string, unknown>> | undefined

Methods#

_assertLiveQuerySources()#

_assertLiveQuerySources(
   queryHash, 
   sources, 
   rowOptions?): void;

Defined in: packages/db/src/client.ts:896

Internal

Reject incompatible local sources or row behavior for a reusable stream.

Parameters#

queryHash#

string

sources#

readonly AnyCollection[]

rowOptions?#

LiveQueryRowOptions

Returns#

void

_bindLiveQueryObserver()#

_bindLiveQueryObserver<T, TKey>(
   collection, 
   queryHash, 
   suspendUntilReady, 
host): LiveQueryObserverClient<T, TKey>;

Defined in: packages/db/src/client.ts:794

Internal

Supply transport behavior without coupling ordinary observers to SSR.

Type Parameters#

T#

T extends object

TKey#

TKey extends string | number

Parameters#

collection#

Collection<T, TKey, any, StandardSchemaV1<unknown, unknown>, T> | null

queryHash#

string | undefined

suspendUntilReady#

boolean

host#

LiveQueryObserverClientHost<T, TKey>

Returns#

LiveQueryObserverClient<T, TKey>

_captureServerQuery()#

_captureServerQuery(
   queryHash, 
   snapshot, 
   sources?, 
   rowOptions?): void;

Defined in: packages/db/src/client.ts:935

Internal

Capture the first server view without starting acquisition.

Parameters#

queryHash#

string

snapshot#

DehydratedLiveQueryResult

sources?#

readonly AnyCollection[]

rowOptions?#

LiveQueryRowOptions

Returns#

void

_consumeLiveQueryResult()#

_consumeLiveQueryResult(queryHash, dehydratedAt): void;

Defined in: packages/db/src/client.ts:927

Internal

Parameters#

queryHash#

string

dehydratedAt#

number

Returns#

void

_failPendingLiveQueries()#

_failPendingLiveQueries(error): void;

Defined in: packages/db/src/client.ts:1017

Internal

Parameters#

error#

unknown

Returns#

void

_getLiveQuery()#

_getLiveQuery(queryHash, forServerSnapshot): DbClientLiveQuery | undefined;

Defined in: packages/db/src/client.ts:885

Internal

Parameters#

queryHash#

string

forServerSnapshot#

boolean = false

Returns#

DbClientLiveQuery | undefined

_hasSsrCollectionSnapshot()#

_hasSsrCollectionSnapshot(collection): boolean;

Defined in: packages/db/src/client.ts:810

Internal

Normalized source transport carries rows, not readiness.

Parameters#

collection#

AnyCollection

Returns#

boolean

_isSsrServerCleanupEnabled()#

_isSsrServerCleanupEnabled(): boolean;

Defined in: packages/db/src/client.ts:880

Internal

Returns#

boolean

_isSsrStreamingEnabled()#

_isSsrStreamingEnabled(): boolean;

Defined in: packages/db/src/client.ts:870

Internal

Returns#

boolean

_materializeCollectionForRender()#

_materializeCollectionForRender<T, TKey, TSchema, TUtils>(options): Collection<T, TKey, TUtils, TSchema, [TSchema] extends [never] ? T : InferSchemaInput<TSchema>>;

Defined in: packages/db/src/client.ts:606

Internal

Type Parameters#

T#

T extends object

TKey#

TKey extends string | number

TSchema#

TSchema extends StandardSchemaV1<unknown, unknown>

TUtils#

TUtils extends UtilsRecord

Parameters#

options#

CollectionOptions<T, TKey, TSchema, TUtils>

Returns#

Collection<T, TKey, TUtils, TSchema, [TSchema] extends [never] ? T : InferSchemaInput<TSchema>>

_registerLiveQuery()#

_registerLiveQuery(
   queryHash, 
   promise, 
   sources?, 
rowOptions?): Promise<void>;

Defined in: packages/db/src/client.ts:970

Internal

Parameters#

queryHash#

string

promise#

Promise<DehydratedLiveQueryResult<object, string | number>>

sources?#

readonly AnyCollection[]

rowOptions?#

LiveQueryRowOptions

Returns#

Promise<void>

_registerLiveQueryResource()#

_registerLiveQueryResource(owner, cleanup): () => void;

Defined in: packages/db/src/client.ts:1004

Internal

Parameters#

owner#

object

cleanup#

() => Promise<void>

Returns#

(): void;

Returns#

void

_setSsrServerCleanupEnabled()#

_setSsrServerCleanupEnabled(enabled): void;

Defined in: packages/db/src/client.ts:875

Internal

Parameters#

enabled#

boolean

Returns#

void

_setSsrStreamingEnabled()#

_setSsrStreamingEnabled(enabled): void;

Defined in: packages/db/src/client.ts:824

Internal

Parameters#

enabled#

boolean

Returns#

void

_waitForSsrLiveQuery()#

_waitForSsrLiveQuery(queryHash, forHydration): Promise<void> | undefined;

Defined in: packages/db/src/client.ts:840

Internal

Wait for transport without claiming or starting a local source.

Parameters#

queryHash#

string

forHydration#

boolean = false

Returns#

Promise<void> | undefined

applyCollectionChunk()#

applyCollectionChunk(chunk): void;

Defined in: packages/db/src/client.ts:784

Parameters#

chunk#

DehydratedCollectionChunk

Returns#

void

cleanup()#

cleanup(): Promise<void>;

Defined in: packages/db/src/client.ts:1025

Returns#

Promise<void>

collection()#

Call Signature#

collection<T, TKey, TUtils>(options, materializeOptions?): Collection<InferSchemaOutput<T>, TKey, TUtils, T, InferSchemaInput<T>> & NonSingleResult;

Defined in: packages/db/src/client.ts:562

Type Parameters#

T#

T extends StandardSchemaV1<unknown, unknown>

TKey#

TKey extends string | number

TUtils#

TUtils extends UtilsRecord

Parameters#

options#

CollectionOptions<InferSchemaOutput<T>, TKey, T, TUtils> & NonSingleResult

materializeOptions?#

CollectionMaterializeOptions<InferSchemaInput<T>>

Returns#

Collection<InferSchemaOutput<T>, TKey, TUtils, T, InferSchemaInput<T>> & NonSingleResult

Call Signature#

collection<T, TKey, TUtils>(options, materializeOptions?): Collection<InferSchemaOutput<T>, TKey, TUtils, T, InferSchemaInput<T>> & SingleResult;

Defined in: packages/db/src/client.ts:572

Type Parameters#

T#

T extends StandardSchemaV1<unknown, unknown>

TKey#

TKey extends string | number

TUtils#

TUtils extends UtilsRecord

Parameters#

options#

CollectionOptions<InferSchemaOutput<T>, TKey, T, TUtils> & SingleResult

materializeOptions?#

CollectionMaterializeOptions<InferSchemaInput<T>>

Returns#

Collection<InferSchemaOutput<T>, TKey, TUtils, T, InferSchemaInput<T>> & SingleResult

Call Signature#

collection<T, TKey, TUtils>(options, materializeOptions?): Collection<T, TKey, TUtils, never, T> & NonSingleResult;

Defined in: packages/db/src/client.ts:582

Type Parameters#

T#

T extends object

TKey#

TKey extends string | number = string | number

TUtils#

TUtils extends UtilsRecord = UtilsRecord

Parameters#

options#

CollectionOptions<T, TKey, never, TUtils> & NonSingleResult

materializeOptions?#

CollectionMaterializeOptions<T>

Returns#

Collection<T, TKey, TUtils, never, T> & NonSingleResult

Call Signature#

collection<T, TKey, TUtils>(options, materializeOptions?): Collection<T, TKey, TUtils, never, T> & SingleResult;

Defined in: packages/db/src/client.ts:590

Type Parameters#

T#

T extends object

TKey#

TKey extends string | number = string | number

TUtils#

TUtils extends UtilsRecord = UtilsRecord

Parameters#

options#

CollectionOptions<T, TKey, never, TUtils> & SingleResult

materializeOptions?#

CollectionMaterializeOptions<T>

Returns#

Collection<T, TKey, TUtils, never, T> & SingleResult

createTransaction()#

createTransaction<T>(config): Transaction<T>;

Defined in: packages/db/src/client.ts:460

Type Parameters#

T#

T extends object = Record<string, unknown>

Parameters#

config#

TransactionConfig<T>

Returns#

Transaction<T>

dehydrate()#

dehydrate(options): DehydratedDbState;

Defined in: packages/db/src/client.ts:697

Parameters#

options#

DehydrateDbClientOptions = {}

Returns#

DehydratedDbState

getDependency()#

getDependency<T>(key): T | undefined;

Defined in: packages/db/src/client.ts:440

Type Parameters#

T#

T

Parameters#

key#

string

Returns#

T | undefined

hydrate()#

hydrate(state): void;

Defined in: packages/db/src/client.ts:765

Parameters#

state#

DehydratedDbState

Returns#

void

preloadLiveQuery()#

preloadLiveQuery(options): Promise<void>;

Defined in: packages/db/src/client.ts:466

Parameters#

options#

LiveQueryOptions

Returns#

Promise<void>

requireDependency()#

requireDependency<T>(key): T;

Defined in: packages/db/src/client.ts:444

Type Parameters#

T#

T

Parameters#

key#

string

Returns#

T

subscribe()#

subscribe(listener): () => void;

Defined in: packages/db/src/client.ts:788

Parameters#

listener#

(event) => void

Returns#

(): void;

Returns#

void