IDeltaQueue Interface
Queue of ops to be sent to or processed from storage
To use, import via @fluidframework/container-definitions/legacy
.
For more information about our API support guarantees, see here.
This type is "sealed," meaning that code outside of the library defining it should not implement or extend it. Future versions of this type may add members or make typing of readonly members more specific.
Signature
/** @sealed */
export interface IDeltaQueue<T> extends IEventProvider<IDeltaQueueEvents<T>>, IDisposable
Extends: IEventProvider<IDeltaQueueEvents<T>>, IDisposable
Type Parameters
Parameter | Description |
---|---|
T |
Properties
Property | Alerts | Type | Description |
---|---|---|---|
idle | Alpha |
boolean | Flag indicating whether or not the queue is idle. I.e. there are no remaining messages to processes. |
length | Alpha |
number | The number of messages remaining in the queue |
paused | Alpha |
boolean | Flag indicating whether or not the queue was paused |
Methods
Method | Alerts | Return Type | Description |
---|---|---|---|
pause() | Alpha |
Promise<void> | Pauses processing on the queue. |
peek() | Alpha |
T | undefined | Peeks at the next message in the queue |
resume() | Alpha |
void | Resumes processing on the queue |
toArray() | Alpha |
T[] | Returns all the items in the queue as an array. Does not remove them from the queue. |
waitTillProcessingDone() | Alpha |
Promise<{ count: number; duration: number; }> | returns number of ops processed and time it took to process these ops. Zeros if queue did not process anything (had no messages, was paused or had hit an error before) |
Property Details
idle
Flag indicating whether or not the queue is idle. I.e. there are no remaining messages to processes.
For more information about our API support guarantees, see here.
This type is "sealed," meaning that code outside of the library defining it should not implement or extend it. Future versions of this type may add members or make typing of readonly members more specific.
Signature
idle: boolean;
Type: boolean
length
The number of messages remaining in the queue
For more information about our API support guarantees, see here.
This type is "sealed," meaning that code outside of the library defining it should not implement or extend it. Future versions of this type may add members or make typing of readonly members more specific.
Signature
length: number;
Type: number
paused
Flag indicating whether or not the queue was paused
For more information about our API support guarantees, see here.
This type is "sealed," meaning that code outside of the library defining it should not implement or extend it. Future versions of this type may add members or make typing of readonly members more specific.
Signature
paused: boolean;
Type: boolean
Method Details
pause
Pauses processing on the queue.
For more information about our API support guarantees, see here.
This type is "sealed," meaning that code outside of the library defining it should not implement or extend it. Future versions of this type may add members or make typing of readonly members more specific.
Signature
pause(): Promise<void>;
Returns
A promise which resolves when processing has been paused.
Return type: Promise<void>
peek
Peeks at the next message in the queue
For more information about our API support guarantees, see here.
This type is "sealed," meaning that code outside of the library defining it should not implement or extend it. Future versions of this type may add members or make typing of readonly members more specific.
Signature
peek(): T | undefined;
Returns
Return type: T | undefined
resume
Resumes processing on the queue
For more information about our API support guarantees, see here.
This type is "sealed," meaning that code outside of the library defining it should not implement or extend it. Future versions of this type may add members or make typing of readonly members more specific.
Signature
resume(): void;
toArray
Returns all the items in the queue as an array. Does not remove them from the queue.
For more information about our API support guarantees, see here.
This type is "sealed," meaning that code outside of the library defining it should not implement or extend it. Future versions of this type may add members or make typing of readonly members more specific.
Signature
toArray(): T[];
Returns
Return type: T[]
waitTillProcessingDone
returns number of ops processed and time it took to process these ops. Zeros if queue did not process anything (had no messages, was paused or had hit an error before)
For more information about our API support guarantees, see here.
This type is "sealed," meaning that code outside of the library defining it should not implement or extend it. Future versions of this type may add members or make typing of readonly members more specific.
Signature
waitTillProcessingDone(): Promise<{
count: number;
duration: number;
}>;
Returns
Return type: Promise<{ count: number; duration: number; }>