Table of Contents - nsq-krakow-0.1.0 Documentation
Pages
Classes and Modules
- Krakow
- Krakow::Command
- Krakow::Command::Auth
- Krakow::Command::Cls
- Krakow::Command::Fin
- Krakow::Command::Identify
- Krakow::Command::Mpub
- Krakow::Command::Nop
- Krakow::Command::Pub
- Krakow::Command::Rdy
- Krakow::Command::Req
- Krakow::Command::Sub
- Krakow::Command::Touch
- Krakow::Connection
- Krakow::ConnectionFeatures
- Krakow::ConnectionFeatures::Deflate
- Krakow::ConnectionFeatures::Deflate::Io
- Krakow::ConnectionFeatures::SnappyFrames
- Krakow::ConnectionFeatures::SnappyFrames::Io
- Krakow::ConnectionFeatures::Ssl
- Krakow::ConnectionFeatures::Ssl::Io
- Krakow::Consumer
- Krakow::Consumer::Queue
- Krakow::Discovery
- Krakow::Distribution
- Krakow::Distribution::Default
- Krakow::Error
- Krakow::Error::BadResponse
- Krakow::Error::BadResponse::NoResponse
- Krakow::Error::ConfigurationError
- Krakow::Error::ConnectionFailure
- Krakow::Error::ConnectionFeatureFailure
- Krakow::Error::ConnectionUnavailable
- Krakow::Error::LookupFailed
- Krakow::Error::OriginNotFound
- Krakow::FrameType
- Krakow::FrameType::Error
- Krakow::FrameType::Message
- Krakow::FrameType::Response
- Krakow::Ksocket
- Krakow::Producer
- Krakow::Producer::Http
- Krakow::Producer::Http::Response
- Krakow::Utils
- Krakow::Utils::Lazy
- Krakow::Utils::Lazy::ClassMethods
- Krakow::Utils::Lazy::InstanceMethods
- Krakow::Utils::Logging
Methods
- ::build — Krakow::FrameType
- ::decode — Krakow::FrameType
- ::error — Krakow::Command
- ::error — Krakow::Command::Auth
- ::error — Krakow::Command::Cls
- ::error — Krakow::Command::Fin
- ::error — Krakow::Command::Identify
- ::error — Krakow::Command::Mpub
- ::error — Krakow::Command::Pub
- ::error — Krakow::Command::Rdy
- ::error — Krakow::Command::Req
- ::error — Krakow::Command::Sub
- ::error — Krakow::Command::Touch
- ::identifier — Krakow::Connection
- ::included — Krakow::Utils::Lazy
- ::inherited — Krakow::Utils::Lazy
- ::level= — Krakow::Utils::Logging
- ::new — Krakow::Connection
- ::new — Krakow::ConnectionFeatures::Deflate::Io
- ::new — Krakow::ConnectionFeatures::SnappyFrames::Io
- ::new — Krakow::ConnectionFeatures::Ssl::Io
- ::new — Krakow::Consumer
- ::new — Krakow::Consumer::Queue
- ::new — Krakow::Distribution
- ::new — Krakow::FrameType::Message
- ::new — Krakow::Ksocket
- ::new — Krakow::Producer
- ::new — Krakow::Producer::Http
- ::new — Krakow::Utils::Lazy::InstanceMethods
- ::ok — Krakow::Command
- ::ok — Krakow::Command::Auth
- ::ok — Krakow::Command::Cls
- ::ok — Krakow::Command::Identify
- ::ok — Krakow::Command::Mpub
- ::ok — Krakow::Command::Pub
- ::ok — Krakow::Command::Sub
- ::response_for — Krakow::Command
- #<< — Krakow::Consumer::Queue
- #add_connection — Krakow::Distribution
- #attribute — Krakow::Utils::Lazy::ClassMethods
- #attributes — Krakow::Utils::Lazy::ClassMethods
- #auth_required — Krakow::Connection
- #build_connection — Krakow::Consumer
- #build_ssl_context — Krakow::Producer::Http
- #calculate_ready! — Krakow::Distribution
- #calculate_ready! — Krakow::Distribution::Default
- #callback_for — Krakow::Connection
- #checksum_mask — Krakow::ConnectionFeatures::SnappyFrames::Io
- #close — Krakow::ConnectionFeatures::Deflate::Io
- #closedown_socket — Krakow::Ksocket
- #confirm — Krakow::Consumer
- #confirm — Krakow::FrameType::Message
- #connect — Krakow::Producer
- #connect! — Krakow::Connection
- #connected? — Krakow::Connection
- #connected? — Krakow::Consumer
- #connected? — Krakow::Producer
- #connection — Krakow::Consumer
- #connection_cleanup — Krakow::Connection
- #connection_failure — Krakow::Consumer
- #connection_failure — Krakow::Producer
- #connection_lookup — Krakow::Distribution
- #connections — Krakow::Distribution
- #consumer_cleanup — Krakow::Consumer
- #content — Krakow::FrameType
- #content — Krakow::FrameType::Error
- #content — Krakow::FrameType::Message
- #content — Krakow::FrameType::Response
- #create_channel — Krakow::Producer::Http
- #create_topic — Krakow::Producer::Http
- #deflate — Krakow::Connection
- #delete_channel — Krakow::Producer::Http
- #delete_topic — Krakow::Producer::Http
- #deq — Krakow::Consumer::Queue
- #deregister_connection — Krakow::Consumer::Queue
- #direct_connect — Krakow::Consumer
- #discover — Krakow::Consumer
- #empty_channel — Krakow::Producer::Http
- #empty_topic — Krakow::Producer::Http
- #enq — Krakow::Consumer::Queue
- #error? — Krakow::Command
- #failure — Krakow::Distribution
- #finish — Krakow::Consumer
- #finish — Krakow::FrameType::Message
- #force_unready — Krakow::Distribution::Default
- #get — Krakow::Ksocket
- #handle — Krakow::Connection
- #identifier — Krakow::Connection
- #identify_and_negotiate — Krakow::Connection
- #identify_defaults — Krakow::Connection
- #in_flight_lookup — Krakow::Distribution
- #info — Krakow::Producer::Http
- #init! — Krakow::Connection
- #init! — Krakow::Consumer
- #initial_ready — Krakow::Distribution
- #inspect — Krakow::Utils::Lazy::InstanceMethods
- #less_than_ideal? — Krakow::Distribution::Default
- #less_than_ideal_ready! — Krakow::Distribution::Default
- #log — Krakow::Utils::Logging
- #lookup — Krakow::Discovery
- #messages — Krakow::Consumer::Queue
- #method_missing — Krakow::ConnectionFeatures::Deflate::Io
- #method_missing — Krakow::ConnectionFeatures::SnappyFrames::Io
- #method_missing — Krakow::ConnectionFeatures::Ssl::Io
- #name — Krakow::Command
- #ok? — Krakow::Command
- #pause_channel — Krakow::Producer::Http
- #ping — Krakow::Producer::Http
- #pop — Krakow::Consumer::Queue
- #process_message — Krakow::Consumer
- #process_to_queue! — Krakow::Connection
- #producer_cleanup — Krakow::Producer
- #push — Krakow::Consumer::Queue
- #put — Krakow::Ksocket
- #rdy_connections — Krakow::Distribution::Default
- #read — Krakow::ConnectionFeatures::Deflate::Io
- #read — Krakow::ConnectionFeatures::SnappyFrames::Io
- #read — Krakow::Ksocket
- #read_loop — Krakow::Ksocket
- #read_stream — Krakow::ConnectionFeatures::Deflate::Io
- #read_stream — Krakow::ConnectionFeatures::SnappyFrames::Io
- #reading? — Krakow::Ksocket
- #readpartial — Krakow::Ksocket
- #ready_for — Krakow::Distribution
- #receive — Krakow::Connection
- #receiving? — Krakow::Connection
- #recv — Krakow::ConnectionFeatures::Deflate::Io
- #recv — Krakow::ConnectionFeatures::SnappyFrames::Io
- #recv — Krakow::ConnectionFeatures::Ssl::Io
- #recv — Krakow::Ksocket
- #redistribute! — Krakow::Distribution
- #redistribute! — Krakow::Distribution::Default
- #register — Krakow::Consumer
- #register_connection — Krakow::Consumer::Queue
- #register_message — Krakow::Distribution
- #registry_lookup — Krakow::Distribution
- #remove_connection — Krakow::Distribution
- #remove_message — Krakow::Consumer
- #requeue — Krakow::Consumer
- #requeue — Krakow::FrameType::Message
- #scrub_duplicate_message — Krakow::Consumer::Queue
- #send_message — Krakow::Producer::Http
- #send_snappy_identifier — Krakow::ConnectionFeatures::SnappyFrames::Io
- #set_attributes — Krakow::Utils::Lazy::ClassMethods
- #set_ready_for — Krakow::Distribution
- #set_ready_for — Krakow::Distribution::Default
- #size — Krakow::Consumer::Queue
- #snappy — Krakow::Connection
- #socket — Krakow::Ksocket
- #stats — Krakow::Producer::Http
- #success — Krakow::Distribution
- #sysread — Krakow::Ksocket
- #tls_v1 — Krakow::Connection
- #to_line — Krakow::Command
- #to_line — Krakow::Command::Auth
- #to_line — Krakow::Command::Cls
- #to_line — Krakow::Command::Fin
- #to_line — Krakow::Command::Identify
- #to_line — Krakow::Command::Mpub
- #to_line — Krakow::Command::Nop
- #to_line — Krakow::Command::Pub
- #to_line — Krakow::Command::Rdy
- #to_line — Krakow::Command::Req
- #to_line — Krakow::Command::Sub
- #to_line — Krakow::Command::Touch
- #to_s — Krakow::Connection
- #to_s — Krakow::Consumer
- #to_s — Krakow::Producer
- #to_s — Krakow::Utils::Lazy::InstanceMethods
- #touch — Krakow::Consumer
- #touch — Krakow::FrameType::Message
- #transmit — Krakow::Connection
- #transmit_with_response — Krakow::Connection
- #unpause_channel — Krakow::Producer::Http
- #unregister_message — Krakow::Distribution
- #update_ready! — Krakow::Consumer
- #validate_message — Krakow::Consumer::Queue
- #validate_ssl_args! — Krakow::ConnectionFeatures::Ssl::Io
- #wait_time_for — Krakow::Connection
- #waiting_connections — Krakow::Distribution::Default
- #write — Krakow::ConnectionFeatures::Deflate::Io
- #write — Krakow::ConnectionFeatures::SnappyFrames::Io
- #write — Krakow::Ksocket
- #write — Krakow::Producer
- #write — Krakow::Producer::Http