Share via

InMemoryCheckpointManager Class

  • Reference
Package:
com.microsoft.azure.eventprocessorhost
  • java.lang.Object

public class InMemoryCheckpointManager implements ICheckpointManager

Constructor Summary

Constructor Description
InMemoryCheckpointManager()

Method Summary

Modifier and Type Method and Description
CompletableFuture<Boolean> checkpointStoreExists()
CompletableFuture<Void> createAllCheckpointsIfNotExists(List<String> partitionIds)
CompletableFuture<Void> createCheckpointStoreIfNotExists()
CompletableFuture<Void> deleteCheckpoint(String partitionId)
CompletableFuture<Void> deleteCheckpointStore()

Deletes the checkpoint store.
CompletableFuture<Checkpoint> getCheckpoint(String partitionId)
void initialize(HostContext hostContext)
CompletableFuture<Void> updateCheckpoint(CompleteLease lease, Checkpoint checkpoint)

Constructor Details

InMemoryCheckpointManager

public InMemoryCheckpointManager()

Method Details

checkpointStoreExists

public CompletableFuture checkpointStoreExists()

Overrides:

InMemoryCheckpointManager.checkpointStoreExists()

createAllCheckpointsIfNotExists

public CompletableFuture createAllCheckpointsIfNotExists(List partitionIds)

Overrides:

InMemoryCheckpointManager.createAllCheckpointsIfNotExists(List<String> partitionIds)

Parameters:

partitionIds

createCheckpointStoreIfNotExists

public CompletableFuture createCheckpointStoreIfNotExists()

Overrides:

InMemoryCheckpointManager.createCheckpointStoreIfNotExists()

deleteCheckpoint

public CompletableFuture deleteCheckpoint(String partitionId)

Overrides:

InMemoryCheckpointManager.deleteCheckpoint(String partitionId)

Parameters:

partitionId

deleteCheckpointStore

public CompletableFuture deleteCheckpointStore()

Deletes the checkpoint store.

Overrides:

InMemoryCheckpointManager.deleteCheckpointStore()

Returns:

CompletableFuture { ->} null on success, completes exceptionally on error.

getCheckpoint

public CompletableFuture getCheckpoint(String partitionId)

Overrides:

InMemoryCheckpointManager.getCheckpoint(String partitionId)

Parameters:

partitionId

initialize

public void initialize(HostContext hostContext)

Parameters:

hostContext

updateCheckpoint

public CompletableFuture updateCheckpoint(CompleteLease lease, Checkpoint checkpoint)

Overrides:

InMemoryCheckpointManager.updateCheckpoint(CompleteLease lease, Checkpoint checkpoint)

Parameters:

lease
checkpoint

Applies to