QueueManager
Defined in: src/lib/db/queue/manager.ts:112
Constructors
Constructor
new QueueManager():
QueueManager
Returns
QueueManager
Methods
clear()
clear(
walletAddress:string):void
Defined in: src/lib/db/queue/manager.ts:321
Clear all queued operations for a wallet.
Parameters
| Parameter | Type |
|---|---|
|
|
|
Returns
void
flush()
flush(
encryptionContext:QueueEncryptionContext,executor:OperationExecutor):Promise<FlushResult>
Defined in: src/lib/db/queue/manager.ts:213
Flush all queued operations for a wallet by executing them with encryption.
Parameters
| Parameter | Type | Description |
|---|---|---|
|
|
Wallet address and signing functions for encryption | |
|
|
Function that executes each operation against the database |
Returns
Promise<FlushResult>
Result with succeeded/failed operation IDs
getOperations()
getOperations(
walletAddress:string):QueuedOperation[]
Defined in: src/lib/db/queue/manager.ts:171
Get all pending operations for a wallet, sorted by dependency order.
Parameters
| Parameter | Type |
|---|---|
|
|
|
Returns
getStatus()
getStatus(
walletAddress:string):QueueStatus
Defined in: src/lib/db/queue/manager.ts:194
Get the status of a wallet’s queue.
Parameters
| Parameter | Type |
|---|---|
|
|
|
Returns
hasPending()
hasPending(
walletAddress:string):boolean
Defined in: src/lib/db/queue/manager.ts:364
Check if a wallet has any pending operations.
Parameters
| Parameter | Type |
|---|---|
|
|
|
Returns
boolean
onQueueChange()
onQueueChange(
walletAddress:string,callback: () =>void): () =>void
Defined in: src/lib/db/queue/manager.ts:345
Register a listener for queue changes on a wallet.
Parameters
| Parameter | Type |
|---|---|
|
|
|
|
|
() => |
Returns
Unsubscribe function
():
void
Returns
void
pause()
pause(
walletAddress:string):void
Defined in: src/lib/db/queue/manager.ts:330
Pause the queue for a wallet (stops flush mid-way).
Parameters
| Parameter | Type |
|---|---|
|
|
|
Returns
void
queueOperation()
queueOperation(
walletAddress:string,type:QueuedOperationType,payload:Record<string,any>,dependencies:string[],maxRetries:number):string|null
Defined in: src/lib/db/queue/manager.ts:128
Queue a new operation for a wallet.
Parameters
| Parameter | Type | Default value |
|---|---|---|
|
|
|
|
|
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
Returns
string | null
The operation ID, or null if queue is full.
removeOperation()
removeOperation(
walletAddress:string,operationId:string):void
Defined in: src/lib/db/queue/manager.ts:180
Remove a specific operation from the queue.
Parameters
| Parameter | Type |
|---|---|
|
|
|
|
|
|
Returns
void
resume()
resume(
walletAddress:string):void
Defined in: src/lib/db/queue/manager.ts:337
Resume the queue for a wallet.
Parameters
| Parameter | Type |
|---|---|
|
|
|
Returns
void