RSB
0.9.6
|
rsb | |
converter | |
BoolConverter | Converter for bool |
ByteArrayConverter | "Converts" arbitrary payloads into a std::string which should be interpreted as an array of bytes |
Converter | |
ConverterSelectionStrategy | Implementation of this interface perform mappings of one of the followings forms: |
EventIdConverter | A converter for EventId |
EventsByScopeMapConverter | A converter for aggregated events ordered by their scope and time for each scope |
Int64Converter | Converter for the int64 type |
ConverterPredicate | Implementations of this interface can be used to perform Converter selection based on predicate evaluation |
AlwaysApplicable | A predicate that unconditionally causes its associated Converter to be selected |
PredicateConverterList | Objects of this class are used to perform Converter selection via a chain-of-responsibility strategy |
ProtocolBufferConverter | A generic converter for data types based on Protocol Buffer messages |
RegexConverterPredicate | Objects of this class select Converter s by matching the query wire-schema or data-type against a sotred reqular expression |
Repository | Maintains a collection of converters for a specific wire format |
RepositoryCreater | An internal factory object to create typed converter repositories |
TypeBasedRepositoryCreater | A RepositoryCreate which can be statically typed using a template argument for the desired wire type |
RosettaConverter | |
SchemaAndByteArrayConverter | "Converts" arbitrary payloads into a pair consisting of the original wire schema and a std::string which should be interpreted as an array of bytes |
SerializationException | An exception indicating a serialization or deserialization problem for data |
StringConverter | Converts any string into any string serializing content to a string |
TypeNameConverterPredicate | Objects of this class select Converter s by matching the query wire-schema or data-type against a stored string |
Uint32Converter | Converter for the uint32 type |
Uint64Converter | Converter for the uint64 type |
UnambiguousConverterMap | Objects this class store mappings of one of the followings forms |
VoidConverter | Fulfill the interface.. |
detail | |
TypeName | |
TypeName< AnyType > | |
eventprocessing | |
DirectEventReceivingStrategy | This push-style event receiving strategy filters and dispatches rsb::Event s in the context of the thread calling handle |
DirectEventSendingStrategy | This event sending strategy just passes incoming events to its associated rsb::transport::OutConnector s without modification, queueing or anything else |
EventReceivingStrategy | Implementations of this interface organize the receiving of events via rsb::transport::InConnector s |
EventSendingStrategy | Implementations of this interface organize the sending of events via rsb::transport::OutConnector s |
Handler | Implementations of this class can be used in contexts where an "event sink" is required |
InRouteConfigurator | A class responsible of configuring the route that processes incoming events from one or more InConnector instances in one Listener |
OutRouteConfigurator | |
ParallelEventReceivingStrategy | This push-style event receiving strategy uses one or more threads to filter rsb::Event s and dispatch matching events to rsb::Handler s |
PullEventReceivingStrategy | Instances of this class retrieve Event s from transport::Connector s when explicitly asked by a client (which usually is a Participant ) |
PullInRouteConfigurator | Objects of this InRouteConfigurator class setup and maintain the required components for a pull-style event receiving configuration |
PushEventReceivingStrategy | This class serves as a base class for event receiving strategy classes that deliver rsb::Event s to rsb::Handler s without triggering by the receiving object |
PushInRouteConfigurator | This specialization of InRouteConfigurator creates and maintains an event receiving setup in which rsb::Event s are delivered using a push-style data flow by invoking registered rsb::Handler s |
filter | |
Filter | A filter filters an event stream by removing unwanted events |
FilterAction | A class to encapsulate enum constants that specify changes of a Filter for FilterObserver instances |
FilterObserver | |
OriginFilter | This filter matches events that originate from a particular participant |
ScopeFilter | |
patterns | |
MethodExistsException | Indicates that a method of a Server already exists |
WaitingEventHandler | |
RemoteServer | The client side of a request-reply-based communication channel |
RequestHandler | |
Server | The server side of a request-reply-based communication channel |
protocol | |
ProtocolException | |
transport | |
inprocess | |
socket | |
Connector | |
ConverterSelectingConnector | This base class enables look up of suitable rsb::converter::Converter s in rsb::transport::Connector classes |
ConnectorFactory | Objects of this class are specialized factories that construct Connector objects and provide introspection for connector implementations without instantiating them |
InConnector | Objects of classes which implement this interface can be used to receive events by means of one transport mechanism |
InPullConnector | Objects of classes which implement this specialized InConnector interface provide the ability to receive events in pull-style manner by means of one transport mechanism |
InPushConnector | Objects of classes which implement this specialized InConnector interface provide the ability to receive events in push-style manner by means of one transport mechanism |
OutConnector | Objects of classes which implement this interface can be used to send events by means of one transport mechanism |
util | |
MD5Hasher | |
MD5 | A simple class representing an md5 sum for a given string |
CommException | General exception thrown upon communication errors |
Event | Basic message that is exchanged between informers and listeners |
Impl | |
EventId | A unique ID for events in RSB |
EventQueuePushHandler | A rsb::Handler for rsb::Listener s that pushes all received events on a rsc::SynchronizedQueue |
Exception | |
Factory | Factory for RSB user-level domain objects for communication patterns |
Handler | Asynchronously called handler interface on the client level |
EventFunctionHandler | A utility class to simplify event handling in ordinary functions or member functions |
DataFunctionHandler | A utility class to simplify data handling by automatically passing the data of the desired type to a function |
DataHandler | A Handler that automatically performs the desired type casting |
FilteringHandler | A utility class that forwards events to another rsb::Handler object if they match a given rsb::filter::Filter |
AnyType | A tag type for constructing Informer instances that can publish data of arbitrary types |
InformerBase | A informer to publish data |
DataPtr | |
Informer | A informer to publish data of a specified type expressed through the template parameter |
Listener | A Listener receives events published by rsb::Informer objects by participating in a channel with a suitable scope |
Impl | |
LocalService | A Service implementation that structures services locally |
MetaData | Framework-supplied meta data attached to each event that give information e.g |
Participant | Objects of this class participate in the exchange of notifications on one channel of the bus |
Impl | |
ParticipantConfig | A class describing the configuration of Participant instances |
EventProcessingStrategy | Instances of this class describe the selection and configuration of an event processing strategy |
Transport | Description of a desired transport |
QualityOfServiceSpec | Specification of desired quality of service settings for sending and receiving events |
QueuePushHandler | A rsb::Handler for rsb::Listener s that pushes all received data on a rsc::SynchronizedQueue |
Reader | A Reader receives events published by a informers by participating in a channel with a suitable scope |
Scope | Scope is a descriptor for a hierarchical channel of the unified bus |
Service | A service provides a hierarchical structure for organizing participants |
UnsupportedQualityOfServiceException | An exception indicating that a desired QualityOfServiceSpec cannot be reached by a transport |