Method List

Classes Methods Files

Search:

#_socket Krakow::ConnectionFeatures::Ssl::Io
#add_connection Krakow::Distribution
#arguments Krakow::Utils::Lazy::InstanceMethods
#attempts Krakow::FrameType::Message
#attempts? Krakow::FrameType::Message
#attribute Krakow::Utils::Lazy::ClassMethods
#attributes Krakow::Utils::Lazy::ClassMethods
#backoff_interval Krakow::Distribution
#backoff_interval Krakow::Consumer
#backoff_interval? Krakow::Consumer
#backoff_interval? Krakow::Distribution
#buffer Krakow::ConnectionFeatures::SnappyFrames::Io
#buffer Krakow::ConnectionFeatures::Deflate::Io
build Krakow::FrameType
#build_connection Krakow::Consumer
#build_ssl_context Krakow::Producer::Http
#calculate_ready! Krakow::Distribution::Default
#calculate_ready! Krakow::Distribution
#callback_for Krakow::Connection
#callbacks Krakow::Connection
#callbacks? Krakow::Connection
#channel Krakow::Consumer
#channel Krakow::Connection
#channel? Krakow::Consumer
#channel? Krakow::Connection
#channel_name Krakow::Command::Sub
#channel_name? Krakow::Command::Sub
#checksum_mask Krakow::ConnectionFeatures::SnappyFrames::Io
#close Krakow::ConnectionFeatures::Deflate::Io
#config Krakow::Producer::Http
#config? Krakow::Producer::Http
#confirm Krakow::FrameType::Message
#confirm Krakow::Consumer
#connect Krakow::Producer
#connected? Krakow::Producer
#connected? Krakow::Connection
#connection Krakow::Producer
#connection Krakow::Consumer
#connection_failure Krakow::Consumer
#connection_failure Krakow::Producer
#connection_lookup Krakow::Distribution
#connection_options Krakow::Consumer
#connection_options Krakow::Producer
#connection_options? Krakow::Producer
#connection_options? Krakow::Consumer
#connection_reconnect Krakow::Consumer
#connections Krakow::Distribution
#connections Krakow::Consumer
#connector Krakow::Connection
#consumer Krakow::Distribution
#consumer? Krakow::Distribution
#content Krakow::FrameType::Error
#content Krakow::FrameType
#content Krakow::FrameType::Message
#content Krakow::FrameType::Response
#count Krakow::Command::Rdy
#count? Krakow::Command::Rdy
#create_channel Krakow::Producer::Http
#create_topic Krakow::Producer::Http
decode Krakow::FrameType
#deflate Krakow::Command::Identify
#deflate Krakow::Connection
#deflate? Krakow::Command::Identify
#deflate_level Krakow::Command::Identify
#deflate_level? Krakow::Command::Identify
#deflator Krakow::ConnectionFeatures::Deflate::Io
#delete_channel Krakow::Producer::Http
#delete_topic Krakow::Producer::Http
#discover Krakow::Consumer
#discovery Krakow::Consumer
#discovery_interval Krakow::Consumer
#discovery_interval? Krakow::Consumer
#discovery_jitter Krakow::Consumer
#discovery_jitter? Krakow::Consumer
#distribution Krakow::Consumer
#empty_channel Krakow::Producer::Http
#empty_topic Krakow::Producer::Http
#endpoint Krakow::Producer::Http
#endpoint? Krakow::Producer::Http
#endpoint_settings Krakow::Connection
#enforce_features Krakow::Connection
#enforce_features? Krakow::Connection
error Krakow::Command::Mpub
error Krakow::Command::Rdy
#error Krakow::FrameType::Error
error Krakow::Command::Cls
error Krakow::Command::Identify
error Krakow::Command::Req
error Krakow::Command
error Krakow::Command::Sub
error Krakow::Command::Fin
error Krakow::Command::Pub
error Krakow::Command::Touch
#error? Krakow::Command
#error? Krakow::FrameType::Error
#error_wait Krakow::Connection
#error_wait? Krakow::Connection
#failure Krakow::Distribution
#feature_negotiation Krakow::Command::Identify
#feature_negotiation? Krakow::Command::Identify
#features Krakow::Connection
#features? Krakow::Connection
#features_args Krakow::Connection
#features_args? Krakow::Connection
#flight_record Krakow::Distribution
#force_unready Krakow::Distribution::Default
#goodbye_my_love! Krakow::Connection
#goodbye_my_love! Krakow::Producer
#goodbye_my_love! Krakow::Consumer
#handle Krakow::Connection
#headers Krakow::ConnectionFeatures::Deflate::Io
#heartbeat_interval Krakow::Command::Identify
#heartbeat_interval? Krakow::Command::Identify
#host Krakow::Producer
#host Krakow::Connection
#host Krakow::Consumer
#host? Krakow::Connection
#host? Krakow::Producer
#host? Krakow::Consumer
#ideal Krakow::Distribution
#identifier Krakow::Connection
identifier Krakow::Connection
#identify_and_negotiate Krakow::Connection
#identify_defaults Krakow::Connection
#in_flight_lookup Krakow::Distribution
included Krakow::Utils::Lazy
#inflator Krakow::ConnectionFeatures::Deflate::Io
#info Krakow::Producer::Http
#init! Krakow::Connection
#init! Krakow::Consumer
#initial_ready Krakow::Distribution
#initialize Krakow::Producer
#initialize Krakow::Connection
#initialize Krakow::Distribution
#initialize Krakow::ConnectionFeatures::Ssl::Io
#initialize Krakow::ConnectionFeatures::Deflate::Io
#initialize Krakow::ConnectionFeatures::SnappyFrames::Io
#initialize Krakow::Utils::Lazy::InstanceMethods
#initialize Krakow::Producer::Http
#initialize Krakow::Consumer
#inspect Krakow::Utils::Lazy::InstanceMethods
#io Krakow::ConnectionFeatures::Deflate::Io
#io Krakow::ConnectionFeatures::SnappyFrames::Io
#less_than_ideal? Krakow::Distribution::Default
#less_than_ideal_ready! Krakow::Distribution::Default
#less_than_ideal_stack Krakow::Distribution::Default
level= Krakow::Utils::Logging
#log Krakow::Utils::Logging
#long_id Krakow::Command::Identify
#long_id? Krakow::Command::Identify
#lookup Krakow::Discovery
#max_in_flight Krakow::Consumer
#max_in_flight Krakow::Distribution
#max_in_flight? Krakow::Distribution
#max_in_flight? Krakow::Consumer
#message Krakow::FrameType::Message
#message Krakow::Command::Pub
#message? Krakow::Command::Pub
#message? Krakow::FrameType::Message
#message_id Krakow::Command::Fin
#message_id Krakow::Command::Touch
#message_id Krakow::Command::Req
#message_id Krakow::FrameType::Message
#message_id? Krakow::FrameType::Message
#message_id? Krakow::Command::Fin
#message_id? Krakow::Command::Req
#message_id? Krakow::Command::Touch
#messages Krakow::Command::Mpub
#messages? Krakow::Command::Mpub
#method_missing Krakow::ConnectionFeatures::Deflate::Io
#method_missing Krakow::ConnectionFeatures::SnappyFrames::Io
#method_missing Krakow::ConnectionFeatures::Ssl::Io
#name Krakow::Command
#notifier Krakow::Consumer
#notifier Krakow::Connection
#notifier? Krakow::Consumer
#notifier? Krakow::Connection
#nsqlookupd Krakow::Consumer
#nsqlookupd Krakow::Discovery
#nsqlookupd? Krakow::Consumer
#nsqlookupd? Krakow::Discovery
ok Krakow::Command::Pub
ok Krakow::Command::Sub
ok Krakow::Command::Cls
ok Krakow::Command::Identify
ok Krakow::Command::Mpub
ok Krakow::Command
#ok? Krakow::Command
#origin Krakow::FrameType::Message
#output_buffer_size Krakow::Command::Identify
#output_buffer_size? Krakow::Command::Identify
#output_buffer_timeout Krakow::Command::Identify
#output_buffer_timeout? Krakow::Command::Identify
#pause_channel Krakow::Producer::Http
#ping Krakow::Producer::Http
#port Krakow::Connection
#port Krakow::Producer
#port Krakow::Consumer
#port? Krakow::Connection
#port? Krakow::Producer
#port? Krakow::Consumer
#process_message Krakow::Consumer
#process_to_queue! Krakow::Connection
#queue Krakow::Connection
#queue Krakow::Consumer
#queue? Krakow::Connection
#rdy_connections Krakow::Distribution::Default
#read_stream Krakow::ConnectionFeatures::Deflate::Io
#read_stream Krakow::ConnectionFeatures::SnappyFrames::Io
#ready_for Krakow::Distribution
#receive Krakow::Connection
#receiving? Krakow::Connection
#reconnect_interval Krakow::Producer
#reconnect_interval? Krakow::Producer
#reconnect_notifier Krakow::Connection
#reconnect_retries Krakow::Producer
#reconnect_retries? Krakow::Producer
#reconnector Krakow::Connection
#recv Krakow::ConnectionFeatures::SnappyFrames::Io
#recv Krakow::ConnectionFeatures::Deflate::Io
#recv Krakow::ConnectionFeatures::Ssl::Io
#redistribute! Krakow::Distribution
#redistribute! Krakow::Distribution::Default
#register Krakow::Consumer
#register_message Krakow::Distribution
#registry Krakow::Distribution
#registry_lookup Krakow::Distribution
#remove_connection Krakow::Distribution
#requeue Krakow::FrameType::Message
#requeue Krakow::Consumer
#responder Krakow::Connection
#response Krakow::Command
#response Krakow::FrameType::Response
#response? Krakow::FrameType::Response
response_for Krakow::Command
#response_interval Krakow::Connection
#response_interval? Krakow::Connection
#response_wait Krakow::Connection
#response_wait? Krakow::Connection
#responses Krakow::Connection
#responses? Krakow::Connection
#result Krakow::Error::BadResponse
#running Krakow::Connection
#sample_rate Krakow::Command::Identify
#sample_rate? Krakow::Command::Identify
#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
#short_id Krakow::Command::Identify
#short_id? Krakow::Command::Identify
#snappy Krakow::Connection
#snappy Krakow::Command::Identify
#snappy? Krakow::Command::Identify
#socket Krakow::Connection
#ssl_context Krakow::Producer::Http
#ssl_context? Krakow::Producer::Http
#stats Krakow::Producer::Http
#success Krakow::Distribution
#timeout Krakow::Command::Req
#timeout? Krakow::Command::Req
#timestamp Krakow::FrameType::Message
#timestamp? Krakow::FrameType::Message
#tls_v1 Krakow::Connection
#tls_v1 Krakow::Command::Identify
#tls_v1? Krakow::Command::Identify
#to_line Krakow::Command::Touch
#to_line Krakow::Command::Sub
#to_line Krakow::Command::Nop
#to_line Krakow::Command::Rdy
#to_line Krakow::Command::Mpub
#to_line Krakow::Command::Cls
#to_line Krakow::Command
#to_line Krakow::Command::Req
#to_line Krakow::Command::Identify
#to_line Krakow::Command::Pub
#to_line Krakow::Command::Fin
#to_s Krakow::Utils::Lazy::InstanceMethods
#to_s Krakow::Consumer
#to_s Krakow::Connection
#to_s Krakow::Producer
#topic Krakow::Connection
#topic Krakow::Consumer
#topic Krakow::Producer
#topic Krakow::Producer::Http
#topic? Krakow::Producer
#topic? Krakow::Producer::Http
#topic? Krakow::Consumer
#topic? Krakow::Connection
#topic_name Krakow::Command::Mpub
#topic_name Krakow::Command::Sub
#topic_name Krakow::Command::Pub
#topic_name? Krakow::Command::Sub
#topic_name? Krakow::Command::Mpub
#topic_name? Krakow::Command::Pub
#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
#uri Krakow::Producer::Http
#version Krakow::Connection
#version? Krakow::Connection
#wait_time_for Krakow::Connection
#waiting_connections Krakow::Distribution::Default
#watch_dog Krakow::Distribution::Default
#watch_dog_interval Krakow::Distribution
#watch_dog_interval? Krakow::Distribution
#write Krakow::ConnectionFeatures::Deflate::Io
#write Krakow::Producer
#write Krakow::ConnectionFeatures::SnappyFrames::Io
#write Krakow::Producer::Http