Table of Contents - newque-0.0.1 Documentation
Pages
- LICENSE
-
README
- Newque-ruby
- Install
- Client
- Client methods
- .write
- .read
- .read_stream
- .count
- .delete
- .health
- Pubsub Client
- .subscribe
- .unsubscribe
- .add_error_handler
- .disconnect
- Fifo Client
- .connect
- .disconnect
- Newque-Ruby Concurrency Guide
- Protocol Options
- HTTP Options
- ZMQ Options
- Response objects
- Write_response
- Read_response
- Count_response
- Delete_response
- Health_response
- Request objects
- Input_request
- Write_request
- Read_request
- Count_request
- Delete_request
- Health_request
- Running the tests
Classes and Modules
- Newque
- Newque::Client
- Newque::Count_Input
- Newque::Count_Output
- Newque::Count_request
- Newque::Count_response
- Newque::Delete_Input
- Newque::Delete_Output
- Newque::Delete_request
- Newque::Delete_response
- Newque::Error_Output
- Newque::Fifo_client
- Newque::Future
- Newque::Health_Input
- Newque::Health_Output
- Newque::Health_request
- Newque::Health_response
- Newque::Http_json
- Newque::Http_plaintext
- Newque::Input
- Newque::Input_request
- Newque::Many
- Newque::NewqueError
- Newque::Newque_http
- Newque::Newque_zmq
- Newque::Output
- Newque::Pubsub_client
- Newque::Read_Input
- Newque::Read_Output
- Newque::Read_request
- Newque::Read_response
- Newque::Util
- Newque::Write_Input
- Newque::Write_Output
- Newque::Write_request
- Newque::Write_response
- Newque::Zmq_tools
Methods
- ::compute_options — Newque::Util
- ::new — Newque::Client
- ::new — Newque::Fifo_client
- ::new — Newque::Pubsub_client
- ::new — Newque::Future
- ::new — Newque::Http_json
- ::new — Newque::Http_plaintext
- ::new — Newque::Newque_http
- ::new — Newque::Write_request
- ::new — Newque::Read_request
- ::new — Newque::Count_request
- ::new — Newque::Delete_request
- ::new — Newque::Health_request
- ::new — Newque::Input_request
- ::new — Newque::Write_response
- ::new — Newque::Read_response
- ::new — Newque::Count_response
- ::new — Newque::Delete_response
- ::new — Newque::Health_response
- ::new — Newque::Newque_zmq
- ::newque_error — Newque::Util
- ::parse_input — Newque::Zmq_tools
- ::resolve_t — Newque::Util
- ::set_zmq_sock_options — Newque::Zmq_tools
- ::time_ms — Newque::Util
- ::wait_t — Newque::Util
- ::zmq_error — Newque::Util
- #add_error_handler — Newque::Pubsub_client
- #connect — Newque::Fifo_client
- #count — Newque::Newque_http
- #count — Newque::Newque_zmq
- #current_state — Newque::Fifo_client
- #delete — Newque::Newque_http
- #delete — Newque::Newque_zmq
- #disconnect — Newque::Fifo_client
- #disconnect — Newque::Pubsub_client
- #get — Newque::Future
- #health — Newque::Newque_http
- #health — Newque::Newque_zmq
- #inspect — Newque::Future
- #inspect — Newque::Write_request
- #inspect — Newque::Read_request
- #inspect — Newque::Count_request
- #inspect — Newque::Delete_request
- #inspect — Newque::Health_request
- #inspect — Newque::Input_request
- #inspect — Newque::Write_response
- #inspect — Newque::Read_response
- #inspect — Newque::Count_response
- #inspect — Newque::Delete_response
- #inspect — Newque::Health_response
- #is_looping? — Newque::Pubsub_client
- #next_state — Newque::Fifo_client
- #parse_json_response — Newque::Newque_http
- #parse_response — Newque::Newque_zmq
- #print_uncaught_exception — Newque::Pubsub_client
- #read — Newque::Http_json
- #read — Newque::Http_plaintext
- #read — Newque::Newque_zmq
- #read_stream — Newque::Newque_http
- #read_stream — Newque::Newque_zmq
- #register — Newque::Newque_zmq
- #send_request — Newque::Newque_zmq
- #serialize — Newque::Write_response
- #serialize — Newque::Read_response
- #serialize — Newque::Count_response
- #serialize — Newque::Delete_response
- #serialize — Newque::Health_response
- #set_req_options — Newque::Newque_http
- #start_loop — Newque::Pubsub_client
- #start_loop — Newque::Newque_zmq
- #subscribe — Newque::Pubsub_client
- #to_s — Newque::Future
- #to_s — Newque::Write_request
- #to_s — Newque::Read_request
- #to_s — Newque::Count_request
- #to_s — Newque::Delete_request
- #to_s — Newque::Health_request
- #to_s — Newque::Input_request
- #to_s — Newque::Write_response
- #to_s — Newque::Read_response
- #to_s — Newque::Count_response
- #to_s — Newque::Delete_response
- #to_s — Newque::Health_response
- #unsubscribe — Newque::Pubsub_client
- #write — Newque::Http_json
- #write — Newque::Http_plaintext
- #write — Newque::Newque_zmq