ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.discardExistingLeases(boolean discardExistingLeases) |
Sets a value indicating whether on start of the host all existing leases should be deleted and the host
should start from scratch.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.feedPollDelay(Duration feedPollDelay) |
Sets the delay in between polling a partition for new changes on the feed, after all current changes are drained.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.leaseAcquireInterval(Duration leaseAcquireInterval) |
Sets he interval to kick off a task to compute if partitions are distributed evenly among known host instances.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.leaseExpirationInterval(Duration leaseExpirationInterval) |
Sets the interval for which the lease is taken on a lease representing a partition.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.leasePrefix(String leasePrefix) |
Sets a prefix to be used as part of the lease ID.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.leaseRenewInterval(Duration leaseRenewInterval) |
Sets the renew interval for all leases for partitions currently held by ChangeFeedProcessor instance. |
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.maxItemCount(int maxItemCount) |
Sets the maximum number of items to be returned in the enumeration operation.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.maxScaleCount(int maxScaleCount) |
Sets the maximum number of partitions the host can serve.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.minScaleCount(int minScaleCount) |
Sets the minimum partition count for the host.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.startContinuation(String startContinuation) |
Sets the start request continuation token to start looking for changes after.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.startFromBeginning(boolean startFromBeginning) |
Sets a value indicating whether change feed in the Azure Cosmos DB service should start from beginning.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.startTime(OffsetDateTime startTime) |
Sets the time (exclusive) to start looking for changes after (UTC time).
|