SummaryCollection Class
Data structure that looks at the op stream to track summaries as they are broadcast, acked and nacked. It provides functionality for watching specific summaries.
To use, import via @fluidframework/container-runtime/legacy.
For more information about our API support guarantees, see here.
Signature
export declare class SummaryCollection extends TypedEventEmitter<ISummaryCollectionOpEvents>
Extends: TypedEventEmitter<ISummaryCollectionOpEvents>
Constructors
| Constructor | Alerts | Description |
|---|---|---|
| (constructor)(deltaManager, logger) | Beta | Constructs a new instance of the SummaryCollection class |
Properties
| Property | Alerts | Modifiers | Type | Description |
|---|---|---|---|---|
| latestAck | Beta | readonly | IAckedSummary | undefined | |
| opsSinceLastAck | Beta | readonly | number |
Methods
| Method | Alerts | Return Type | Description |
|---|---|---|---|
| addOpListener(listener) | Beta | void | |
| createWatcher(clientId) | Beta | IClientSummaryWatcher | Creates and returns a summary watcher for a specific client. This will allow for local sent summaries to be better tracked. |
| emit(event, args) | Beta | boolean | |
| removeOpListener(listener) | Beta | void | |
| removeWatcher(clientId) | Beta | void | |
| setPendingAckTimerTimeoutCallback(maxAckWaitTime, timeoutCallback) | Beta | void | |
| unsetPendingAckTimerTimeoutCallback() | Beta | void | |
| waitFlushed() | Beta | Promise<IAckedSummary | undefined> | Returns a promise that resolves once all pending summary ops have been acked or nacked. |
| waitSummaryAck(referenceSequenceNumber) | Beta | Promise<IAckedSummary> | Returns a promise that resolves once a summary is acked that has a reference sequence number greater than or equal to the passed in sequence number. |
Constructor Details
(constructor)
Constructs a new instance of the SummaryCollection class
For more information about our API support guarantees, see here.
Signature
constructor(deltaManager: IDeltaManager<ISequencedDocumentMessage, IDocumentMessage>, logger: ITelemetryBaseLogger);
Parameters
| Parameter | Type | Description |
|---|---|---|
| deltaManager | IDeltaManager<ISequencedDocumentMessage, IDocumentMessage> | |
| logger | ITelemetryBaseLogger |
Property Details
latestAck
For more information about our API support guarantees, see here.
Signature
get latestAck(): IAckedSummary | undefined;
Type: IAckedSummary | undefined
opsSinceLastAck
For more information about our API support guarantees, see here.
Signature
get opsSinceLastAck(): number;
Type: number
Method Details
addOpListener
For more information about our API support guarantees, see here.
Signature
addOpListener(listener: () => void): void;
Parameters
| Parameter | Type | Description |
|---|---|---|
| listener | () => void |
createWatcher
Creates and returns a summary watcher for a specific client. This will allow for local sent summaries to be better tracked.
For more information about our API support guarantees, see here.
Signature
createWatcher(clientId: string): IClientSummaryWatcher;
Parameters
| Parameter | Type | Description |
|---|---|---|
| clientId | string | client id for watcher |
Returns
Return type: IClientSummaryWatcher
emit
For more information about our API support guarantees, see here.
Signature
emit(event: OpActionEventName, ...args: Parameters<OpActionEventListener>): boolean;
Parameters
| Parameter | Type | Description |
|---|---|---|
| event | OpActionEventName | |
| args | Parameters<OpActionEventListener> |
Returns
Return type: boolean
removeOpListener
For more information about our API support guarantees, see here.
Signature
removeOpListener(listener: () => void): void;
Parameters
| Parameter | Type | Description |
|---|---|---|
| listener | () => void |
removeWatcher
For more information about our API support guarantees, see here.
Signature
removeWatcher(clientId: string): void;
Parameters
| Parameter | Type | Description |
|---|---|---|
| clientId | string |
setPendingAckTimerTimeoutCallback
For more information about our API support guarantees, see here.
Signature
setPendingAckTimerTimeoutCallback(maxAckWaitTime: number, timeoutCallback: () => void): void;
Parameters
| Parameter | Type | Description |
|---|---|---|
| maxAckWaitTime | number | |
| timeoutCallback | () => void |
unsetPendingAckTimerTimeoutCallback
For more information about our API support guarantees, see here.
Signature
unsetPendingAckTimerTimeoutCallback(): void;
waitFlushed
Returns a promise that resolves once all pending summary ops have been acked or nacked.
For more information about our API support guarantees, see here.
Signature
waitFlushed(): Promise<IAckedSummary | undefined>;
Returns
Return type: Promise<IAckedSummary | undefined>
waitSummaryAck
Returns a promise that resolves once a summary is acked that has a reference sequence number greater than or equal to the passed in sequence number.
For more information about our API support guarantees, see here.
Signature
waitSummaryAck(referenceSequenceNumber: number): Promise<IAckedSummary>;
Parameters
| Parameter | Type | Description |
|---|---|---|
| referenceSequenceNumber | number | reference sequence number to wait for |
Returns
The latest acked summary
Return type: Promise<IAckedSummary>