ScheduleManager Class
This class has the following responsibilities: 1. It tracks batches as we process ops and raises "batchBegin" and "batchEnd" events. As part of it, it validates batch correctness (i.e. no system ops in the middle of batch) 2. It creates instance of ScheduleManagerCore that ensures we never start processing ops from batch unless all ops of the batch are in.
Signature
export declare class ScheduleManager
Constructors
| Constructor | Description |
|---|---|
| (constructor)(deltaManager, emitter, logger) | Constructs a new instance of the ScheduleManager class |
Methods
| Method | Return Type | Description |
|---|---|---|
| afterOpProcessing(error, message) | void | |
| beforeOpProcessing(message) | void |
Constructor Details
(constructor)
Constructs a new instance of the ScheduleManager class
Signature
constructor(deltaManager: IDeltaManager<ISequencedDocumentMessage, IDocumentMessage>, emitter: EventEmitter, logger: ITelemetryLogger);
Parameters
| Parameter | Type | Description |
|---|---|---|
| deltaManager | IDeltaManager<ISequencedDocumentMessage, IDocumentMessage> | |
| emitter | EventEmitter | |
| logger | ITelemetryLogger |
Method Details
afterOpProcessing
Signature
afterOpProcessing(error: any | undefined, message: ISequencedDocumentMessage): void;
Parameters
| Parameter | Type | Description |
|---|---|---|
| error | any | undefined | |
| message | ISequencedDocumentMessage |
beforeOpProcessing
Signature
beforeOpProcessing(message: ISequencedDocumentMessage): void;
Parameters
| Parameter | Type | Description |
|---|---|---|
| message | ISequencedDocumentMessage |