ICheckpointManager Interface

Package:

com.microsoft.azure.eventprocessorhost

public interface ICheckpointManager

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)
CompletableFuture<Void>	updateCheckpoint(CompleteLease lease, Checkpoint checkpoint)

Method Details

checkpointStoreExists

public CompletableFuture checkpointStoreExists()

createAllCheckpointsIfNotExists

public CompletableFuture createAllCheckpointsIfNotExists(List partitionIds)

Parameters:

partitionIds

createCheckpointStoreIfNotExists

public CompletableFuture createCheckpointStoreIfNotExists()

deleteCheckpoint

public CompletableFuture deleteCheckpoint(String partitionId)

Parameters:

partitionId

deleteCheckpointStore

public CompletableFuture deleteCheckpointStore()

Deletes the checkpoint store.

Returns:

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

getCheckpoint

public CompletableFuture getCheckpoint(String partitionId)

Parameters:

partitionId

updateCheckpoint

public CompletableFuture updateCheckpoint(CompleteLease lease, Checkpoint checkpoint)

Parameters:

lease

checkpoint