Use lock name
This commit is contained in:
parent
3dbf0b3a64
commit
a9046e9f26
|
@ -51,7 +51,7 @@ docWritethroughProcessorQueue.process(async message => {
|
||||||
const lockResponse = await locks.doWithLock(
|
const lockResponse = await locks.doWithLock(
|
||||||
{
|
{
|
||||||
type: LockType.TRY_TWICE,
|
type: LockType.TRY_TWICE,
|
||||||
name: LockName.PERSIST_WRITETHROUGH,
|
name: LockName.PERSIST_DOC_WRITETHROUGH,
|
||||||
resource: cacheKeyPrefix,
|
resource: cacheKeyPrefix,
|
||||||
ttl: Duration.fromSeconds(60).toMs(),
|
ttl: Duration.fromSeconds(60).toMs(),
|
||||||
},
|
},
|
||||||
|
|
|
@ -23,6 +23,7 @@ export enum LockName {
|
||||||
APP_MIGRATION = "app_migrations",
|
APP_MIGRATION = "app_migrations",
|
||||||
PROCESS_AUTO_COLUMNS = "process_auto_columns",
|
PROCESS_AUTO_COLUMNS = "process_auto_columns",
|
||||||
PROCESS_USER_INVITE = "process_user_invite",
|
PROCESS_USER_INVITE = "process_user_invite",
|
||||||
|
PERSIST_DOC_WRITETHROUGH = "persist_doc_writethrough",
|
||||||
}
|
}
|
||||||
|
|
||||||
export type LockOptions = {
|
export type LockOptions = {
|
||||||
|
|
Loading…
Reference in New Issue