public interface ClusterSyncService
The issue is described in length in SLING-4627 - the short version is composed of two different factors:
Modifier and Type | Method and Description |
---|---|
void |
cancelSync() |
void |
sync(BaseTopologyView view,
java.lang.Runnable callback)
Starts the synchronization process and calls the provided
callback upon completion.
|
void sync(BaseTopologyView view, java.lang.Runnable callback)
sync() is not thread-safe and should not be invoked concurrently.
If sync() gets called before a previous invocation finished, that previous invocation will be discarded, ie the callback of the previous invocation will no longer be called.
The synchronization process consists of making sure that the repository has processed any potential backlog of instances that are no longer part of the provided, new view. Plus it writes a 'sync-token' to a well-defined location, with all peers doing the same, and upon seeing all other sync-tokens declares successful completion - at which point it calls the callback.run().
view
- the view which all instances in the local cluster
should agree on having seencallback
- the runnable which should be called after
successful syncingvoid cancelSync()
Copyright © 2022 The Apache Software Foundation. All rights reserved.