跳到主要内容

RuntimeAdapter

Defined in: packages/rxdb-plugin-trigger/src/core/runtime-adapter.ts:33

Properties

storageTier

readonly storageTier: StorageTier;

Defined in: packages/rxdb-plugin-trigger/src/core/runtime-adapter.ts:34

Methods

atomicTransition()

atomicTransition(
EntityClass,
id,
expected,
patch): Promise<boolean>;

Defined in: packages/rxdb-plugin-trigger/src/core/runtime-adapter.ts:49

CAS 原子更新

当且仅当 expected 条件完全匹配时,才执行 patch 更新。 用于分布式锁实现。

Parameters

ParameterType
EntityClassEntityType
idstring
expectedRecord<string, unknown>
patchRecord<string, unknown>

Returns

Promise<boolean>


count()

count(EntityClass, query?): Observable<number>;

Defined in: packages/rxdb-plugin-trigger/src/core/runtime-adapter.ts:38

Parameters

ParameterType
EntityClassEntityType
query?FindQuery

Returns

Observable<number>


find()

find<T>(EntityClass, query): Observable<T[]>;

Defined in: packages/rxdb-plugin-trigger/src/core/runtime-adapter.ts:37

Type Parameters

Type ParameterDefault type
Tunknown

Parameters

ParameterType
EntityClassEntityType
queryFindQuery

Returns

Observable<T[]>


getById()

getById<T>(EntityClass, id): Observable<T | undefined>;

Defined in: packages/rxdb-plugin-trigger/src/core/runtime-adapter.ts:36

Type Parameters

Type ParameterDefault type
Tunknown

Parameters

ParameterType
EntityClassEntityType
idstring

Returns

Observable<T | undefined>


notifyExternalUpdate()

notifyExternalUpdate(
EntityClass,
id,
patch): void;

Defined in: packages/rxdb-plugin-trigger/src/core/runtime-adapter.ts:57

通知外部更新(触发 RxDB 响应式更新)

Parameters

ParameterType
EntityClassEntityType
idstring
patchRecord<string, unknown>

Returns

void


removeMany()

removeMany(entities): Promise<void>;

Defined in: packages/rxdb-plugin-trigger/src/core/runtime-adapter.ts:41

Parameters

ParameterType
entitiesunknown[]

Returns

Promise<void>


save()

save(entity): Promise<void>;

Defined in: packages/rxdb-plugin-trigger/src/core/runtime-adapter.ts:39

Parameters

ParameterType
entityunknown

Returns

Promise<void>


saveMany()

saveMany(entities): Promise<unknown[]>;

Defined in: packages/rxdb-plugin-trigger/src/core/runtime-adapter.ts:40

Parameters

ParameterType
entitiesunknown[]

Returns

Promise<unknown[]>