ack(const Callback< void, RPC< void > > &completion, MedusaID node, StreamID id, string last_tuple) | Remote< Borealis::QueryProcessor > | |
ack(MedusaID node, StreamID id, string last_tuple) | Remote< Borealis::QueryProcessor > | |
checkpoint(const Callback< void, RPC< void > > &completion, vector< StreamEvent > tuples_to_checkpoint, map< StreamID, string > tuples_to_trim) | Remote< Borealis::QueryProcessor > | |
checkpoint(vector< StreamEvent > tuples_to_checkpoint, map< StreamID, string > tuples_to_trim) | Remote< Borealis::QueryProcessor > | |
choke_queries(const Callback< void, RPC< vector< Query > > > &completion, vector< Query > queries) | Remote< Borealis::QueryProcessor > | |
choke_queries(vector< Query > queries) | Remote< Borealis::QueryProcessor > | |
create_cpview(const Callback< void, RPC< void > > &completion, CPViewDescription view_desc, StreamDef streamdef) | Remote< Borealis::QueryProcessor > | |
create_cpview(CPViewDescription view_desc, StreamDef streamdef) | Remote< Borealis::QueryProcessor > | |
create_stream(const Callback< void, RPC< void > > &completion, StreamDef stream) | Remote< Borealis::QueryProcessor > | |
create_stream(StreamDef stream) | Remote< Borealis::QueryProcessor > | |
get_sel(const Callback< void, RPC< double > > &completion) | Remote< Borealis::QueryProcessor > | |
get_sel() | Remote< Borealis::QueryProcessor > | |
get_stats(const Callback< void, RPC< vector< Stats > > > &completion) | Remote< Borealis::QueryProcessor > | |
get_stats() | Remote< Borealis::QueryProcessor > | |
get_subscriptions(const Callback< void, RPC< vector< Subscription > > > &completion, vector< Name > streams) | Remote< Borealis::QueryProcessor > | |
get_subscriptions(vector< Name > streams) | Remote< Borealis::QueryProcessor > | |
load_box(const Callback< void, RPC< void > > &completion, string file_path) | Remote< Borealis::QueryProcessor > | |
load_box(string file_path) | Remote< Borealis::QueryProcessor > | |
pack_queries(const Callback< void, RPC< vector< Query > > > &completion, vector< Query > queries) | Remote< Borealis::QueryProcessor > | |
pack_queries(vector< Query > queries) | Remote< Borealis::QueryProcessor > | |
pack_query(const Callback< void, RPC< Query > > &completion, Query query) | Remote< Borealis::QueryProcessor > | |
pack_query(Query query) | Remote< Borealis::QueryProcessor > | |
remove_query(const Callback< void, RPC< void > > &completion, Query query) | Remote< Borealis::QueryProcessor > | |
remove_query(Query query) | Remote< Borealis::QueryProcessor > | |
replace_query(const Callback< void, RPC< void > > &completion, vector< Name > old_queries, vector< Query > new_queries) | Remote< Borealis::QueryProcessor > | |
replace_query(vector< Name > old_queries, vector< Query > new_queries) | Remote< Borealis::QueryProcessor > | |
resume_queries(const Callback< void, RPC< void > > &completion, vector< Query > queries) | Remote< Borealis::QueryProcessor > | |
resume_queries(vector< Query > queries) | Remote< Borealis::QueryProcessor > | |
set_primary_status(const Callback< void, RPC< void > > &completion, bool status) | Remote< Borealis::QueryProcessor > | |
set_primary_status(bool status) | Remote< Borealis::QueryProcessor > | |
set_queries_status(const Callback< void, RPC< void > > &completion, vector< Name > name, QueryStatus status) | Remote< Borealis::QueryProcessor > | |
set_queries_status(vector< Name > name, QueryStatus status) | Remote< Borealis::QueryProcessor > | |
set_query_status(const Callback< void, RPC< void > > &completion, Name name, QueryStatus status) | Remote< Borealis::QueryProcessor > | |
set_query_status(Name name, QueryStatus status) | Remote< Borealis::QueryProcessor > | |
set_recovery_method(const Callback< void, RPC< void > > &completion, int method) | Remote< Borealis::QueryProcessor > | |
set_recovery_method(int method) | Remote< Borealis::QueryProcessor > | |
set_replicas(const Callback< void, RPC< void > > &completion, vector< MedusaID > replicas) | Remote< Borealis::QueryProcessor > | |
set_replicas(vector< MedusaID > replicas) | Remote< Borealis::QueryProcessor > | |
set_secondaries(const Callback< void, RPC< void > > &completion, vector< MedusaID > secondaries) | Remote< Borealis::QueryProcessor > | |
set_secondaries(vector< MedusaID > secondaries) | Remote< Borealis::QueryProcessor > | |
setup_query(const Callback< void, RPC< void > > &completion, Query query) | Remote< Borealis::QueryProcessor > | |
setup_query(Query query) | Remote< Borealis::QueryProcessor > | |
subscribe(const Callback< void, RPC< void > > &completion, Subscription sub, unsigned int add_or_remove) | Remote< Borealis::QueryProcessor > | |
subscribe(Subscription sub, unsigned int add_or_remove) | Remote< Borealis::QueryProcessor > | |
subscribe_many(const Callback< void, RPC< vector< Subscription > > > &completion, vector< Subscription > sub, unsigned int add_or_remove) | Remote< Borealis::QueryProcessor > | |
subscribe_many(vector< Subscription > sub, unsigned int add_or_remove) | Remote< Borealis::QueryProcessor > | |
trim(const Callback< void, RPC< void > > &completion, MedusaID node, StreamID id, string last_tuple) | Remote< Borealis::QueryProcessor > | |
trim(MedusaID node, StreamID id, string last_tuple) | Remote< Borealis::QueryProcessor > | |
typecheck(const Callback< void, RPC< Query > > &completion, Query query) | Remote< Borealis::QueryProcessor > | |
typecheck(Query query) | Remote< Borealis::QueryProcessor > | |
typecheck_and_setup(const Callback< void, RPC< Query > > &completion, Query query) | Remote< Borealis::QueryProcessor > | |
typecheck_and_setup(Query query) | Remote< Borealis::QueryProcessor > | |
update_stream(const Callback< void, RPC< void > > &completion, StreamDef old_sd, StreamDef new_sd) | Remote< Borealis::QueryProcessor > | |
update_stream(StreamDef old_sd, StreamDef new_sd) | Remote< Borealis::QueryProcessor > | |