| Class | Description |
|---|---|
| Broker |
This class tracks incoming requests from workers to consume Analyst tasks, and attempts to match those
requests to enqueued tasks.
|
| Broker.WrappedResponse |
We wrap responses in a class that has a machine ID, and then put them in a TreeSet so that
the machine with the lowest ID on a given graph always gets single-point work.
|
| BrokerMain | |
| CircularList<T> | |
| Job |
FIXME delivered tasks map is oblivious to multiple tasks having the same ID.
|
| JobStatus |
Describes the status of Job.
|
| QueueType | |
| WorkerCatalog | |
| WorkerObservation |
Copyright © 2018. All rights reserved.