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, SubscriptionMap >	Subscriptions
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:

• Admin.h
• Admin.cc

---