Method List
-
#action Newque::Input_request
-
#add_error_handler Newque::Pubsub_client
-
#atomic Newque::Write_request
-
#channel Newque::Input_request
-
compute_options Newque::Util
-
#conn Newque::Newque_http
-
#connect Newque::Fifo_client
-
#count Newque::Count_response
-
#count Newque::Newque_http
-
#count Newque::Newque_zmq
-
#delete Newque::Newque_http
-
#delete Newque::Newque_zmq
-
#disconnect Newque::Pubsub_client
-
#disconnect Newque::Fifo_client
-
#get Newque::Future
-
#global Newque::Health_request
-
#health Newque::Newque_zmq
-
#health Newque::Newque_http
-
#ids Newque::Write_request
-
#initialize Newque::Read_request
-
#initialize Newque::Pubsub_client
-
#initialize Newque::Count_request
-
#initialize Newque::Delete_response
-
#initialize Newque::Health_response
-
#initialize Newque::Read_response
-
#initialize Newque::Write_request
-
#initialize Newque::Client
-
#initialize Newque::Http_json
-
#initialize Newque::Future
-
#initialize Newque::Delete_request
-
#initialize Newque::Newque_zmq
-
#initialize Newque::Newque_http
-
#initialize Newque::Count_response
-
#initialize Newque::Health_request
-
#initialize Newque::Fifo_client
-
#initialize Newque::Http_plaintext
-
#initialize Newque::Write_response
-
#initialize Newque::Input_request
-
#inspect Newque::Input_request
-
#inspect Newque::Health_request
-
#inspect Newque::Delete_request
-
#inspect Newque::Read_request
-
#inspect Newque::Count_request
-
#inspect Newque::Write_request
-
#inspect Newque::Delete_response
-
#inspect Newque::Future
-
#inspect Newque::Write_response
-
#inspect Newque::Health_response
-
#inspect Newque::Count_response
-
#inspect Newque::Read_response
-
#last_id Newque::Read_response
-
#last_timens Newque::Read_response
-
#length Newque::Read_response
-
#limit Newque::Read_request
-
#messages Newque::Input_request
-
#messages Newque::Read_response
-
#mode Newque::Read_request
-
newque_error Newque::Util
-
#options Newque::Newque_http
-
parse_input Newque::Zmq_tools
-
#protocol Newque::Client
-
#read Newque::Http_plaintext
-
#read Newque::Http_json
-
#read Newque::Newque_zmq
-
#read_stream Newque::Newque_http
-
#read_stream Newque::Newque_zmq
-
resolve_t Newque::Util
-
#saved Newque::Write_response
-
#serialize Newque::Health_response
-
#serialize Newque::Delete_response
-
#serialize Newque::Count_response
-
#serialize Newque::Read_response
-
#serialize Newque::Write_response
-
set_zmq_sock_options Newque::Zmq_tools
-
#sock Newque::Newque_zmq
-
#subscribe Newque::Pubsub_client
-
#thread Newque::Future
-
time_ms Newque::Util
-
#timeout Newque::Newque_http
-
#to_s Newque::Delete_response
-
#to_s Newque::Health_response
-
#to_s Newque::Count_response
-
#to_s Newque::Read_response
-
#to_s Newque::Input_request
-
#to_s Newque::Delete_request
-
#to_s Newque::Health_request
-
#to_s Newque::Write_response
-
#to_s Newque::Count_request
-
#to_s Newque::Read_request
-
#to_s Newque::Future
-
#to_s Newque::Write_request
-
#unsubscribe Newque::Pubsub_client
-
wait_t Newque::Util
-
#write Newque::Http_plaintext
-
#write Newque::Newque_zmq
-
#write Newque::Http_json
-
zmq_error Newque::Util