StorageMonitor

Defined in: packages/rxdb-plugin-trigger/src/core/storage-monitor.ts:17

rxdb-plugin-trigger - RxDB 触发器插件

基于 RxDB 的分布式任务队列和定时调度插件，支持：

• 任务触发与批量触发（trigger / triggerAndWait / batchTrigger）
• 定时 Cron 调度（schedules API）
• 实体变更触发（entityTriggers API）
• DAG 工作流执行（WorkflowExecutor）
• 多标签页协作与领导选举
• 幂等性、并发控制、重试机制

Example

import { rxDBPluginTrigger } from 'rxdb-plugin-trigger';

const db = await createRxDatabase({ ... });
db.addPlugin(rxDBPluginTrigger());

const task = db.trigger.task({
  id: 'my-task',
  run: async (payload, ctx) => {
    console.log('Running task:', payload);
    return { result: 'done' };
  }
});

// 触发任务
await task.trigger({ data: 'hello' });

// 触发并等待结果
const result = await task.triggerAndWait({ data: 'hello' });

Constructors

Constructor

new StorageMonitor(rxdb): StorageMonitor;

Defined in: packages/rxdb-plugin-trigger/src/core/storage-monitor.ts:24

Parameters

Parameter	Type
rxdb	RxDB

Returns

StorageMonitor

Methods

destroy()

destroy(): void;

Defined in: packages/rxdb-plugin-trigger/src/core/storage-monitor.ts:71

destroy - 销毁

Returns

void

---

startAlerting()

startAlerting(thresholds?, pollIntervalMs?): void;

Defined in: packages/rxdb-plugin-trigger/src/core/storage-monitor.ts:42

startAlerting - 启动告警监控

Parameters

Parameter	Type	Default value
thresholds?	StorageAlertThresholds	undefined
pollIntervalMs?	number	60_000

Returns

void

---

storageStats$()

storageStats$(pollIntervalMs?): Observable<StorageStats>;

Defined in: packages/rxdb-plugin-trigger/src/core/storage-monitor.ts:33

storageStats$ - 存储统计信息流

定期发出存储统计信息，包括运行记录数和预估存储大小。

Parameters

Parameter	Type	Default value
pollIntervalMs	number	30_000

Returns

Observable<StorageStats>