Index
All Classes and Interfaces|All Packages|Constant Field Values
A
- AbstractServiceWithBackgroundCheck - Class in org.apache.sling.discovery.commons.providers.spi.base
-
Base class which implements the concept of a 'BackgroundCheck', a thread that periodically executes a check until that one succeeds.
- AbstractServiceWithBackgroundCheck() - Constructor for class org.apache.sling.discovery.commons.providers.spi.base.AbstractServiceWithBackgroundCheck
- activate() - Method in class org.apache.sling.discovery.commons.providers.spi.base.OakBacklogClusterSyncService
- activate() - Method in class org.apache.sling.discovery.commons.providers.spi.base.SyncTokenService
- activate(BundleContext) - Method in class org.apache.sling.discovery.commons.providers.spi.base.IdMapService
- added() - Method in class org.apache.sling.discovery.commons.InstancesDiff
-
Returns the
InstanceCollection
collection containing theInstanceDescription
instances that are contained in the new collection but not in the old collection. - addHistoryEntry(BaseTopologyView, String) - Method in class org.apache.sling.discovery.commons.providers.spi.base.ClusterSyncHistory
- addInstanceDescription(DefaultInstanceDescription) - Method in class org.apache.sling.discovery.commons.providers.DefaultClusterView
-
Add the given instance to this cluster and set the cluster on the instance (back pointer)
- all(boolean) - Method in class org.apache.sling.discovery.commons.InstancesDiff
-
Returns the
InstanceSet
set containing theInstanceDescription
instances that are contained in either the old or the new collection. - AsyncEvent - Interface in org.apache.sling.discovery.commons.providers.base
-
An AsyncEvent can be enqueued to the AsyncEventSender for later, asynchronous triggering
B
- backgroundCheckRunnable - Variable in class org.apache.sling.discovery.commons.providers.spi.base.AbstractServiceWithBackgroundCheck
- BaseTopologyView - Class in org.apache.sling.discovery.commons.providers
-
Very simple abstract base class for the TopologyView which comes with the 'setNotCurrent()' method - that allows the ViewStateManager to mark a topologyView as no longer current - and the isCurrent() is handled accordingly.
- BaseTopologyView() - Constructor for class org.apache.sling.discovery.commons.providers.BaseTopologyView
- bind(TopologyEventListener) - Method in class org.apache.sling.discovery.commons.providers.base.ViewStateManagerImpl
- bind(TopologyEventListener) - Method in interface org.apache.sling.discovery.commons.providers.ViewStateManager
-
Binds the given eventListener, sending it an INIT event if applicable.
C
- cancelPreviousBackgroundCheck() - Method in class org.apache.sling.discovery.commons.providers.spi.base.AbstractServiceWithBackgroundCheck
-
Cancel the currently ongoing background check if there is any ongoing.
- cancelSync() - Method in class org.apache.sling.discovery.commons.providers.spi.base.ClusterSyncServiceChain
- cancelSync() - Method in class org.apache.sling.discovery.commons.providers.spi.base.OakBacklogClusterSyncService
- cancelSync() - Method in class org.apache.sling.discovery.commons.providers.spi.base.SyncTokenService
- cancelSync() - Method in interface org.apache.sling.discovery.commons.providers.spi.ClusterSyncService
- clearCache() - Method in class org.apache.sling.discovery.commons.providers.spi.base.IdMapService
- clusterSyncHistory - Variable in class org.apache.sling.discovery.commons.providers.spi.base.SyncTokenService
- ClusterSyncHistory - Class in org.apache.sling.discovery.commons.providers.spi.base
- ClusterSyncHistory() - Constructor for class org.apache.sling.discovery.commons.providers.spi.base.ClusterSyncHistory
- ClusterSyncService - Interface in org.apache.sling.discovery.commons.providers.spi
-
The ClusterSyncService can be used to establish strong consistency with the underlying (eventually consistent) repository in use.
- ClusterSyncServiceChain - Class in org.apache.sling.discovery.commons.providers.spi.base
-
Allows chaining of ClusterSyncService, itself implementing the ClusterSyncService interface
- ClusterSyncServiceChain(ClusterSyncService...) - Constructor for class org.apache.sling.discovery.commons.providers.spi.base.ClusterSyncServiceChain
-
Creates a new chain of ClusterSyncService that calls a cascaded sync with the provided ClusterSyncService.
- commonsConfig - Variable in class org.apache.sling.discovery.commons.providers.spi.base.OakBacklogClusterSyncService
- commonsConfig - Variable in class org.apache.sling.discovery.commons.providers.spi.base.SyncTokenService
D
- deactivate() - Method in class org.apache.sling.discovery.commons.providers.spi.base.IdMapService
- DefaultClusterView - Class in org.apache.sling.discovery.commons.providers
-
Default implementation of the ClusterView interface.
- DefaultClusterView(String) - Constructor for class org.apache.sling.discovery.commons.providers.DefaultClusterView
- DefaultInstanceDescription - Class in org.apache.sling.discovery.commons.providers
-
Base implementation for the InstanceDescription interface.
- DefaultInstanceDescription(DefaultClusterView, boolean, boolean, String, Map<String, String>) - Constructor for class org.apache.sling.discovery.commons.providers.DefaultInstanceDescription
- deleteResource(ResourceResolver, String) - Static method in class org.apache.sling.discovery.commons.providers.util.ResourceHelper
- DiscoveryLiteConfig - Interface in org.apache.sling.discovery.commons.providers.spi.base
-
Provides the configuration of a few paths needed by discovery-lite processing services
- DiscoveryLiteDescriptor - Class in org.apache.sling.discovery.commons.providers.spi.base
-
Simplifies access to the underlying JSON-backed oak discovery-lite descriptor
- dispose() - Method in class org.apache.sling.discovery.commons.InitDelayingTopologyEventListener
-
Marks this listener as no longer active - ensures that it doesn't call the delegate via any potentially pending scheduler callback.
E
- equals(Object) - Method in class org.apache.sling.discovery.commons.providers.DefaultClusterView
- equals(Object) - Method in class org.apache.sling.discovery.commons.providers.DefaultInstanceDescription
- equalsIgnoreSyncToken(BaseTopologyView) - Method in class org.apache.sling.discovery.commons.providers.base.ViewStateManagerImpl
-
Checks if the previouesView is equal to the newView, ignoring the syncToken (but only if the newView has partially started instances).
- EventHelper - Class in org.apache.sling.discovery.commons.providers
-
Contains static factory methods for creating TopologyEvents with BaseTopologyView as well as some TopologyEvent related helper methods
- EventHelper() - Constructor for class org.apache.sling.discovery.commons.providers.EventHelper
F
- filterWith(InstanceFilter) - Method in class org.apache.sling.discovery.commons.InstancesDiff.InstanceCollection
-
Filter the instances with a custom
InstanceFilter
filter.
G
- get() - Method in class org.apache.sling.discovery.commons.InstancesDiff.InstanceCollection
-
Return the collection of
InstanceDescription
instances that have not been filtered out. - getActiveIds() - Method in class org.apache.sling.discovery.commons.providers.spi.base.DiscoveryLiteDescriptor
-
Returns the 'active' field of the discovery-lite descriptor
- getClusterSyncHistory() - Method in class org.apache.sling.discovery.commons.providers.spi.base.SyncTokenService
- getClusterSyncServiceIntervalMillis() - Method in interface org.apache.sling.discovery.commons.providers.spi.base.DiscoveryLiteConfig
-
Returns the interval (in milliseconds) to be used when waiting for the sync tokens or id mapping
- getClusterSyncServiceTimeoutMillis() - Method in interface org.apache.sling.discovery.commons.providers.spi.base.DiscoveryLiteConfig
-
Returns the timeout (in milliseconds) to be used when waiting for the sync tokens or id mapping
- getClusterView() - Method in class org.apache.sling.discovery.commons.providers.DefaultInstanceDescription
- getCommonsConfig() - Method in class org.apache.sling.discovery.commons.providers.spi.base.OakBacklogClusterSyncService
- getConsistencyHistory() - Method in class org.apache.sling.discovery.commons.providers.spi.base.OakBacklogClusterSyncService
- getDeactivatingIds() - Method in class org.apache.sling.discovery.commons.providers.spi.base.DiscoveryLiteDescriptor
-
Returns the 'deactivating' field of the discovery-lite descriptor
- getDescriptorFrom(ResourceResolver) - Static method in class org.apache.sling.discovery.commons.providers.spi.base.DiscoveryLiteDescriptor
-
{"seq":8,"final":true,"id":"aae34e9a-b08d-409e-be10-9ff4106e5387","me":4,"active":[4],"deactivating":[],"inactive":[1,2,3]}
- getDescriptorStr() - Method in class org.apache.sling.discovery.commons.providers.spi.base.DiscoveryLiteDescriptor
-
Returns the raw toString of the underlying descriptor
- getId() - Method in class org.apache.sling.discovery.commons.providers.DefaultClusterView
- getIdMapPath() - Method in interface org.apache.sling.discovery.commons.providers.spi.base.DiscoveryLiteConfig
-
Returns the configured path to store the idMap to
- getInstance(String) - Method in class org.apache.sling.discovery.commons.providers.BaseTopologyView
-
Simple getter for a particular slingId
- getInstances() - Method in class org.apache.sling.discovery.commons.providers.DefaultClusterView
- getLeader() - Method in class org.apache.sling.discovery.commons.providers.DefaultClusterView
- getLocalClusterSyncTokenId() - Method in class org.apache.sling.discovery.commons.providers.BaseTopologyView
-
Returns the id that shall be used in the syncToken by the ClusterSyncService.
- getLocalClusterSyncTokenId() - Method in class org.apache.sling.discovery.commons.providers.spi.LocalClusterView
- getLocalInstance() - Method in class org.apache.sling.discovery.commons.providers.DefaultClusterView
-
Returns the local InstanceDescription or null if no local instance is listed
- getMyId() - Method in class org.apache.sling.discovery.commons.providers.spi.base.DiscoveryLiteDescriptor
-
Returns the 'me' field of the discovery-lite descriptor
- getMyId() - Method in class org.apache.sling.discovery.commons.providers.spi.base.IdMapService
- getOrCreateResource(ResourceResolver, String) - Static method in class org.apache.sling.discovery.commons.providers.util.ResourceHelper
- getPartiallyStartedClusterNodeIds() - Method in class org.apache.sling.discovery.commons.providers.spi.LocalClusterView
- getProperties() - Method in class org.apache.sling.discovery.commons.providers.DefaultInstanceDescription
- getPropertiesForLogging(Resource) - Static method in class org.apache.sling.discovery.commons.providers.util.ResourceHelper
-
Compile a string builder containing the properties of a resource - used for logging
- getProperty(String) - Method in class org.apache.sling.discovery.commons.providers.DefaultInstanceDescription
- getResourceResolver() - Method in class org.apache.sling.discovery.commons.providers.spi.base.OakBacklogClusterSyncService
-
Get or create a ResourceResolver
- getResourceResolver() - Method in class org.apache.sling.discovery.commons.providers.spi.base.SyncTokenService
-
Get or create a ResourceResolver
- getSeqNum() - Method in class org.apache.sling.discovery.commons.providers.spi.base.DiscoveryLiteDescriptor
- getSettingsService() - Method in class org.apache.sling.discovery.commons.providers.spi.base.OakBacklogClusterSyncService
- getSlingId() - Method in class org.apache.sling.discovery.commons.providers.DefaultInstanceDescription
- getSyncHistory() - Method in class org.apache.sling.discovery.commons.providers.spi.base.ClusterSyncHistory
- getSyncHistory() - Method in class org.apache.sling.discovery.commons.providers.spi.base.OakBacklogClusterSyncService
- getSyncTokenPath() - Method in interface org.apache.sling.discovery.commons.providers.spi.base.DiscoveryLiteConfig
-
Returns the configured path to store the syncTokens to
- getViewId() - Method in class org.apache.sling.discovery.commons.providers.spi.base.DiscoveryLiteDescriptor
-
Returns the 'id' field of the discovery-lite descriptor
H
- hadPreviousView() - Method in class org.apache.sling.discovery.commons.providers.base.ViewStateManagerImpl
- handleActivated() - Method in class org.apache.sling.discovery.commons.providers.base.ViewStateManagerImpl
- handleActivated() - Method in interface org.apache.sling.discovery.commons.providers.ViewStateManager
-
Handles activation - ie marks this manager as activated thus the TOPOLOGY_INIT event can be sent to already bound listeners and subsequent calls to handleChanging/handleNewView will result in according/appropriate TOPOLOGY_CHANGING/ TOPOLOGY_CHANGED events.
- handleChanging() - Method in class org.apache.sling.discovery.commons.providers.base.ViewStateManagerImpl
- handleChanging() - Method in interface org.apache.sling.discovery.commons.providers.ViewStateManager
-
Handles the fact that some (possibly early) indicator of a change in a topology has been detected and that a new view is being agreed upon (whatever that means, be it voting or similar).
- handleDeactivated() - Method in class org.apache.sling.discovery.commons.providers.base.ViewStateManagerImpl
- handleDeactivated() - Method in interface org.apache.sling.discovery.commons.providers.ViewStateManager
-
Must be called when the corresponding service (typically a DiscoveryService implementation) is deactivated.
- handleNewView(BaseTopologyView) - Method in class org.apache.sling.discovery.commons.providers.base.ViewStateManagerImpl
- handleNewView(BaseTopologyView) - Method in interface org.apache.sling.discovery.commons.providers.ViewStateManager
-
Handles the fact that a new view became true/established and sends out TOPOLOGY_INIT to uninitialized listeners and TOPOLOGY_CHANGED to already initialized listeners (in the latter case, also sends a TOPOLOGY_CHANGING if that has not yet been done)
- handleTopologyEvent(TopologyEvent) - Method in class org.apache.sling.discovery.commons.InitDelayingTopologyEventListener
- hashCode() - Method in class org.apache.sling.discovery.commons.providers.DefaultClusterView
- hashCode() - Method in class org.apache.sling.discovery.commons.providers.DefaultInstanceDescription
- hasPartiallyStartedInstances() - Method in class org.apache.sling.discovery.commons.providers.spi.LocalClusterView
- history - Variable in class org.apache.sling.discovery.commons.providers.spi.base.ClusterSyncHistory
I
- IdMapService - Class in org.apache.sling.discovery.commons.providers.spi.base
-
The IdMapService is responsible for storing a slingId-clusterNodeId pair to the repository and given all other instances in the cluster do the same can map clusterNodeIds to slingIds (or vice-versa)
- IdMapService() - Constructor for class org.apache.sling.discovery.commons.providers.spi.base.IdMapService
- infoOrDebug(String) - Method in class org.apache.sling.discovery.commons.providers.util.LogSilencer
- infoOrDebug(String, String) - Method in class org.apache.sling.discovery.commons.providers.util.LogSilencer
- InitDelayingTopologyEventListener - Class in org.apache.sling.discovery.commons
-
This listener facade applies a 'startup delay' to a topology event handler, that is, it allows to specify a startup time during which any topology events will be queued and processing only starts after this time.
- InitDelayingTopologyEventListener(long, TopologyEventListener) - Constructor for class org.apache.sling.discovery.commons.InitDelayingTopologyEventListener
-
Creates a new init-delaying listener with the given delay, delegate and scheduler.
- InitDelayingTopologyEventListener(long, TopologyEventListener, Scheduler) - Constructor for class org.apache.sling.discovery.commons.InitDelayingTopologyEventListener
-
Deprecated.
- InitDelayingTopologyEventListener(long, TopologyEventListener, Scheduler, Logger) - Constructor for class org.apache.sling.discovery.commons.InitDelayingTopologyEventListener
- InitDelayingTopologyEventListener(long, TopologyEventListener, Logger) - Constructor for class org.apache.sling.discovery.commons.InitDelayingTopologyEventListener
-
Creates a new init-delaying listener with the given delay, delegate, scheduler and optinoal logger.
- installMinEventDelayHandler(DiscoveryService, Scheduler, long) - Method in class org.apache.sling.discovery.commons.providers.base.ViewStateManagerImpl
- installMinEventDelayHandler(DiscoveryService, Scheduler, long) - Method in interface org.apache.sling.discovery.commons.providers.ViewStateManager
-
Installs an optional 'min event delay handler' which, using the given scheduler, delays sending TOPOLOGY_CHANGED event after receiving a handleNewView - with the idea as to limit the number of toggling between view states.
- InstancesDiff - Class in org.apache.sling.discovery.commons
-
The
InstancesDiff
allows to combine and filter two collections ofInstanceDescription
instances, an "old" collection and a "new" collection. - InstancesDiff(Collection<T>, Collection<T>) - Constructor for class org.apache.sling.discovery.commons.InstancesDiff
-
Create a new
InstancesDiff
based on the provided old and newCollection
collections of instances. - InstancesDiff(ClusterView, ClusterView) - Constructor for class org.apache.sling.discovery.commons.InstancesDiff
-
Create a new
InstancesDiff
based on the instances from the old and newClusterView
cluster views provided. - InstancesDiff(TopologyEvent) - Constructor for class org.apache.sling.discovery.commons.InstancesDiff
-
Create a new
InstancesDiff
based on the instances from the old and newTopologyView
topology views contained in theTopologyEvent
event provided. - InstancesDiff(TopologyView, TopologyView) - Constructor for class org.apache.sling.discovery.commons.InstancesDiff
-
Create a new
InstancesDiff
based on the instances from the old and newTopologyView
topology views provided. - InstancesDiff.InstanceCollection - Class in org.apache.sling.discovery.commons
-
The
InstanceCollection
collection allows to filter the instances using a set of custom filter either implementingInstanceFilter
or pre-defined ones. - isCurrent() - Method in class org.apache.sling.discovery.commons.providers.BaseTopologyView
- isFinal() - Method in class org.apache.sling.discovery.commons.providers.spi.base.DiscoveryLiteDescriptor
- isInClusterView(ClusterView) - Method in class org.apache.sling.discovery.commons.InstancesDiff.InstanceCollection
-
Keep only the instances that are contained in the same
ClusterView
cluster view as the one provided. - isInitialized() - Method in class org.apache.sling.discovery.commons.providers.spi.base.IdMapService
- isLeader() - Method in class org.apache.sling.discovery.commons.InstancesDiff.InstanceCollection
-
Keep only the leader instances (see
InstanceDescription.isLeader()
. - isLeader() - Method in class org.apache.sling.discovery.commons.providers.DefaultInstanceDescription
- isLocal() - Method in class org.apache.sling.discovery.commons.InstancesDiff.InstanceCollection
-
Keep only the local instance (see
InstanceDescription.isLocal()
. - isLocal() - Method in class org.apache.sling.discovery.commons.providers.DefaultInstanceDescription
- isNotInClusterView(ClusterView) - Method in class org.apache.sling.discovery.commons.InstancesDiff.InstanceCollection
-
Filter out the instances that are contained in the same
ClusterView
cluster view as the one provided. - isNotLeader() - Method in class org.apache.sling.discovery.commons.InstancesDiff.InstanceCollection
-
Filter out the leader instances (see
InstanceDescription.isLeader()
. - isNotLocal() - Method in class org.apache.sling.discovery.commons.InstancesDiff.InstanceCollection
-
Filter out the local instances (see
InstanceDescription.isLocal()
. - isPartiallyStarted(Integer) - Method in class org.apache.sling.discovery.commons.providers.spi.LocalClusterView
- isValidPropertyName(String) - Static method in class org.apache.sling.discovery.commons.providers.util.PropertyNameHelper
-
SLING-2883 : properly test for valid property names
L
- LocalClusterView - Class in org.apache.sling.discovery.commons.providers.spi
- LocalClusterView(String, String) - Constructor for class org.apache.sling.discovery.commons.providers.spi.LocalClusterView
- lock - Variable in class org.apache.sling.discovery.commons.providers.base.ViewStateManagerImpl
-
The lock object with which all public methods are guarded - to be provided in the constructor.
- logger - Variable in class org.apache.sling.discovery.commons.providers.spi.base.AbstractServiceWithBackgroundCheck
- logger - Variable in class org.apache.sling.discovery.commons.providers.spi.base.ClusterSyncServiceChain
- LogSilencer - Class in org.apache.sling.discovery.commons.providers.util
-
Helper class to help reduce log.info output.
- LogSilencer(Logger) - Constructor for class org.apache.sling.discovery.commons.providers.util.LogSilencer
- LogSilencer(Logger, long) - Constructor for class org.apache.sling.discovery.commons.providers.util.LogSilencer
M
- moveResource(Resource, String) - Static method in class org.apache.sling.discovery.commons.providers.util.ResourceHelper
-
Move resource to given path.
N
- newChangedEvent(BaseTopologyView, BaseTopologyView) - Static method in class org.apache.sling.discovery.commons.providers.EventHelper
-
Simple factory method for creating a TOPOLOGY_CHANGED event with the given old and new views
- newChangingEvent(BaseTopologyView) - Static method in class org.apache.sling.discovery.commons.providers.EventHelper
-
Simple factory method for creating a TOPOLOGY_CHANGING event with the given oldView
- newInitEvent(BaseTopologyView) - Static method in class org.apache.sling.discovery.commons.providers.EventHelper
-
Simple factory method for creating a TOPOLOGY_INIT event with the given newView
- newPropertiesChangedEvent(BaseTopologyView, BaseTopologyView) - Static method in class org.apache.sling.discovery.commons.providers.EventHelper
- newViewStateManager(Lock, ClusterSyncService) - Static method in class org.apache.sling.discovery.commons.providers.base.ViewStateManagerFactory
- NonLocalInstanceDescription - Class in org.apache.sling.discovery.commons.providers
-
InstanceDescription which represents an instance that is explicitly not local, ie isOwn==false.
- NonLocalInstanceDescription(DefaultClusterView, boolean, String, Map<String, String>) - Constructor for class org.apache.sling.discovery.commons.providers.NonLocalInstanceDescription
O
- OAK_DISCOVERYLITE_CLUSTERVIEW - Static variable in class org.apache.sling.discovery.commons.providers.spi.base.DiscoveryLiteDescriptor
-
TODO: avoid hardcoding the constant here but use an Oak constant class instead if possible
- OakBacklogClusterSyncService - Class in org.apache.sling.discovery.commons.providers.spi.base
-
The OakBacklogClusterSyncService will wait until all instances in the local cluster are no longer in any backlog state.
- OakBacklogClusterSyncService() - Constructor for class org.apache.sling.discovery.commons.providers.spi.base.OakBacklogClusterSyncService
- onChange(List<ResourceChange>) - Method in class org.apache.sling.discovery.commons.providers.spi.base.IdMapService
- onlyDiffersInProperties(BaseTopologyView) - Method in class org.apache.sling.discovery.commons.providers.base.ViewStateManagerImpl
- org.apache.sling.discovery.commons - package org.apache.sling.discovery.commons
-
Provides commons utility for users for the Discovery API.
- org.apache.sling.discovery.commons.providers - package org.apache.sling.discovery.commons.providers
-
Provides commons utility for providers of the Discovery API.
- org.apache.sling.discovery.commons.providers.base - package org.apache.sling.discovery.commons.providers.base
-
Provides commons implementations for providers of the Discovery API.
- org.apache.sling.discovery.commons.providers.spi - package org.apache.sling.discovery.commons.providers.spi
-
Provides an SPI for providers, used by discovery.commons.providers.impl
- org.apache.sling.discovery.commons.providers.spi.base - package org.apache.sling.discovery.commons.providers.spi.base
-
Provides default SPI-implementations used by discovery.commons.providers.impl
- org.apache.sling.discovery.commons.providers.util - package org.apache.sling.discovery.commons.providers.util
-
Provides some static helpers for providers of the Discovery API.
P
- PropertyNameHelper - Class in org.apache.sling.discovery.commons.providers.util
- PropertyNameHelper() - Constructor for class org.apache.sling.discovery.commons.providers.util.PropertyNameHelper
R
- removed() - Method in class org.apache.sling.discovery.commons.InstancesDiff
-
Returns the
InstanceCollection
collection containing theInstanceDescription
instances that are contained in the old collection but not in the new collection. - removeInstanceDescription(InstanceDescription) - Method in class org.apache.sling.discovery.commons.providers.DefaultClusterView
-
Removes the given instance from this cluster.
- reset() - Method in class org.apache.sling.discovery.commons.providers.util.LogSilencer
- ResourceHelper - Class in org.apache.sling.discovery.commons.providers.util
-
Some helper methods surrounding resources
- ResourceHelper() - Constructor for class org.apache.sling.discovery.commons.providers.util.ResourceHelper
- resourceResolverFactory - Variable in class org.apache.sling.discovery.commons.providers.spi.base.OakBacklogClusterSyncService
- resourceResolverFactory - Variable in class org.apache.sling.discovery.commons.providers.spi.base.SyncTokenService
- retained(boolean) - Method in class org.apache.sling.discovery.commons.InstancesDiff
-
Returns the
InstanceSet
collection containing theInstanceDescription
instances that are contained in both the old collection and the new collection. - retained(boolean, boolean) - Method in class org.apache.sling.discovery.commons.InstancesDiff
-
Returns the
InstanceCollection
collection containing theInstanceDescription
instances that are contained in both the old and the new collections.
S
- setConsistencyHistory(ClusterSyncHistory) - Method in class org.apache.sling.discovery.commons.providers.spi.base.OakBacklogClusterSyncService
- setConsistencyHistory(ClusterSyncHistory) - Method in class org.apache.sling.discovery.commons.providers.spi.base.SyncTokenService
- setNotCurrent() - Method in class org.apache.sling.discovery.commons.providers.BaseTopologyView
-
Marks this view as no longer current - this typically results in a TOPOLOGY_CHANGING event to be sent.
- setPartiallyStartedClusterNodeIds(Collection<Integer>) - Method in class org.apache.sling.discovery.commons.providers.spi.LocalClusterView
- setProperties(Map<String, String>) - Method in class org.apache.sling.discovery.commons.providers.DefaultInstanceDescription
-
Sets the properties of this instance
- setProperty(String, String) - Method in class org.apache.sling.discovery.commons.providers.DefaultInstanceDescription
-
for testing only!
- settingsService - Variable in class org.apache.sling.discovery.commons.providers.spi.base.OakBacklogClusterSyncService
- settingsService - Variable in class org.apache.sling.discovery.commons.providers.spi.base.SyncTokenService
- slingId - Variable in class org.apache.sling.discovery.commons.providers.spi.base.AbstractServiceWithBackgroundCheck
- startBackgroundCheck(String, AbstractServiceWithBackgroundCheck.BackgroundCheck, Runnable, long, long) - Method in class org.apache.sling.discovery.commons.providers.spi.base.AbstractServiceWithBackgroundCheck
-
Start a new BackgroundCheck in a separate thread, that periodically calls BackgroundCheck.check and upon completion calls the provided callback.run()
- sync(BaseTopologyView, Runnable) - Method in class org.apache.sling.discovery.commons.providers.spi.base.ClusterSyncServiceChain
- sync(BaseTopologyView, Runnable) - Method in class org.apache.sling.discovery.commons.providers.spi.base.OakBacklogClusterSyncService
- sync(BaseTopologyView, Runnable) - Method in class org.apache.sling.discovery.commons.providers.spi.base.SyncTokenService
- sync(BaseTopologyView, Runnable) - Method in interface org.apache.sling.discovery.commons.providers.spi.ClusterSyncService
-
Starts the synchronization process and calls the provided callback upon completion.
- syncToken(BaseTopologyView, Runnable) - Method in class org.apache.sling.discovery.commons.providers.spi.base.SyncTokenService
- SyncTokenService - Class in org.apache.sling.discovery.commons.providers.spi.base
-
Implements the syncToken idea: each instance stores a key-value pair with key=stringId and value=discoveryLiteSequenceNumber under /var/discovery/oak/syncTokens - and then waits until it sees the same token from all other instances in the cluster.
- SyncTokenService() - Constructor for class org.apache.sling.discovery.commons.providers.spi.base.SyncTokenService
T
- testConstructor(DiscoveryLiteConfig, ResourceResolverFactory, SlingSettingsService) - Static method in class org.apache.sling.discovery.commons.providers.spi.base.SyncTokenService
- testConstructor(DiscoveryLiteConfig, IdMapService, SlingSettingsService, ResourceResolverFactory) - Static method in class org.apache.sling.discovery.commons.providers.spi.base.OakBacklogClusterSyncService
-
for testing only!
- testConstructor(DiscoveryLiteConfig, SlingSettingsService, ResourceResolverFactory) - Static method in class org.apache.sling.discovery.commons.providers.spi.base.IdMapService
-
test-only constructor
- testConstructorAndActivate(DiscoveryLiteConfig, ResourceResolverFactory, SlingSettingsService) - Static method in class org.apache.sling.discovery.commons.providers.spi.base.SyncTokenService
- testConstructorAndActivate(DiscoveryLiteConfig, IdMapService, SlingSettingsService, ResourceResolverFactory) - Static method in class org.apache.sling.discovery.commons.providers.spi.base.OakBacklogClusterSyncService
- toShortString() - Method in class org.apache.sling.discovery.commons.providers.BaseTopologyView
- toShortString(TopologyEvent) - Static method in class org.apache.sling.discovery.commons.providers.EventHelper
-
Returns a shorter toString than the default TopologyEvent.toString() which can be rather large and unusable in log files
- toSlingId(int, ResourceResolver) - Method in class org.apache.sling.discovery.commons.providers.spi.base.IdMapService
- toString() - Method in class org.apache.sling.discovery.commons.providers.DefaultClusterView
- toString() - Method in class org.apache.sling.discovery.commons.providers.DefaultInstanceDescription
- toString() - Method in class org.apache.sling.discovery.commons.providers.spi.base.DiscoveryLiteDescriptor
- trigger() - Method in interface org.apache.sling.discovery.commons.providers.base.AsyncEvent
-
As soon as this AsyncEvent is at the front of AsyncEventSender's FIFO queue it will be invoked via this trigger() method.
- triggerBackgroundCheck() - Method in class org.apache.sling.discovery.commons.providers.spi.base.AbstractServiceWithBackgroundCheck
-
for testing only!
U
- unbind(TopologyEventListener) - Method in class org.apache.sling.discovery.commons.providers.base.ViewStateManagerImpl
- unbind(TopologyEventListener) - Method in interface org.apache.sling.discovery.commons.providers.ViewStateManager
-
Unbinds the given eventListener, returning whether or not it was bound at all.
- unchanged(BaseTopologyView) - Method in class org.apache.sling.discovery.commons.providers.base.ViewStateManagerImpl
V
- ViewStateManager - Interface in org.apache.sling.discovery.commons.providers
-
The ViewStateManager is at the core of managing TopologyEventListeners, the 'view state' (changing vs changed) and sending out the appropriate and according TopologyEvents to the registered listeners - depending on the implementation it also supports the ClusterSyncService, which is invoked on handleNewView.
- ViewStateManagerFactory - Class in org.apache.sling.discovery.commons.providers.base
-
Used to create an implementation classes of type ViewStateManager (with the idea to be able to leave the implementation classes as package-protected)
- ViewStateManagerFactory() - Constructor for class org.apache.sling.discovery.commons.providers.base.ViewStateManagerFactory
- ViewStateManagerImpl - Class in org.apache.sling.discovery.commons.providers.base
-
The ViewStateManager is at the core of managing TopologyEventListeners, the 'view state' (changing vs changed) and sending out the appropriate and according TopologyEvents to the registered listeners.
W
- waitForAsyncEvents(long) - Method in class org.apache.sling.discovery.commons.providers.base.ViewStateManagerImpl
- waitForAsyncEvents(long) - Method in interface org.apache.sling.discovery.commons.providers.ViewStateManager
-
for testing only: wait for any potentially queued async events to be delivered before returning.
- waitForInit(long) - Method in class org.apache.sling.discovery.commons.providers.spi.base.IdMapService
-
for testing only
All Classes and Interfaces|All Packages|Constant Field Values
InitDelayingTopologyEventListener(long, TopologyEventListener)