public interface AnnouncementRegistry
Modifier and Type | Method and Description |
---|---|
void |
addAllExcept(Announcement target,
ClusterView localClusterView,
AnnouncementFilter filter)
Add all registered announcements to the given target announcement that are accepted by the given filter
|
void |
checkExpiredAnnouncements()
Check for expired announcements and remove any if applicable
|
boolean |
hasActiveAnnouncement(java.lang.String ownerId)
Whether or not the given owner has an active (ie not expired) announcement registered
|
java.util.Collection<Announcement> |
listAnnouncementsInSameCluster(ClusterView localClusterView)
list all announcements that were received by instances in the local cluster
|
java.util.Collection<InstanceDescription> |
listInstances(ClusterView localClusterView)
Returns the list of instances contained in all non-expired announcements of this registry
|
java.util.Collection<Announcement> |
listLocalAnnouncements()
list all announcements that were received (incoming or inherited) by this instance
|
java.util.Collection<CachedAnnouncement> |
listLocalIncomingAnnouncements()
list all announcements that this instance received (incoming)
|
long |
registerAnnouncement(Announcement topologyAnnouncement)
Register the given announcement - and returns the backoff interval (in seconds)
for stable connectors
- or -1 if the registration was not successful (likely indicating a loop)
|
void |
unregisterAnnouncement(java.lang.String ownerId)
Unregister the announcement owned by the given slingId
|
long registerAnnouncement(Announcement topologyAnnouncement)
java.util.Collection<Announcement> listAnnouncementsInSameCluster(ClusterView localClusterView)
java.util.Collection<Announcement> listLocalAnnouncements()
java.util.Collection<CachedAnnouncement> listLocalIncomingAnnouncements()
void checkExpiredAnnouncements()
java.util.Collection<InstanceDescription> listInstances(ClusterView localClusterView)
void addAllExcept(Announcement target, ClusterView localClusterView, AnnouncementFilter filter)
void unregisterAnnouncement(java.lang.String ownerId)
boolean hasActiveAnnouncement(java.lang.String ownerId)
Copyright © 2022 The Apache Software Foundation. All rights reserved.