Main Page | Namespace List | Class Hierarchy | Class List | File List | Class Members | File Members

Admin Class Reference

#include <Admin.h>

List of all members.

Public Types

typedef map< Name, ptr< PendingQuery > > PendingQueries
typedef map< Name, ptr< StreamDef > > StreamMap
typedef map< Name, vector<
ptr< StreamDef > > > 
StreamVersionsMap
typedef map< Name, ptr< Query > > LocalQueries
typedef map< Name, ptr< Subscription > > SubscriptionMap
typedef map< Name, SubscriptionMapSubscriptions
typedef map< Name, ptr< CPViewDescription > > CPViewDescriptionMap

Public Member Functions

 Admin (string id)
 ~Admin ()
AsyncRPC< void > create_schema (Schema schema)
AsyncRPC< void > create_stream (StreamDef streamdef)
AsyncRPC< void > create_cp (CPViewDescription view_desc, StreamDef streamdef)
AsyncRPC< void > create_query (Query query)
AsyncRPC< void > create_query_xml (string query)
AsyncRPC< void > set_query_status (Name name, QueryStatus status)
 Change query from statuts to one of: stopped, running, or deleted.
AsyncRPC< void > set_queries_status (vector< Name > name, QueryStatus status)
 Set the status of a bunch of local queries at once.
AsyncRPC< void > subscribe (Subscription sub, unsigned int add_or_remove)
AsyncRPC< void > subscribe_many (vector< Subscription > sub, unsigned int add_or_remove)
 Only supporting multiple simultaneous subscriptions to local streams.
AsyncRPC< void > create_and_start_queries (vector< Query > queries)
AsyncRPC< void > queries_and_subscriptions (vector< Query > queries, vector< Subscription > subs, unsigned int add_or_remove)
AsyncRPC< void > move_load (vector< Name > query_names, string partner)
 Moving load: step 1 preparing queries and subscriptions.
AsyncRPC< void > split_query (Name query_hunk_name, map< Name, vector< Name > > boxes_per_hunk)
 Split a query hunk: Can only split query hunks that are not running locally.
AsyncRPC< void > merge_query (vector< Name > existing_query_hunk_names, Name new_query_hunk_name)
 Merge existing query hunks.
MultiRPC< InputStreamInfo > add_stream_observer ()
 Observer design pattern.
MultiRPC< Query > add_query_observer ()
MultiRPC< vector< Subscription > > add_sub_observer ()
 NMSTL_RPC_OBJECT (Admin)

Protected Member Functions

void in_thread_init ()


Member Typedef Documentation

typedef map<Name, ptr<CPViewDescription> > Admin::CPViewDescriptionMap
 

typedef map<Name, ptr<Query> > Admin::LocalQueries
 

typedef map<Name, ptr<PendingQuery> > Admin::PendingQueries
 

typedef map<Name, ptr<StreamDef> > Admin::StreamMap
 

typedef map<Name, vector< ptr<StreamDef> > > Admin::StreamVersionsMap
 

typedef map<Name, ptr<Subscription> > Admin::SubscriptionMap
 

typedef map<Name, SubscriptionMap > Admin::Subscriptions
 


Constructor & Destructor Documentation

Admin::Admin string  id  ) 
 

Admin::~Admin  ) 
 


Member Function Documentation

MultiRPC< Query > Admin::add_query_observer  ) 
 

MultiRPC< InputStreamInfo > Admin::add_stream_observer  ) 
 

Observer design pattern.

The Admin is an observable module. Other components can register as observers. They will then be notified everytime the state of the Admin changes. Currently, obervers are notified every time the node subscribes to a new input stream. The notification is a reply to this original method call.

Returns:
a new or changed stream definition for an input stream

MultiRPC< vector< Subscription > > Admin::add_sub_observer  ) 
 

AsyncRPC< void > Admin::create_and_start_queries vector< Query >  queries  ) 
 

AsyncRPC< void > Admin::create_cp CPViewDescription  view_desc,
StreamDef  streamdef
 

AsyncRPC< void > Admin::create_query Query  query  ) 
 

AsyncRPC< void > Admin::create_query_xml string  query  ) 
 

AsyncRPC< void > Admin::create_schema Schema  schema  ) 
 

AsyncRPC< void > Admin::create_stream StreamDef  streamdef  ) 
 

void Admin::in_thread_init  )  [protected]
 

AsyncRPC< void > Admin::merge_query vector< Name >  existing_query_hunk_names,
Name  new_query_hunk_name
 

Merge existing query hunks.

AsyncRPC< void > Admin::move_load vector< Name >  query_names,
string  partner
 

Moving load: step 1 preparing queries and subscriptions.

Admin::NMSTL_RPC_OBJECT Admin   ) 
 

AsyncRPC< void > Admin::queries_and_subscriptions vector< Query >  queries,
vector< Subscription >  subs,
unsigned int  add_or_remove
 

AsyncRPC< void > Admin::set_queries_status vector< Name >  name,
QueryStatus  status
 

Set the status of a bunch of local queries at once.

AsyncRPC< void > Admin::set_query_status Name  name,
QueryStatus  status
 

Change query from statuts to one of: stopped, running, or deleted.

AsyncRPC< void > Admin::split_query Name  query_hunk_name,
map< Name, vector< Name > >  boxes_per_hunk
 

Split a query hunk: Can only split query hunks that are not running locally.

AsyncRPC< void > Admin::subscribe Subscription  sub,
unsigned int  add_or_remove
 

AsyncRPC< void > Admin::subscribe_many vector< Subscription >  sub,
unsigned int  add_or_remove
 

Only supporting multiple simultaneous subscriptions to local streams.


The documentation for this class was generated from the following files:
Generated on Fri Nov 12 15:15:23 2004 for Borealis by doxygen 1.3.8