|
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 () |