|
Public Member Functions |
void | create_schema (const Callback< void, RPC< void > > &completion, Schema schema) |
| Invokes create_schema on the remote server (non-blocking interface).
|
RPC< void > | create_schema (Schema schema) |
| Invokes create_schema on the remote server (blocking interface).
|
void | create_stream (const Callback< void, RPC< void > > &completion, StreamDef streamdef) |
| Invokes create_stream on the remote server (non-blocking interface).
|
RPC< void > | create_stream (StreamDef streamdef) |
| Invokes create_stream on the remote server (blocking interface).
|
void | create_cp (const Callback< void, RPC< void > > &completion, CPViewDescription view_desc, StreamDef streamdef) |
| Invokes create_cp on the remote server (non-blocking interface).
|
RPC< void > | create_cp (CPViewDescription view_desc, StreamDef streamdef) |
| Invokes create_cp on the remote server (blocking interface).
|
void | create_query (const Callback< void, RPC< void > > &completion, Query query) |
| Invokes create_query on the remote server (non-blocking interface).
|
RPC< void > | create_query (Query query) |
| Invokes create_query on the remote server (blocking interface).
|
void | create_query_xml (const Callback< void, RPC< void > > &completion, string query) |
| Invokes create_query_xml on the remote server (non-blocking interface).
|
RPC< void > | create_query_xml (string query) |
| Invokes create_query_xml on the remote server (blocking interface).
|
void | set_query_status (const Callback< void, RPC< void > > &completion, Name name, QueryStatus status) |
| Change query from statuts to one of: stopped, running, or deleted (non-blocking interface) callback is invoked when the result is available.
|
RPC< void > | set_query_status (Name name, QueryStatus status) |
| Change query from statuts to one of: stopped, running, or deleted (blocking interface).
|
void | set_queries_status (const Callback< void, RPC< void > > &completion, vector< Name > name, QueryStatus status) |
| Invokes set_queries_status on the remote server (non-blocking interface).
|
RPC< void > | set_queries_status (vector< Name > name, QueryStatus status) |
| Invokes set_queries_status on the remote server (blocking interface).
|
void | subscribe (const Callback< void, RPC< void > > &completion, Subscription sub, unsigned int add_or_remove) |
| Invokes subscribe on the remote server (non-blocking interface).
|
RPC< void > | subscribe (Subscription sub, unsigned int add_or_remove) |
| Invokes subscribe on the remote server (blocking interface).
|
void | subscribe_many (const Callback< void, RPC< void > > &completion, vector< Subscription > sub, unsigned int add_or_remove) |
| Invokes subscribe_many on the remote server (non-blocking interface).
|
RPC< void > | subscribe_many (vector< Subscription > sub, unsigned int add_or_remove) |
| Invokes subscribe_many on the remote server (blocking interface).
|
void | create_and_start_queries (const Callback< void, RPC< void > > &completion, vector< Query > queries) |
| Invokes create_and_start_queries on the remote server (non-blocking interface).
|
RPC< void > | create_and_start_queries (vector< Query > queries) |
| Invokes create_and_start_queries on the remote server (blocking interface).
|
void | queries_and_subscriptions (const Callback< void, RPC< void > > &completion, vector< Query > queries, vector< Subscription > subs, unsigned int add_or_remove) |
| Invokes queries_and_subscriptions on the remote server (non-blocking interface).
|
RPC< void > | queries_and_subscriptions (vector< Query > queries, vector< Subscription > subs, unsigned int add_or_remove) |
| Invokes queries_and_subscriptions on the remote server (blocking interface).
|
void | move_load (const Callback< void, RPC< void > > &completion, vector< Name > query_names, string partner) |
| Invokes move_load on the remote server (non-blocking interface).
|
RPC< void > | move_load (vector< Name > query_names, string partner) |
| Invokes move_load on the remote server (blocking interface).
|
void | split_query (const Callback< void, RPC< void > > &completion, Name query_hunk_name, map< Name, vector< Name > > boxes_per_hunk) |
| Invokes split_query on the remote server (non-blocking interface).
|
RPC< void > | split_query (Name query_hunk_name, map< Name, vector< Name > > boxes_per_hunk) |
| Invokes split_query on the remote server (blocking interface).
|
void | merge_query (const Callback< void, RPC< void > > &completion, vector< Name > existing_query_hunk_names, Name new_query_hunk_name) |
| Invokes merge_query on the remote server (non-blocking interface).
|
RPC< void > | merge_query (vector< Name > existing_query_hunk_names, Name new_query_hunk_name) |
| Invokes merge_query on the remote server (blocking interface).
|
void | add_stream_observer (const Callback< void, RPC< InputStreamInfo > > &completion) |
| Invokes add_stream_observer on the remote server (non-blocking interface).
|
void | add_query_observer (const Callback< void, RPC< Query > > &completion) |
| Invokes add_query_observer on the remote server (non-blocking interface).
|
void | add_sub_observer (const Callback< void, RPC< vector< Subscription > > > &completion) |
| Invokes add_sub_observer on the remote server (non-blocking interface).
|