m2etis  0.4
Pubsub

Namespaces

 m2etis
 
 m2etis::pubsub
 
 m2etis::pubsub::filter
 
 m2etis::pubsub::deliver
 
 m2etis::pubsub::order
 
 m2etis::pubsub::partition
 
 m2etis::pubsub::persistence
 
 m2etis::net
 
 m2etis::pubsub::rendezvous
 
 m2etis::pubsub::routing
 
 m2etis::pubsub::security
 
 m2etis::pubsub::validity
 

Classes

class  m2etis::pubsub::Channel< ChannelType, NetworkType, EventType >
 Channel. More...
 
class  m2etis::pubsub::ChannelEventInterface
 ChannelEventInterface. More...
 
struct  m2etis::pubsub::BasicChannelInterface< EventType >
 
class  m2etis::pubsub::ChannelConfiguration
 
struct  m2etis::pubsub::ChannelVector
 
class  m2etis::pubsub::ChannelManager< ChannelNames >
 
class  m2etis::pubsub::ChannelConfigurationImpl
 
class  m2etis::pubsub::ChannelType< RoutingT, FilterT, OrderT, DeliverT, PersistenceT, ValidityT, PartitionT, SecurityT, RendezvousT >
 
struct  m2etis::pubsub::deliver::Comp
 
class  m2etis::pubsub::deliver::AckDeliver< NetworkType, Retries, Multiples >
 
class  m2etis::pubsub::deliver::BaseDeliver< NetworkType >
 
class  m2etis::pubsub::deliver::NackDeliver< NetworkType, Retries, Multiples >
 
class  m2etis::pubsub::deliver::NullDeliver< NetworkType >
 
class  m2etis::pubsub::BasicDeliverCallbackInterface< EventType >
 
struct  m2etis::pubsub::DeliverInfo
 
class  m2etis::pubsub::filter::AttributeAccessor< EventType, AttributeType >
 
class  m2etis::pubsub::filter::AttributeAccessor_Basic
 
class  m2etis::pubsub::filter::AttributeTypeInformation< EventType, NetworkType >
 
class  m2etis::pubsub::filter::BaseFilter< EventType, NetworkType >
 
class  m2etis::pubsub::filter::BruteForceFilter< EventType, NetworkType >
 
class  m2etis::pubsub::filter::AttributeDecisionTreeNode< EventType, NetworkType, AttributeType >
 
class  m2etis::pubsub::filter::DecisionTreeLeaf< EventType, NetworkType >
 
class  m2etis::pubsub::filter::DecisionTreeNode< EventType, NetworkType >
 
class  m2etis::pubsub::filter::DecisionTreeFilter< EventType, NetworkType >
 
struct  m2etis::isSerializable< EventType >
 
struct  m2etis::isSerializable< pubsub::filter::Position >
 
struct  m2etis::isSerializable< std::vector< unsigned char > >
 
class  m2etis::pubsub::filter::Position
 
class  m2etis::pubsub::filter::Book
 
class  m2etis::pubsub::filter::AndExp< EventType >
 
class  m2etis::pubsub::filter::AttributeFilter< EventType, AttributeType >
 
class  m2etis::pubsub::filter::EqualsAttributeFilter< EventType, AttributeType >
 
class  m2etis::pubsub::filter::FalsePredicate< EventType >
 
class  m2etis::pubsub::filter::FilterExp< EventType >
 
struct  std::hash< m2etis::pubsub::filter::FilterExp< EventType > >
 
class  m2etis::pubsub::filter::GreaterThanAttributeFilter< EventType, AttributeType >
 
class  m2etis::pubsub::filter::LessThanAttributeFilter< EventType, AttributeType >
 
class  m2etis::pubsub::filter::NotEqualsAttributeFilter< EventType, AttributeType >
 
class  m2etis::pubsub::filter::OrExp< EventType >
 
class  m2etis::pubsub::filter::Predicate< EventType >
 
class  m2etis::pubsub::filter::TruePredicate< EventType >
 
class  m2etis::pubsub::filter::DecisionTreePreProcessVisitor< EventType, NetworkType >
 
class  m2etis::pubsub::filter::DecisionTreeWalkerVisitor< EventType, NetworkType >
 
class  m2etis::pubsub::filter::FilterVisitor< EventType >
 
class  m2etis::pubsub::filter::GeneralBooleanExpressionsPreProcessVisitor< EventType, NetworkType >
 
class  m2etis::pubsub::filter::GetMinPredicatesVisitor< EventType >
 
class  m2etis::pubsub::filter::MatchVisitor< EventType >
 
class  m2etis::pubsub::filter::VariableAssignmentVisitor< EventType >
 
class  m2etis::pubsub::filter::EqualsPredicateIndex< EventType, AttributeType >
 
class  m2etis::pubsub::filter::GreaterThanPredicateIndex< EventType, AttributeType >
 
class  m2etis::pubsub::filter::LessThanPredicateIndex< EventType, AttributeType >
 
class  m2etis::pubsub::filter::NotEqualsPredicateIndex< EventType, AttributeType >
 
class  m2etis::pubsub::filter::PredicateIdentifierFactory
 
class  m2etis::pubsub::filter::PredicateIndex< EventType >
 
class  m2etis::pubsub::filter::SubscriptionIdentifierFactory
 
class  m2etis::pubsub::filter::GeneralBooleanExpressionsFilter< EventType, NetworkType >
 
class  m2etis::pubsub::filter::NullFilter< EventType, NetworkType >
 
struct  m2etis::pubsub::ForwardInfo
 
class  m2etis::pubsub::MessageBuffer
 
class  m2etis::pubsub::order::BaseOrder< NetworkType >
 This is the interface that should be used for all Order Strategies It specifies all functions that shold be overloaded in every strategy as well as some commonly needed functions. More...
 
struct  m2etis::pubsub::order::DetMergeConfig
 
class  m2etis::pubsub::order::DetMergeOrder< NetworkType, Config >
 Implements the Deterministic Merge Order Strategy. More...
 
class  m2etis::pubsub::order::GMSOrder< NetworkType, Timeout >
 implements the Order Strategy from Garcia-Molina and Spauster The Strategy ensures synchronisation along multiple trees. Doesn't work with RoutingStrategies sending directly Notify messages instead of Published to root, e.g. DirectBroadcastRouting More...
 
class  m2etis::pubsub::order::MTPOrder< NetworkType, Timeout, deli >
 This class implements the MTP Order strategy The root node is used as a fixed sequencer. Every node that wants to send a message, request a sequenzer number (TOKEN) from the sequencer and afterwards sends his message along with this sequence number. More...
 
class  m2etis::pubsub::order::NullOrder< NetworkType >
 This class implements the NullOrder Strategy This Strategy does nothing for ordering. All Messages are forwarded as fast as possible. More...
 
class  m2etis::pubsub::order::RemoveHelper< IDType, KEYType >
 
class  m2etis::pubsub::partition::BasePartition< NetworkType, EventType >
 
class  m2etis::pubsub::partition::BruteForcePartition< NetworkType, EventType >
 
class  m2etis::pubsub::partition::DirectBroadcastPartition< NetworkType, EventType >
 
class  m2etis::pubsub::partition::NullPartition< NetworkType, EventType >
 
class  PartitionFiltersChannel3< EventType >
 
class  m2etis::pubsub::persistence::NullPersistence
 
class  m2etis::pubsub::PubSubSystem
 class for accessing the m2etis pub/sub system. It is the main entry point for the usage of the m2etis networking library. More...
 
class  m2etis::pubsub::PubSubSystemEnvironment
 
class  m2etis::pubsub::rendezvous::BaseRendezvous
 
class  m2etis::pubsub::rendezvous::NullRendezvous
 
class  m2etis::pubsub::routing::BaseRouting< NetworkType >
 
class  m2etis::pubsub::routing::DirectBroadcastRouting< NetworkType >
 creates connections between every single node and sends messages directly, so every node is a root node for its connections doesn't work with GMSOrder because it doesn't use publish messages but notifies directly More...
 
class  m2etis::pubsub::routing::DirectRouting< NetworkType >
 
class  m2etis::pubsub::routing::HierarchicalSpreaditRouting< NetworkType, ChildAmount >
 
class  m2etis::pubsub::routing::ScribeRouting< NetworkType >
 
class  m2etis::pubsub::routing::SpreaditRouting< NetworkType >
 
struct  m2etis::pubsub::Scheduler< ClockUpdater >::Job
 
class  m2etis::pubsub::Scheduler< ClockUpdater >
 
class  m2etis::pubsub::security::NullSecurity
 
class  m2etis::pubsub::Tree< ChannelType, NetworkType, EventType >
 Tree. More...
 
class  m2etis::pubsub::TreeFactory
 TreeFactory builds trees with a unique MessageType. More...
 
class  m2etis::pubsub::validity::BaseValidity
 
class  m2etis::pubsub::validity::NullValidity
 
class  m2etis::pubsub::validity::TimeValidity< MIN, MAX >
 
class  AttributeTypeInformation
 
class  BaseFilter
 
class  DecisionTreeFilter
 
class  DecisionTreePreProcesssVisitor
 
class  GeneralBooleanExpressionsFilter
 

Enumerations

enum  m2etis::pubsub::ControlTarget : uint16_t { m2etis::pubsub::ControlTarget::ROOT, m2etis::pubsub::ControlTarget::ALL, m2etis::pubsub::ControlTarget::SINGLE }
 
enum  m2etis::pubsub::deliver::Amount { m2etis::pubsub::deliver::Amount::EXACTLY_ONCE, m2etis::pubsub::deliver::Amount::AT_MOST_ONCE, m2etis::pubsub::deliver::Amount::AT_LEAST_ONCE }
 
enum  m2etis::pubsub::filter::BaseFilter< EventType, NetworkType >::FilterUnsubscribeInformation { m2etis::pubsub::filter::BaseFilter< EventType, NetworkType >::FORWARDUNSUBSCRIBE, m2etis::pubsub::filter::BaseFilter< EventType, NetworkType >::UNSUBSCRIBEFROMTREE, m2etis::pubsub::filter::BaseFilter< EventType, NetworkType >::CANCELUNSUBSCRIBE }
 
enum  { m2etis::pubsub::filter::BruteForceFilter< EventType, NetworkType >::size }
 
enum  { m2etis::pubsub::filter::DecisionTreeFilter< EventType, NetworkType >::size }
 
enum  m2etis::pubsub::OperatorName { m2etis::pubsub::EQUALS, m2etis::pubsub::NOTEQUALS, m2etis::pubsub::GREATERTHAN, m2etis::pubsub::LESSTHAN }
 
enum  m2etis::pubsub::filter::OperatorName { m2etis::pubsub::filter::EQUALS, m2etis::pubsub::filter::NOTEQUALS, m2etis::pubsub::filter::GREATERTHAN, m2etis::pubsub::filter::LESSTHAN }
 
enum  { m2etis::pubsub::filter::GeneralBooleanExpressionsFilter< EventType, NetworkType >::size }
 
enum  { m2etis::pubsub::filter::NullFilter< EventType, NetworkType >::size }
 
enum  m2etis::pubsub::filter::NullFilter< EventType, NetworkType >::FilterUnsubscribeInformation { m2etis::pubsub::filter::NullFilter< EventType, NetworkType >::FORWARDUNSUBSCRIBE, m2etis::pubsub::filter::NullFilter< EventType, NetworkType >::UNSUBSCRIBEFROMTREE, m2etis::pubsub::filter::NullFilter< EventType, NetworkType >::CANCELUNSUBSCRIBE }
 
enum  m2etis::pubsub::msgProcess : uint16_t { m2etis::pubsub::msgProcess::MSG_NONE, m2etis::pubsub::msgProcess::MSG_PROCESS, m2etis::pubsub::msgProcess::MSG_DELETE, m2etis::pubsub::msgProcess::MSG_PROCESS_AND_DELETE }
 
enum  m2etis::pubsub::order::LateDeliver { m2etis::pubsub::order::LateDeliver::DELIVER, m2etis::pubsub::order::LateDeliver::DROP }
 what to do when recieving an old message after Timeout More...
 
enum  m2etis::pubsub::partition::NullPartition< NetworkType, EventType >::TreeName { m2etis::pubsub::partition::NullPartition< NetworkType, EventType >::ALL }
 
enum  attribute_names {
  POSITION_X, POSITION_Y, POSITION_REGION, BOOK_TITLE,
  BOOK_PRICE, BOOK_CONDITION
}
 
enum  m2etis::pubsub::exceptionEvents {
  m2etis::pubsub::CONNECTION_FAILED, m2etis::pubsub::CONNECTION_CLOSED, m2etis::pubsub::NODEFAILURE, m2etis::pubsub::UNDEFINED,
  m2etis::pubsub::BINDFAILURE
}
 

Detailed Description

Enumeration Type Documentation

template<typename EventType , typename NetworkType >
anonymous enum
Enumerator
size 

Definition at line 52 of file BruteForceFilter.h.

template<typename EventType, typename NetworkType>
anonymous enum
Enumerator
size 

Definition at line 68 of file DecisionTreeFilter.h.

template<typename EventType, typename NetworkType>
anonymous enum
Enumerator
size 

Definition at line 63 of file GeneralBooleanExpressionsFilter.h.

template<typename EventType , typename NetworkType >
anonymous enum
Enumerator
size 

Definition at line 45 of file NullFilter.h.

Enumerator
EXACTLY_ONCE 
AT_MOST_ONCE 
AT_LEAST_ONCE 

Definition at line 34 of file BaseDeliver.h.

Enumerator
POSITION_X 
POSITION_Y 
POSITION_REGION 
BOOK_TITLE 
BOOK_PRICE 
BOOK_CONDITION 

Definition at line 46 of file PartitionFiltersChannel3.h.

enum m2etis::pubsub::ControlTarget : uint16_t
strong
Enumerator
ROOT 
ALL 
SINGLE 

Definition at line 28 of file ControlTargets.h.

Enumerator
CONNECTION_FAILED 
CONNECTION_CLOSED 
NODEFAILURE 
UNDEFINED 
BINDFAILURE 

Definition at line 45 of file PubSubSystem.h.

template<typename EventType , typename NetworkType >
enum m2etis::pubsub::filter::NullFilter::FilterUnsubscribeInformation
Enumerator
FORWARDUNSUBSCRIBE 
UNSUBSCRIBEFROMTREE 
CANCELUNSUBSCRIBE 

Definition at line 48 of file NullFilter.h.

template<typename EventType, typename NetworkType>
enum m2etis::pubsub::filter::BaseFilter::FilterUnsubscribeInformation
Enumerator
FORWARDUNSUBSCRIBE 
UNSUBSCRIBEFROMTREE 
CANCELUNSUBSCRIBE 

Definition at line 55 of file BaseFilter.h.

what to do when recieving an old message after Timeout

Enumerator
DELIVER 
DROP 

Definition at line 46 of file MTPOrder.h.

enum m2etis::pubsub::msgProcess : uint16_t
strong
Enumerator
MSG_NONE 
MSG_PROCESS 
MSG_DELETE 
MSG_PROCESS_AND_DELETE 

Definition at line 28 of file MsgProcess.h.

Enumerator
EQUALS 
NOTEQUALS 
GREATERTHAN 
LESSTHAN 

Definition at line 29 of file PredicateIndex.h.

Enumerator
EQUALS 
NOTEQUALS 
GREATERTHAN 
LESSTHAN 

Definition at line 64 of file FilterPredicate.h.

template<typename NetworkType , typename EventType >
enum m2etis::pubsub::partition::NullPartition::TreeName
Enumerator
ALL 

Definition at line 40 of file NullPartition.h.