Oak-Team
/
oak-domain
13
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 33 Wiki Activity

feat: 支持了watcher和timer的exclusive模式

This commit is contained in:
Pan Qiancheng 2026-01-23 14:37:07 +08:00
parent aa8a45d147
commit 7feeac0d78
2 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
lib/types/Watcher.d.ts vendored
View File

@ -12,6 +12,7 @@ export interface BBWatcher<ED extends EntityDict & BaseEntityDict, T extends key
actionData: ActionData<ED, T> | (() => Promise<ActionData<ED, T>>);
singleton?: true;
lazy?: true;
exclusive?: true;
}
export interface WBWatcher<ED extends EntityDict & BaseEntityDict, T extends keyof ED, Cxt extends AsyncContext<ED>> {
type?: 'base';
@ -23,6 +24,7 @@ export interface WBWatcher<ED extends EntityDict & BaseEntityDict, T extends key
forUpdate?: true;
singleton?: true;
lazy?: true;
exclusive?: true;
}
export interface WBFreeWatcher<ED extends EntityDict & BaseEntityDict, T extends keyof ED, Cxt extends AsyncContext<ED>> {
type: 'free';
@ -34,6 +36,7 @@ export interface WBFreeWatcher<ED extends EntityDict & BaseEntityDict, T extends
forUpdate?: true;
singleton?: true;
lazy?: true;
exclusive?: true;
}
export type Watcher<ED extends EntityDict & BaseEntityDict, T extends keyof ED, Cxt extends AsyncContext<ED>> = BBWatcher<ED, T> | WBWatcher<ED, T, Cxt> | WBFreeWatcher<ED, T, Cxt>;
export {};

3
src/types/Watcher.ts
View File

@ -15,6 +15,7 @@ export interface BBWatcher<ED extends EntityDict & BaseEntityDict, T extends key
actionData: ActionData<ED, T> | (() => Promise<ActionData<ED, T>>);
singleton?: true; // 置singleton意味着在集群环境中只有一个进程会去执行
lazy?: true; // 置lazy意味着在启动时不会立即执行，而是等到第一次调度时才执行
exclusive?: true; // 置exclusive意味着在同一实例中不会并发处理同一条数据，而是抛出警告
};
export interface WBWatcher<ED extends EntityDict & BaseEntityDict, T extends keyof ED, Cxt extends AsyncContext<ED>> {
@ -27,6 +28,7 @@ export interface WBWatcher<ED extends EntityDict & BaseEntityDict, T extends key
forUpdate?: true;
singleton?: true; // 置singleton意味着在集群环境中只有一个进程会去执行
lazy?: true; // 置lazy意味着在启动时不会立即执行，而是等到第一次调度时才执行
exclusive?: true; // 置exclusive意味着在同一实例中不会并发处理同一条数据，而是抛出警告
};
export interface WBFreeWatcher<ED extends EntityDict & BaseEntityDict, T extends keyof ED, Cxt extends AsyncContext<ED>> {
@ -39,6 +41,7 @@ export interface WBFreeWatcher<ED extends EntityDict & BaseEntityDict, T extends
forUpdate?: true;
singleton?: true; // 置singleton意味着在集群环境中只有一个进程会去执行
lazy?: true; // 置lazy意味着在启动时不会立即执行，而是等到第一次调度时才执行
exclusive?: true; // 置exclusive意味着在同一实例中不会并发处理同一条数据，而是抛出警告
};
export type Watcher<ED extends EntityDict & BaseEntityDict, T extends keyof ED, Cxt extends AsyncContext<ED>> = BBWatcher<ED, T> | WBWatcher<ED, T, Cxt> | WBFreeWatcher<ED, T, Cxt>;