Package org.edg.info

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.