Uses of Class
emissary.directory.DirectoryEntry
-
Packages that use DirectoryEntry Package Description emissary.client.response Provides client response objects for interacting with Emissary over HTTP/HTTPSemissary.core Provides classes necessary for the core data structures in Emissary.emissary.directory The Emissary Directory controls the advertisement and availability of services (places) in the Emissary system.emissary.place Places are for identifying, processing, transforming, and analyzing data of interest.emissary.pool Pooling and spooling to provide resource bounds and management for the nodes in the system.emissary.server.mvc Provides classes that create Emissary HTTP/HTTPS endpoints that return viewsemissary.server.mvc.adapters Provides classes to adapt calls to HTTP/HTTPS -
-
Uses of DirectoryEntry in emissary.client.response
Methods in emissary.client.response that return DirectoryEntry Modifier and Type Method Description DirectoryEntry
Directory. getDirectoryEntry()
Methods in emissary.client.response with parameters of type DirectoryEntry Modifier and Type Method Description void
Directory. setDirectoryEntry(DirectoryEntry directoryEntry)
Constructors in emissary.client.response with parameters of type DirectoryEntry Constructor Description Directory(DirectoryEntry directoryEntry)
-
Uses of DirectoryEntry in emissary.core
Fields in emissary.core with type parameters of type DirectoryEntry Modifier and Type Field Description protected Deque<DirectoryEntry>
MobileAgent. nextKeyQueue
Methods in emissary.core that return DirectoryEntry Modifier and Type Method Description DirectoryEntry[]
IMobileAgent. getItineraryQueueItems()
Retreive the current list of stored itinerary stepsDirectoryEntry[]
MobileAgent. getItineraryQueueItems()
Provide access to the itinerary queue for the MoveAdapterDirectoryEntry
BaseDataObject. getLastPlaceVisited()
DirectoryEntry
IBaseDataObject. getLastPlaceVisited()
Return an SDE based on the last item in the transform history or null if emptyprotected DirectoryEntry
MobileAgent. getNextKey(IServiceProviderPlace place, IBaseDataObject payloadArg)
Get the next key from the directory with error handling Can return null if there is no place to handle the formDirectoryEntry
BaseDataObject. getPenultimatePlaceVisited()
DirectoryEntry
IBaseDataObject. getPenultimatePlaceVisited()
Return an SDE based on the penultimate item in the transform history or null if emptyprotected DirectoryEntry
MobileAgent. nextKeyFromDirectory(String dataId, IServiceProviderPlace place, DirectoryEntry lastEntry, IBaseDataObject payloadArg)
Communicate with the directory through the current place to get the next place to go.Methods in emissary.core with parameters of type DirectoryEntry Modifier and Type Method Description protected DirectoryEntry
MobileAgent. nextKeyFromDirectory(String dataId, IServiceProviderPlace place, DirectoryEntry lastEntry, IBaseDataObject payloadArg)
Communicate with the directory through the current place to get the next place to go.protected void
HDMobileAgent. recordHistory(DirectoryEntry placeEntry, List<IBaseDataObject> payloadListArg)
Record history for a bunch of payload objects (IBaseDataObject)protected void
MobileAgent. recordHistory(DirectoryEntry placeEntry, IBaseDataObject payloadArg)
Record the processing history in the data objectMethod parameters in emissary.core with type arguments of type DirectoryEntry Modifier and Type Method Description void
HDMobileAgent. arrive(Object payload, IServiceProviderPlace arrivalPlace, int moveErrorCount, List<DirectoryEntry> queuedItineraryItems)
The arrive method that takes in a list of payloads arriving on the new machinevoid
IMobileAgent. arrive(Object payload, IServiceProviderPlace arrivalPlace, int mec, List<DirectoryEntry> iq)
Arriving payload assigned to an agent for process at arrivalPlacevoid
MobileAgent. arrive(Object dataObject, IServiceProviderPlace arrivalPlaceArg, int moveErrorCount, List<DirectoryEntry> queuedItineraryItems)
This is for an already in process agent arriving at a new place from a "moveTo". -
Uses of DirectoryEntry in emissary.directory
Fields in emissary.directory with type parameters of type DirectoryEntry Modifier and Type Field Description protected Set<DirectoryEntry>
DirectoryPlace. peerDirectories
Peer directories to this oneMethods in emissary.directory that return DirectoryEntry Modifier and Type Method Description static DirectoryEntry
DirectoryEntry. fromXml(org.jdom2.Element e)
Build an entry from the supplied xml fragmentDirectoryEntry
DirectoryEntryList. getEntry(int i)
Get entry at specified positionDirectoryEntry
DirectoryEntryList. pickOneOf(int desiredExpense)
Pick one of any that are tied for expense at randomDirectoryEntry
DirectoryEntryMap. removeEntry(String entryKey)
Remove a directory entry from the mapprotected DirectoryEntry
DirectoryEntryMap. removeEntry(String key, String entryKey)
Remove the directory entry specified by entry key from the list specified by keyMethods in emissary.directory that return types with arguments of type DirectoryEntry Modifier and Type Method Description List<DirectoryEntry>
DirectoryEntryMap. allEntries()
Builds a super list of all the entries currently in all buckets of the mapList<DirectoryEntry>
DirectoryEntryMap. collectAllMatching(String key)
Collect all entries that match the key returning them as a listList<DirectoryEntry>
DirectoryEntryMap. collectAllOnDirectory(String key)
Find all entries on a directorystatic List<DirectoryEntry>
DirectoryEntryList. deepCopy(List<DirectoryEntry> that, boolean sort)
Utility method to make a deep copy of a List<DirectoryEntry>List<DirectoryEntry>
DirectoryPlace. getEntries()
Make directory contents available for debug or display and analysisList<DirectoryEntry>
IDirectoryPlace. getEntries()
Make directory contents available for debug or display and analysisList<DirectoryEntry>
DirectoryPlace. getMatchingEntries(String pattern)
Get list of DirectoryEntry that match the key patternList<DirectoryEntry>
IDirectoryPlace. getMatchingEntries(String pattern)
Get list of DirectoryEntry that match the key patternList<DirectoryEntry>
DirectoryPlace. nextKeys(String dataId, IBaseDataObject payload, DirectoryEntry lastPlace)
Called by mobile agent to get a destination for a payloadprotected List<DirectoryEntry>
DirectoryPlace. nextKeys(String dataId, IBaseDataObject payload, DirectoryEntry lastPlace, DirectoryEntryMap entries)
Get tne next logical entry based on current dataId and last place visitedList<DirectoryEntry>
DirectoryEntryMap. removeAllMatching(String key)
Remove all entries that match the key returning them as a listList<DirectoryEntry>
DirectoryEntryMap. removeAllMatching(String key, long checkpoint)
Remove all entries that match the key returning them as a listList<DirectoryEntry>
DirectoryEntryMap. removeAllOnDirectory(String key)
Find and remove all entries on a directoryList<DirectoryEntry>
DirectoryEntryMap. removeAllOnDirectory(String key, long checkpoint)
Find and remove all entries on a directoryMethods in emissary.directory with parameters of type DirectoryEntry Modifier and Type Method Description boolean
DirectoryEntryList. add(DirectoryEntry o)
Add a new DirectoryEntryvoid
DirectoryEntryMap. addEntry(DirectoryEntry d)
Add a directory entry to the appropriate DirectoryEntryList If it is a duplicate entry in all parts except cost, only the lowest cost entry is kept.protected void
DirectoryEntryMap. addEntry(String key, DirectoryEntry d)
Add the directory entry to the specified listprotected void
DirectoryPlace. addEntry(DirectoryEntry newEntry)
Add an entry to the directory Entries are kept in a Hash by "datatype::serviceType" Each entry is a List of sorted DirectoryEntries sorted order on cost and then quality, held in a DirectoryEntryList objectint
DirectoryEntryComparator. compare(DirectoryEntry d1, DirectoryEntry d2)
protected void
DirectoryPlace. deregisterFrom(DirectoryEntry dir, List<String> keys, boolean propagating)
Private helper to deregister entry from directoriesprotected void
DirectoryPlace. handleEntryRefresh(DirectoryEntry entry)
boolean
DirectoryEntry. isBetterThan(DirectoryEntry that)
Used to order directory entries.List<DirectoryEntry>
DirectoryPlace. nextKeys(String dataId, IBaseDataObject payload, DirectoryEntry lastPlace)
Called by mobile agent to get a destination for a payloadprotected List<DirectoryEntry>
DirectoryPlace. nextKeys(String dataId, IBaseDataObject payload, DirectoryEntry lastPlace, DirectoryEntryMap entries)
Get tne next logical entry based on current dataId and last place visitedprotected void
DirectoryPlace. registerWith(DirectoryEntry dir, List<DirectoryEntry> entryList, boolean propagating)
Private helper to register directories.protected void
DirectoryPlace. sendFailMessage(DirectoryEntry directory, String failKey, boolean permanent)
Send directory failure message to another directoryMethod parameters in emissary.directory with type arguments of type DirectoryEntry Modifier and Type Method Description boolean
DirectoryEntryList. addAll(Collection<? extends DirectoryEntry> c)
Add entries from a collection.void
DirectoryEntryMap. addEntries(List<DirectoryEntry> entryList)
Merge new entries in our local entry mapprotected void
DirectoryPlace. addEntries(List<DirectoryEntry> entryList)
Add a list of entries to the directory Entries are kept in a Hash by "datatype::serviceType" Each entry is a List of sorted DirectoryEntries sorted order on cost and then quality, held in a DirectoryEntryList objectstatic List<DirectoryEntry>
DirectoryEntryList. deepCopy(List<DirectoryEntry> that, boolean sort)
Utility method to make a deep copy of a List<DirectoryEntry>void
DirectoryPlace. irdAddPlaces(List<DirectoryEntry> entryList, boolean propagating)
Register a list of entries.void
IRemoteDirectory. irdAddPlaces(List<DirectoryEntry> entryList, boolean propagating)
Register a set of entries.void
DirectoryAdapter. peerUpdate(String observableKey, Set<DirectoryEntry> peers)
Called when the peer group changesvoid
DirectoryObserverManager. peerUpdate(Set<DirectoryEntry> peers)
Notify all peer observers of peer list changevoid
PeerObserver. peerUpdate(String observableKey, Set<DirectoryEntry> peers)
Called when the peer group changesvoid
DirectoryObserverManager. placeAddEntries(List<DirectoryEntry> placeEntries)
Notify all matching place observers of place addsvoid
DirectoryObserverManager. placeCostChangeEntries(List<DirectoryEntry> placeEntries)
Notify all matching place observers of place cost changesvoid
DirectoryObserverManager. placeRemoveEntries(List<DirectoryEntry> placeEntries)
Notify all matching place observers of place removesprotected void
DirectoryPlace. registerWith(DirectoryEntry dir, List<DirectoryEntry> entryList, boolean propagating)
Private helper to register directories.Constructors in emissary.directory with parameters of type DirectoryEntry Constructor Description DirectoryEntry(DirectoryEntry that)
Copy constructor -
Uses of DirectoryEntry in emissary.place
Methods in emissary.place that return DirectoryEntry Modifier and Type Method Description DirectoryEntry
IServiceProviderPlace. getDirectoryEntry()
Return an entry representing this place in the directoryDirectoryEntry
ServiceProviderPlace. getDirectoryEntry()
Return an encapsulation of our key and cost structure Only good for the top key on the listMethods in emissary.place that return types with arguments of type DirectoryEntry Modifier and Type Method Description List<DirectoryEntry>
IServiceProviderPlace. nextKeys(String dataId, IBaseDataObject payload, DirectoryEntry lastPlace)
Return list of next places to go with data.List<DirectoryEntry>
ServiceProviderPlace. nextKeys(String dataId, IBaseDataObject payload, DirectoryEntry lastEntry)
Delegate nextKey to our directoryMethods in emissary.place with parameters of type DirectoryEntry Modifier and Type Method Description List<DirectoryEntry>
IServiceProviderPlace. nextKeys(String dataId, IBaseDataObject payload, DirectoryEntry lastPlace)
Return list of next places to go with data.List<DirectoryEntry>
ServiceProviderPlace. nextKeys(String dataId, IBaseDataObject payload, DirectoryEntry lastEntry)
Delegate nextKey to our directory -
Uses of DirectoryEntry in emissary.pool
Methods in emissary.pool that return types with arguments of type DirectoryEntry Modifier and Type Method Description List<DirectoryEntry>
MoveSpool.SpoolItem. getItineraryItems()
Get the list of itinerary itemsMethod parameters in emissary.pool with type arguments of type DirectoryEntry Modifier and Type Method Description int
MoveSpool. arrive(Object payload, IServiceProviderPlace place, int errorCount, List<DirectoryEntry> itineraryItems)
Add an arriving payload and associated state transfer info to the spool Calls MobileAgent.arrive in this caseprotected int
MoveSpool. enqueue(MoveSpool.Method method, Object payload, IServiceProviderPlace place, int errorCount, List<DirectoryEntry> itineraryItems)
Add an item to the spool.static boolean
PayloadLauncher. launch(Object payload, IServiceProviderPlace place, int errorCount, List<DirectoryEntry> itineraryItems)
Constructor parameters in emissary.pool with type arguments of type DirectoryEntry Constructor Description SpoolItem(MoveSpool.Method method, Object payload, IServiceProviderPlace place, int errorCount, List<DirectoryEntry> itineraryItems)
-
Uses of DirectoryEntry in emissary.server.mvc
Constructors in emissary.server.mvc with parameters of type DirectoryEntry Constructor Description DirectoryEntryInfo(String stripe, DirectoryEntry entry, long now)
-
Uses of DirectoryEntry in emissary.server.mvc.adapters
Method parameters in emissary.server.mvc.adapters with type arguments of type DirectoryEntry Modifier and Type Method Description EmissaryResponse
DirectoryAdapter. outboundAddPlaces(String parentDirectory, List<DirectoryEntry> entryList, boolean propagating)
Handle the packaging and sending of an addPlaces call to a remote directory.
-