This library provides a host for distributing change feed events in partitioned collection across multiple observers. Instances of the host can scale up (by adding) or down (by removing) dynamically, and the load will be automatically distributed among active instances in about-equal way.
Other
51
stars
22
forks
source link
Introduce ICheckpointPartitionProcessorFactory allowing to pass default ILeaseCheckpointer #149
This PR introduces the functionality for re-using the default checkpoint mechanism for a custom IPartitionProcessor implementation. It can be used if the custom processor requires continuation tokens to be written in leases.
The proposed changes introduce new ICheckpointPartitionProcessorFactory interface:
IPartitionProcessor Create(ILease lease, ILeaseCheckpointer leaseCheckpointer, IChangeFeedObserver observer)
This PR introduces the functionality for re-using the default checkpoint mechanism for a custom
IPartitionProcessorimplementation. It can be used if the custom processor requires continuation tokens to be written in leases.The proposed changes introduce new
ICheckpointPartitionProcessorFactoryinterface:IPartitionProcessor Create(ILease lease, ILeaseCheckpointer leaseCheckpointer, IChangeFeedObserver observer)