Method List
-
#_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
-
#auth_required Krakow::Connection
-
#backoff_interval Krakow::Distribution
-
#backoff_interval Krakow::Consumer
-
#backoff_interval? Krakow::Distribution
-
#backoff_interval? Krakow::Consumer
-
#buffer Krakow::Ksocket
-
#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
-
#calculate_ready! Krakow::Distribution::Default
-
#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
-
#closedown_socket Krakow::Ksocket
-
#config Krakow::Producer::Http
-
#config? Krakow::Producer::Http
-
#confirm Krakow::Consumer
-
#confirm Krakow::FrameType::Message
-
#connect Krakow::Producer
-
#connected? Krakow::Producer
-
#connected? Krakow::Consumer
-
#connected? Krakow::Connection
-
#connection Krakow::Consumer
-
#connection Krakow::Producer
-
#connection Krakow::FrameType::Message
-
#connection_cleanup Krakow::Connection
-
#connection_failure Krakow::Producer
-
#connection_failure Krakow::Consumer
-
#connection_lookup Krakow::Distribution
-
#connection_options Krakow::Producer
-
#connection_options Krakow::Consumer
-
#connection_options? Krakow::Consumer
-
#connection_options? Krakow::Producer
-
#connections Krakow::Consumer
-
#connections Krakow::Distribution
-
#consumer Krakow::Distribution
-
#consumer Krakow::Consumer::Queue
-
#consumer? Krakow::Distribution
-
#consumer_cleanup Krakow::Consumer
-
#content Krakow::FrameType::Message
-
#content Krakow::FrameType::Error
-
#content Krakow::FrameType::Response
-
#content Krakow::FrameType
-
#count Krakow::Command::Rdy
-
#count? Krakow::Command::Rdy
-
#create_channel Krakow::Producer::Http
-
#create_topic Krakow::Producer::Http
-
decode Krakow::FrameType
-
#deflate Krakow::Connection
-
#deflate Krakow::Command::Identify
-
#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
-
#deregister_connection Krakow::Consumer::Queue
-
#direct_connect Krakow::Consumer
-
#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::Rdy
-
error Krakow::Command::Sub
-
error Krakow::Command::Touch
-
error Krakow::Command::Fin
-
error Krakow::Command
-
error Krakow::Command::Pub
-
error Krakow::Command::Cls
-
error Krakow::Command::Req
-
error Krakow::Command::Mpub
-
error Krakow::Command::Auth
-
error Krakow::Command::Identify
-
#error Krakow::FrameType::Error
-
#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
-
#get Krakow::Ksocket
-
#handle Krakow::Connection
-
#headers Krakow::ConnectionFeatures::Deflate::Io
-
#heartbeat_interval Krakow::Command::Identify
-
#heartbeat_interval? Krakow::Command::Identify
-
#host Krakow::Connection
-
#host Krakow::Producer
-
#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::Consumer
-
#init! Krakow::Connection
-
#initial_ready Krakow::Distribution
-
#initialize Krakow::FrameType::Message
-
#initialize Krakow::ConnectionFeatures::Ssl::Io
-
#initialize Krakow::Producer
-
#initialize Krakow::Consumer::Queue
-
#initialize Krakow::Consumer
-
#initialize Krakow::ConnectionFeatures::Deflate::Io
-
#initialize Krakow::Distribution
-
#initialize Krakow::Ksocket
-
#initialize Krakow::Producer::Http
-
#initialize Krakow::Connection
-
#initialize Krakow::Utils::Lazy::InstanceMethods
-
#initialize Krakow::ConnectionFeatures::SnappyFrames::Io
-
#inspect Krakow::Utils::Lazy::InstanceMethods
-
#instance_stamp Krakow::FrameType::Message
-
#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::Consumer
-
#max_in_flight? Krakow::Distribution
-
#message Krakow::FrameType::Message
-
#message Krakow::Command::Pub
-
#message? Krakow::FrameType::Message
-
#message? Krakow::Command::Pub
-
#message_id Krakow::FrameType::Message
-
#message_id Krakow::Command::Touch
-
#message_id Krakow::Command::Fin
-
#message_id Krakow::Command::Req
-
#message_id? Krakow::Command::Req
-
#message_id? Krakow::Command::Fin
-
#message_id? Krakow::FrameType::Message
-
#message_id? Krakow::Command::Touch
-
#messages Krakow::Consumer::Queue
-
#messages Krakow::Command::Mpub
-
#messages? Krakow::Command::Mpub
-
#method_missing Krakow::ConnectionFeatures::Ssl::Io
-
#method_missing Krakow::ConnectionFeatures::SnappyFrames::Io
-
#method_missing Krakow::ConnectionFeatures::Deflate::Io
-
#name Krakow::Command
-
#notifier Krakow::Connection
-
#notifier Krakow::Producer
-
#notifier Krakow::Consumer
-
#notifier? Krakow::Connection
-
#notifier? Krakow::Consumer
-
#nsqlookupd Krakow::Discovery
-
#nsqlookupd Krakow::Consumer
-
#nsqlookupd? Krakow::Discovery
-
#nsqlookupd? Krakow::Consumer
-
ok Krakow::Command::Pub
-
ok Krakow::Command::Cls
-
ok Krakow::Command
-
ok Krakow::Command::Mpub
-
ok Krakow::Command::Identify
-
ok Krakow::Command::Auth
-
ok Krakow::Command::Sub
-
#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
-
#pop Krakow::Consumer::Queue
-
#pop_order Krakow::Consumer::Queue
-
#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
-
#producer_cleanup Krakow::Producer
-
#push Krakow::Consumer::Queue
-
#put Krakow::Ksocket
-
#queue Krakow::Connection
-
#queue Krakow::Consumer
-
#queue? Krakow::Connection
-
#rdy_connections Krakow::Distribution::Default
-
#read_loop Krakow::Ksocket
-
#read_stream Krakow::ConnectionFeatures::SnappyFrames::Io
-
#read_stream Krakow::ConnectionFeatures::Deflate::Io
-
#reading? Krakow::Ksocket
-
#ready_for Krakow::Distribution
-
#receive Krakow::Connection
-
#receiving? Krakow::Connection
-
#reconnect_interval Krakow::Producer
-
#reconnect_interval? Krakow::Producer
-
#reconnect_retries Krakow::Producer
-
#reconnect_retries? Krakow::Producer
-
#recv Krakow::ConnectionFeatures::Ssl::Io
-
#recv Krakow::ConnectionFeatures::Deflate::Io
-
#recv Krakow::ConnectionFeatures::SnappyFrames::Io
-
#redistribute! Krakow::Distribution::Default
-
#redistribute! Krakow::Distribution
-
#register Krakow::Consumer
-
#register_connection Krakow::Consumer::Queue
-
#register_message Krakow::Distribution
-
#registry Krakow::Distribution
-
#registry_lookup Krakow::Distribution
-
#removal_callback Krakow::Consumer::Queue
-
#remove_connection Krakow::Distribution
-
#remove_message Krakow::Consumer
-
#requeue Krakow::FrameType::Message
-
#requeue Krakow::Consumer
-
#response Krakow::FrameType::Response
-
#response Krakow::Command
-
#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
-
#scrub_duplicate_message Krakow::Consumer::Queue
-
#secret Krakow::Command::Auth
-
#secret? Krakow::Command::Auth
-
#send_message Krakow::Producer::Http
-
#send_snappy_identifier Krakow::ConnectionFeatures::SnappyFrames::Io
-
#set_attributes Krakow::Utils::Lazy::ClassMethods
-
#set_ready_for Krakow::Distribution::Default
-
#set_ready_for Krakow::Distribution
-
#short_id Krakow::Command::Identify
-
#short_id? Krakow::Command::Identify
-
#size Krakow::Consumer::Queue
-
#snappy Krakow::Connection
-
#snappy Krakow::Command::Identify
-
#snappy? Krakow::Command::Identify
-
#socket Krakow::Connection
-
#socket Krakow::Ksocket
-
#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::Command::Identify
-
#tls_v1 Krakow::Connection
-
#tls_v1? Krakow::Command::Identify
-
#to_line Krakow::Command::Identify
-
#to_line Krakow::Command::Touch
-
#to_line Krakow::Command::Mpub
-
#to_line Krakow::Command::Auth
-
#to_line Krakow::Command::Sub
-
#to_line Krakow::Command::Req
-
#to_line Krakow::Command::Rdy
-
#to_line Krakow::Command::Pub
-
#to_line Krakow::Command::Nop
-
#to_line Krakow::Command::Fin
-
#to_line Krakow::Command::Cls
-
#to_line Krakow::Command
-
#to_s Krakow::Utils::Lazy::InstanceMethods
-
#to_s Krakow::Connection
-
#to_s Krakow::Producer
-
#to_s Krakow::Consumer
-
#topic Krakow::Producer::Http
-
#topic Krakow::Connection
-
#topic Krakow::Producer
-
#topic Krakow::Consumer
-
#topic? Krakow::Producer::Http
-
#topic? Krakow::Connection
-
#topic? Krakow::Producer
-
#topic? Krakow::Consumer
-
#topic_name Krakow::Command::Mpub
-
#topic_name Krakow::Command::Pub
-
#topic_name Krakow::Command::Sub
-
#topic_name? Krakow::Command::Mpub
-
#topic_name? Krakow::Command::Pub
-
#topic_name? Krakow::Command::Sub
-
#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
-
#validate_message Krakow::Consumer::Queue
-
#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::Producer::Http
-
#write Krakow::Producer
-
#write Krakow::ConnectionFeatures::SnappyFrames::Io
-
#write Krakow::ConnectionFeatures::Deflate::Io