Class: SQLAdapterLockManager

Methods

assertCanPerformQueueOperation()

assertCanPerformQueueOperation(queue: string, operation: string): Promise<void>;

Parameters

Parameter	Type
queue	string
operation	string

Returns

Promise<void>

---

getLockForQueueJobOperation()

getLockForQueueJobOperation(queue: string, jobId: string): Lock;

Parameters

Parameter	Type
queue	string
jobId	string

Returns

Lock

---

getLockForQueueManagementOperation()

getLockForQueueManagementOperation(queue: string): Lock;

Parameters

Parameter	Type
queue	string

Returns

Lock

---

purgeQueueJobLocks()

purgeQueueJobLocks(queue: string): Promise<void>;

Parameters

Parameter	Type
queue	string

Returns

Promise<void>

---

purgeQueueManagementLocks()

purgeQueueManagementLocks(queue: string): Promise<void>;

Parameters

Parameter	Type
queue	string

Returns

Promise<void>

---

shutdown()

shutdown(): Promise<void>;

Shuts down (destroys) the Knex instance underlying the migrator instance.

Returns

Promise<void>

WARNING

If an error occurs during shutdown by knex or one if its underlying libraries, it will be thrown