Interface ICheckpointStorageProvider
Represents a checkpoint storage provider.
Namespace: Reaqtor.QueryEngine
Assembly: Reaqtor.QueryEngine.Interfaces.dll
Syntax
public interface ICheckpointStorageProviderMethods
StartNewCheckpoint(String)
Start a new (full) checkpoint with the provided identifier.
Declaration
IStateWriter StartNewCheckpoint(string id)Parameters
| Type | Name | Description |
|---|---|---|
| System.String | id | Identifier for the checkpoint. |
Returns
| Type | Description |
|---|---|
| IStateWriter | A writer which is used to store the state. |
TryReadCheckpoint(out String, out IStateReader)
Read the state contained in the latest full checkpoint. In case of success, the identifier of the checkpoint as well as a reader are provided.
Declaration
bool TryReadCheckpoint(out string id, out IStateReader reader)Parameters
| Type | Name | Description |
|---|---|---|
| System.String | id | Identifier for the checkpoint |
| IStateReader | reader | A reader which is used to extract the state. |
Returns
| Type | Description |
|---|---|
| System.Boolean | true if a full checkpoint is available, false otherwise. |
UpdateCheckpoint(String)
Update the latest full checkpoint and update its identifier. This corresponds to a differential checkpoint.
Declaration
IStateWriter UpdateCheckpoint(string id)Parameters
| Type | Name | Description |
|---|---|---|
| System.String | id | Identifier for the checkpoint |
Returns
| Type | Description |
|---|---|
| IStateWriter | A writer which is used to store the state. |
Remarks
Throws an exception if there is no full checkpoint in the storage provider.