Remote< Borealis::QueryProcessor > Class Reference

#include <rpc_QueryProcessor.h>

List of all members.

Public Member Functions
void	typecheck (const Callback< void, RPC< Query > > &completion, Query query)
	Invokes typecheck on the remote server (non-blocking interface).
RPC< Query >	typecheck (Query query)
	Invokes typecheck on the remote server (blocking interface).
void	setup_query (const Callback< void, RPC< void > > &completion, Query query)
	Invokes setup_query on the remote server (non-blocking interface).
RPC< void >	setup_query (Query query)
	Invokes setup_query on the remote server (blocking interface).
void	typecheck_and_setup (const Callback< void, RPC< Query > > &completion, Query query)
	Invokes typecheck_and_setup on the remote server (non-blocking interface).
RPC< Query >	typecheck_and_setup (Query query)
	Invokes typecheck_and_setup on the remote server (blocking interface).
void	load_box (const Callback< void, RPC< void > > &completion, string file_path)
	Invokes load_box on the remote server (non-blocking interface).
RPC< void >	load_box (string file_path)
	Invokes load_box on the remote server (blocking interface).
void	choke_queries (const Callback< void, RPC< vector< Query > > > &completion, vector< Query > queries)
	Invokes choke_queries on the remote server (non-blocking interface).
RPC< vector< Query > >	choke_queries (vector< Query > queries)
	Invokes choke_queries on the remote server (blocking interface).
void	resume_queries (const Callback< void, RPC< void > > &completion, vector< Query > queries)
	Invokes resume_queries on the remote server (non-blocking interface).
RPC< void >	resume_queries (vector< Query > queries)
	Invokes resume_queries on the remote server (blocking interface).
void	pack_query (const Callback< void, RPC< Query > > &completion, Query query)
	Invokes pack_query on the remote server (non-blocking interface).
RPC< Query >	pack_query (Query query)
	Invokes pack_query on the remote server (blocking interface).
void	pack_queries (const Callback< void, RPC< vector< Query > > > &completion, vector< Query > queries)
	Invokes pack_queries on the remote server (non-blocking interface).
RPC< vector< Query > >	pack_queries (vector< Query > queries)
	Invokes pack_queries on the remote server (blocking interface).
void	remove_query (const Callback< void, RPC< void > > &completion, Query query)
	Invokes remove_query on the remote server (non-blocking interface).
RPC< void >	remove_query (Query query)
	Invokes remove_query on the remote server (blocking interface).
void	replace_query (const Callback< void, RPC< void > > &completion, vector< Name > old_queries, vector< Query > new_queries)
	Invokes replace_query on the remote server (non-blocking interface).
RPC< void >	replace_query (vector< Name > old_queries, vector< Query > new_queries)
	Invokes replace_query on the remote server (blocking interface).
void	set_query_status (const Callback< void, RPC< void > > &completion, Name name, QueryStatus status)
	Invokes set_query_status on the remote server (non-blocking interface).
RPC< void >	set_query_status (Name name, QueryStatus status)
	Invokes set_query_status on the remote server (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< vector< Subscription > > > &completion, vector< Subscription > sub, unsigned int add_or_remove)
	Invokes subscribe_many on the remote server (non-blocking interface).
RPC< vector< Subscription > >	subscribe_many (vector< Subscription > sub, unsigned int add_or_remove)
	Invokes subscribe_many on the remote server (blocking interface).
void	get_subscriptions (const Callback< void, RPC< vector< Subscription > > > &completion, vector< Name > streams)
	Invokes get_subscriptions on the remote server (non-blocking interface).
RPC< vector< Subscription > >	get_subscriptions (vector< Name > streams)
	Invokes get_subscriptions on the remote server (blocking interface).
void	get_stats (const Callback< void, RPC< vector< Stats > > > &completion)
	Invokes get_stats on the remote server (non-blocking interface).
RPC< vector< Stats > >	get_stats ()
	Invokes get_stats on the remote server (blocking interface).
void	get_sel (const Callback< void, RPC< double > > &completion)
	Invokes get_sel on the remote server (non-blocking interface).
RPC< double >	get_sel ()
	Invokes get_sel on the remote server (blocking interface).
void	create_stream (const Callback< void, RPC< void > > &completion, StreamDef stream)
	Invokes create_stream on the remote server (non-blocking interface).
RPC< void >	create_stream (StreamDef stream)
	Invokes create_stream on the remote server (blocking interface).
void	create_cpview (const Callback< void, RPC< void > > &completion, CPViewDescription view_desc, StreamDef streamdef)
	Invokes create_cpview on the remote server (non-blocking interface).
RPC< void >	create_cpview (CPViewDescription view_desc, StreamDef streamdef)
	Invokes create_cpview on the remote server (blocking interface).
void	update_stream (const Callback< void, RPC< void > > &completion, StreamDef old_sd, StreamDef new_sd)
	Invokes update_stream on the remote server (non-blocking interface).
RPC< void >	update_stream (StreamDef old_sd, StreamDef new_sd)
	Invokes update_stream on the remote server (blocking interface).
void	ack (const Callback< void, RPC< void > > &completion, MedusaID node, StreamID id, string last_tuple)
	Invokes ack on the remote server (non-blocking interface).
RPC< void >	ack (MedusaID node, StreamID id, string last_tuple)
	Invokes ack on the remote server (blocking interface).
void	trim (const Callback< void, RPC< void > > &completion, MedusaID node, StreamID id, string last_tuple)
	Invokes trim on the remote server (non-blocking interface).
RPC< void >	trim (MedusaID node, StreamID id, string last_tuple)
	Invokes trim on the remote server (blocking interface).
void	set_recovery_method (const Callback< void, RPC< void > > &completion, int method)
	Invokes set_recovery_method on the remote server (non-blocking interface).
RPC< void >	set_recovery_method (int method)
	Invokes set_recovery_method on the remote server (blocking interface).
void	set_primary_status (const Callback< void, RPC< void > > &completion, bool status)
	Invokes set_primary_status on the remote server (non-blocking interface).
RPC< void >	set_primary_status (bool status)
	Invokes set_primary_status on the remote server (blocking interface).
void	set_secondaries (const Callback< void, RPC< void > > &completion, vector< MedusaID > secondaries)
	Invokes set_secondaries on the remote server (non-blocking interface).
RPC< void >	set_secondaries (vector< MedusaID > secondaries)
	Invokes set_secondaries on the remote server (blocking interface).
void	set_replicas (const Callback< void, RPC< void > > &completion, vector< MedusaID > replicas)
	Invokes set_replicas on the remote server (non-blocking interface).
RPC< void >	set_replicas (vector< MedusaID > replicas)
	Invokes set_replicas on the remote server (blocking interface).
void	checkpoint (const Callback< void, RPC< void > > &completion, vector< StreamEvent > tuples_to_checkpoint, map< StreamID, string > tuples_to_trim)
	Invokes checkpoint on the remote server (non-blocking interface).
RPC< void >	checkpoint (vector< StreamEvent > tuples_to_checkpoint, map< StreamID, string > tuples_to_trim)
	Invokes checkpoint on the remote server (blocking interface).

---

Member Function Documentation

RPC< void > Remote< Borealis::QueryProcessor >::ack (  MedusaID  node, StreamID  id, string  last_tuple )

Invokes ack on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::ack (  const Callback< void, RPC< void > > &  completion, MedusaID  node, StreamID  id, string  last_tuple )

Invokes ack on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< void > Remote< Borealis::QueryProcessor >::checkpoint (  vector< StreamEvent >  tuples_to_checkpoint, map< StreamID, string >  tuples_to_trim )

Invokes checkpoint on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::checkpoint (  const Callback< void, RPC< void > > &  completion, vector< StreamEvent >  tuples_to_checkpoint, map< StreamID, string >  tuples_to_trim )

Invokes checkpoint on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< vector<Query> > Remote< Borealis::QueryProcessor >::choke_queries (  vector< Query >  queries  )

Invokes choke_queries on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::choke_queries (  const Callback< void, RPC< vector< Query > > > &  completion, vector< Query >  queries )

Invokes choke_queries on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< void > Remote< Borealis::QueryProcessor >::create_cpview (  CPViewDescription  view_desc, StreamDef  streamdef )

Invokes create_cpview on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::create_cpview (  const Callback< void, RPC< void > > &  completion, CPViewDescription  view_desc, StreamDef  streamdef )

Invokes create_cpview on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< void > Remote< Borealis::QueryProcessor >::create_stream (  StreamDef  stream  )

Invokes create_stream on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::create_stream (  const Callback< void, RPC< void > > &  completion, StreamDef  stream )

Invokes create_stream on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< double > Remote< Borealis::QueryProcessor >::get_sel (   )

Invokes get_sel on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::get_sel (  const Callback< void, RPC< double > > &  completion  )

Invokes get_sel on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< vector<Stats> > Remote< Borealis::QueryProcessor >::get_stats (   )

Invokes get_stats on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::get_stats (  const Callback< void, RPC< vector< Stats > > > &  completion  )

Invokes get_stats on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< vector<Subscription> > Remote< Borealis::QueryProcessor >::get_subscriptions (  vector< Name >  streams  )

Invokes get_subscriptions on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::get_subscriptions (  const Callback< void, RPC< vector< Subscription > > > &  completion, vector< Name >  streams )

Invokes get_subscriptions on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< void > Remote< Borealis::QueryProcessor >::load_box (  string  file_path  )

Invokes load_box on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::load_box (  const Callback< void, RPC< void > > &  completion, string  file_path )

Invokes load_box on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< vector<Query> > Remote< Borealis::QueryProcessor >::pack_queries (  vector< Query >  queries  )

Invokes pack_queries on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::pack_queries (  const Callback< void, RPC< vector< Query > > > &  completion, vector< Query >  queries )

Invokes pack_queries on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< Query > Remote< Borealis::QueryProcessor >::pack_query (  Query  query  )

Invokes pack_query on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::pack_query (  const Callback< void, RPC< Query > > &  completion, Query  query )

Invokes pack_query on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< void > Remote< Borealis::QueryProcessor >::remove_query (  Query  query  )

Invokes remove_query on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::remove_query (  const Callback< void, RPC< void > > &  completion, Query  query )

Invokes remove_query on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< void > Remote< Borealis::QueryProcessor >::replace_query (  vector< Name >  old_queries, vector< Query >  new_queries )

Invokes replace_query on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::replace_query (  const Callback< void, RPC< void > > &  completion, vector< Name >  old_queries, vector< Query >  new_queries )

Invokes replace_query on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< void > Remote< Borealis::QueryProcessor >::resume_queries (  vector< Query >  queries  )

Invokes resume_queries on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::resume_queries (  const Callback< void, RPC< void > > &  completion, vector< Query >  queries )

Invokes resume_queries on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< void > Remote< Borealis::QueryProcessor >::set_primary_status (  bool  status  )

Invokes set_primary_status on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::set_primary_status (  const Callback< void, RPC< void > > &  completion, bool  status )

Invokes set_primary_status on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< void > Remote< Borealis::QueryProcessor >::set_queries_status (  vector< Name >  name, QueryStatus  status )

Invokes set_queries_status on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::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). callback is invoked when the result is available.

RPC< void > Remote< Borealis::QueryProcessor >::set_query_status (  Name  name, QueryStatus  status )

Invokes set_query_status on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::set_query_status (  const Callback< void, RPC< void > > &  completion, Name  name, QueryStatus  status )

Invokes set_query_status on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< void > Remote< Borealis::QueryProcessor >::set_recovery_method (  int  method  )

Invokes set_recovery_method on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::set_recovery_method (  const Callback< void, RPC< void > > &  completion, int  method )

Invokes set_recovery_method on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< void > Remote< Borealis::QueryProcessor >::set_replicas (  vector< MedusaID >  replicas  )

Invokes set_replicas on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::set_replicas (  const Callback< void, RPC< void > > &  completion, vector< MedusaID >  replicas )

Invokes set_replicas on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< void > Remote< Borealis::QueryProcessor >::set_secondaries (  vector< MedusaID >  secondaries  )

Invokes set_secondaries on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::set_secondaries (  const Callback< void, RPC< void > > &  completion, vector< MedusaID >  secondaries )

Invokes set_secondaries on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< void > Remote< Borealis::QueryProcessor >::setup_query (  Query  query  )

Invokes setup_query on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::setup_query (  const Callback< void, RPC< void > > &  completion, Query  query )

Invokes setup_query on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< void > Remote< Borealis::QueryProcessor >::subscribe (  Subscription  sub, unsigned int  add_or_remove )

Invokes subscribe on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::subscribe (  const Callback< void, RPC< void > > &  completion, Subscription  sub, unsigned int  add_or_remove )

Invokes subscribe on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< vector<Subscription> > Remote< Borealis::QueryProcessor >::subscribe_many (  vector< Subscription >  sub, unsigned int  add_or_remove )

Invokes subscribe_many on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::subscribe_many (  const Callback< void, RPC< vector< Subscription > > > &  completion, vector< Subscription >  sub, unsigned int  add_or_remove )

Invokes subscribe_many on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< void > Remote< Borealis::QueryProcessor >::trim (  MedusaID  node, StreamID  id, string  last_tuple )

Invokes trim on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::trim (  const Callback< void, RPC< void > > &  completion, MedusaID  node, StreamID  id, string  last_tuple )

Invokes trim on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< Query > Remote< Borealis::QueryProcessor >::typecheck (  Query  query  )

Invokes typecheck on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::typecheck (  const Callback< void, RPC< Query > > &  completion, Query  query )

Invokes typecheck on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< Query > Remote< Borealis::QueryProcessor >::typecheck_and_setup (  Query  query  )

Invokes typecheck_and_setup on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::typecheck_and_setup (  const Callback< void, RPC< Query > > &  completion, Query  query )

Invokes typecheck_and_setup on the remote server (non-blocking interface). callback is invoked when the result is available.

RPC< void > Remote< Borealis::QueryProcessor >::update_stream (  StreamDef  old_sd, StreamDef  new_sd )

Invokes update_stream on the remote server (blocking interface).

void Remote< Borealis::QueryProcessor >::update_stream (  const Callback< void, RPC< void > > &  completion, StreamDef  old_sd, StreamDef  new_sd )

Invokes update_stream on the remote server (non-blocking interface). callback is invoked when the result is available.

---

The documentation for this class was generated from the following file:

• rpc_QueryProcessor.h

---