|
|||||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |
Interface Summary | |
DateTimeConstants | Constants related to date and time. |
ODPXMLConstants | Constants for the XML parser. |
StandardColumnNames | Class StandardColumnNames |
StreamingConstants | Constants used by the streaming protocol. |
Class Summary | |
ArchiverInstance | Class is used to provide an Archiving service. |
CleanableInstance | Base class for database (history and latest) producers. |
ConsumerConnection | Details of a single streaming connection to a consumer. |
ConsumerInstance | The "agent" that serves the Consumer. |
ContinuousConsumerInstance | ContinuousConsumerInstances only ever need to contact one publisher in order to answer a query. |
CostModel | Determines the best publisher to contact, given a list. |
CostModelForComplexQuery | Used for figuring out which is the best publisher to contact, given a list. |
CostModelForSimpleQuery | DOCUMENT ME! |
DBConstants | Holds any error codes that are thrown by the MySQL database and are significant to rgma. |
DBProducerInstance | |
DeclarableInstance | Supports "Declarable" behaviour: declaring and registering tables. |
Decoder | used for decoding a PublisherDescription. |
FastStreamProducerInstance | Performs same function as StreamProducerInstance, but uses fast SQL INSERT parsing and new faster/more stable streaming. |
FixedColumn | Class FixedColumn |
InsertableInstance | InsertableInstance. |
InstanceBase | InstanceBase is an object that supports the corresponding APIBase. |
InstanceTracker | InstanceTracker is used to store and track InstanceBase objects. |
LatestProducerInstance | |
Message | Simple wrapper of a servlet connection to make it easier to find and compare messages. |
Messenger | Messages that can't fail can be send by implementations of this. |
MessengerWatcher | Thread to watch fast messenger and reset it if it blocks on a single message for too long. |
ODPXMLParser | Version of XMLConverter that uses SAX parser for increased performance. |
OnDemandProducerInstance | OnDemandProducer. |
OneTimeConsumerInstance | OneTimeConsumerInstances only ever need to contact one publisher in order to answer a query. |
QueryHandler | QueryHandler acts as an interface to parsql, the SQL Parser. |
Queue | |
QueueDiskCache | Circular disk cache for storing tuples. |
QueueEntry | Represents a tuple in a memory queue. |
QueueManager | Contains a queue that holds tuples the Consumer has obtained from its Producers. |
RegistrationThread | RegistrationThread used to update the termination interval for Producer and Consumer instances. |
RegistryInstance | RegistryInstance is an object that supports the RegistryServlet. |
RegistryMediator | Determines which producers are relevant to consumer queries, and which consumers are relevant to newly-registered producers. |
RegistryReplica | Convenient wrapper class that takes a Replica that fits into the Registry db structure and provides assorted accessor methods. |
RemoteDatabase | Encapsulates a remote database. |
Replica | Represents a collection of tables to be replicated. |
ReplicaCreator | Creats Replicas derived from the db. |
ReplicaDecoder | Translates an XML message to the local Registry DB. |
ReplicaEncoder | Convers Replicas to XML. |
ReplicaManager | The ReplicaManager is used to issue and recieve regular updates from neighbouring Registries. |
ReplicaRow | Represents a Row of data to be replicated. |
ReplicaStorer | Stores replicas using the local db. |
ReplicaTable | Represents a table to be replicated with other Registry services. |
ResponseTester | Determines which Publisher from a list has the fastest response. |
RetentionPeriods | |
RetentionPeriodTracker | Class is used with the SP. |
SchemaInstance | SchemaInstance is an object that supports the SchemaServlet. |
SiteFilter | This class is used to allow/deny requests destined to a particular destination. |
SocketUtils | Class SocketUtils |
StatusBuilder | Builds an XML representation of an Object's state using reflection. |
StatusPrinter | Formatter used to create fancy status messages. |
StopStreamingRequest | |
StreamingServer | Handles incoming requests to stream from StreamProducers on behalf of all local ConsumerInstances. |
StreamingThread | Thread that periodically initiates streaming for a single producer. |
TimeoutThread | Thread to keep track of timeouts for consumers. |
TupleChecker | Tuple checker for one table in a producer. |
Exception Summary | |
DiskCacheException | Exception thrown by the QueueDiskCache. |
QueueManagerException | Exception generated by QueueManager. |
|
|||||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |