Table of Contents - pulsar_sdk-0.8.8 Documentation
Pages
Classes and Modules
- Google::Protobuf
- Google::Protobuf::MessageExts
- Pulsar
- Pulsar::Proto
- Pulsar::Proto::BaseCommand
- Pulsar::Proto::CommandAck
- Pulsar::Proto::CommandGetTopicsOfNamespace
- Pulsar::Proto::CommandLookupTopicResponse
- Pulsar::Proto::CommandPartitionedTopicMetadataResponse
- Pulsar::Proto::CommandSubscribe
- Pulsar::Proto::Schema
- PulsarAdmin
- PulsarAdmin::Api
- PulsarSdk
- PulsarSdk::Client
- PulsarSdk::Client::Connection
- PulsarSdk::Client::Connection::ConsumerHandler
- PulsarSdk::Client::Connection::ProducerHandler
- PulsarSdk::Client::Connection::ResponseContainer
- PulsarSdk::Client::Connection::SeqGenerator
- PulsarSdk::Client::Connection::Status
- PulsarSdk::Client::ConnectionPool
- PulsarSdk::Client::Rpc
- PulsarSdk::Consumer
- PulsarSdk::Consumer::Base
- PulsarSdk::Consumer::Base::SeqGenerator
- PulsarSdk::Consumer::Manager
- PulsarSdk::Consumer::MessageTracker
- PulsarSdk::Consumer::MessageTracker::NackQueue
- PulsarSdk::Consumer::MessageTracker::ReceivedQueue
- PulsarSdk::Formatter
- PulsarSdk::Options
- PulsarSdk::Options::Base
- PulsarSdk::Options::Connection
- PulsarSdk::Options::Consumer
- PulsarSdk::Options::Producer
- PulsarSdk::Options::Reader
- PulsarSdk::Options::Tls
- PulsarSdk::Producer
- PulsarSdk::Producer::Base
- PulsarSdk::Producer::Manager
- PulsarSdk::Producer::Message
- PulsarSdk::Producer::Murmur3
- PulsarSdk::Producer::ReceiptQueue
- PulsarSdk::Producer::Router
- PulsarSdk::Producer::SeqGenerator
- PulsarSdk::Protocol
- PulsarSdk::Protocol::Frame
- PulsarSdk::Protocol::Lookup
- PulsarSdk::Protocol::Message
- PulsarSdk::Protocol::Namespace
- PulsarSdk::Protocol::Partitioned
- PulsarSdk::Protocol::Reader
- PulsarSdk::Protocol::Structure
- PulsarSdk::Protocol::Topic
- PulsarSdk::Tweaks
- PulsarSdk::Tweaks::AssignAttributes
- PulsarSdk::Tweaks::BaseCommand
- PulsarSdk::Tweaks::BinaryHeap
- PulsarSdk::Tweaks::CleanInspect
- PulsarSdk::Tweaks::TimeAtMicrosecond
- PulsarSdk::Tweaks::TimeAtMicrosecond::ClassMethods
- PulsarSdk::Tweaks::TimeAtMicrosecond::base
- PulsarSdk::Tweaks::TimeoutQueue
- PulsarSdk::Tweaks::WaitMap
- TimeX
Methods
- ::binary — PulsarSdk::Protocol::Frame
- ::crc32 — PulsarSdk::Protocol::Frame
- ::decode — PulsarSdk::Protocol::Frame
- ::encode — PulsarSdk::Protocol::Frame
- ::encode_command — PulsarSdk::Protocol::Frame
- ::establish — PulsarSdk::Client::Connection
- ::new — PulsarAdmin::Api
- ::new — PulsarSdk::Client::Connection
- ::new — PulsarSdk::Client::Connection::Status
- ::new — PulsarSdk::Client::Connection::SeqGenerator
- ::new — PulsarSdk::Client::ConnectionPool
- ::new — PulsarSdk::Client::Rpc
- ::new — PulsarSdk::Consumer::Base
- ::new — PulsarSdk::Consumer::Base::SeqGenerator
- ::new — PulsarSdk::Consumer::Manager
- ::new — PulsarSdk::Consumer::MessageTracker
- ::new — PulsarSdk::Producer::Base
- ::new — PulsarSdk::Producer::SeqGenerator
- ::new — PulsarSdk::Producer::Manager
- ::new — PulsarSdk::Producer::Message
- ::new — PulsarSdk::Producer::Router
- ::new — PulsarSdk::Protocol::Lookup
- ::new — PulsarSdk::Protocol::Namespace
- ::new — PulsarSdk::Protocol::Partitioned
- ::new — PulsarSdk::Protocol::Reader
- ::new — PulsarSdk::Protocol::Structure
- ::new — PulsarSdk::Tweaks::BinaryHeap
- ::new — PulsarSdk::Tweaks::TimeoutQueue
- ::new — PulsarSdk::Tweaks::WaitMap
- ::new — PulsarSdk::Tweaks::AssignAttributes
- ::parse — PulsarSdk::Protocol::Topic
- ::prepended — PulsarSdk::Tweaks::TimeAtMicrosecond
- #ack — PulsarSdk::Protocol::Message
- #ack_handler — PulsarSdk::Consumer::MessageTracker
- #active_status — PulsarSdk::Client::Connection
- #add — PulsarSdk::Tweaks::TimeoutQueue
- #add — PulsarSdk::Tweaks::WaitMap
- #add_consumer — PulsarSdk::Consumer::MessageTracker
- #adjust — PulsarSdk::Tweaks::BinaryHeap
- #assign_attributes — PulsarSdk::Tweaks::AssignAttributes
- #at_timestamp — PulsarSdk::Tweaks::TimeAtMicrosecond::ClassMethods
- #attribute_names — PulsarSdk::Tweaks::BaseCommand
- #binary_string — PulsarSdk::Producer::Message
- #bind_handler! — PulsarSdk::Consumer::Base
- #bind_handler! — PulsarSdk::Producer::Base
- #build_from — PulsarSdk::Tweaks::BinaryHeap
- #call — PulsarSdk::Formatter
- #clear — PulsarSdk::Tweaks::TimeoutQueue
- #clear — PulsarSdk::Tweaks::WaitMap
- #close — PulsarSdk::Client::Connection
- #close — PulsarSdk::Client::ConnectionPool
- #close — PulsarSdk::Client::Rpc
- #close — PulsarSdk::Consumer::Base
- #close — PulsarSdk::Consumer::Manager
- #close — PulsarSdk::Consumer::MessageTracker
- #close — PulsarSdk::Producer::Base
- #close — PulsarSdk::Producer::Manager
- #close — PulsarSdk::Tweaks::TimeoutQueue
- #close — PulsarSdk::Tweaks::WaitMap
- #closed? — PulsarSdk::Client::Connection
- #combine_default_value — PulsarAdmin::Api
- #compare — PulsarSdk::Tweaks::BinaryHeap
- #confirmed? — PulsarSdk::Protocol::Message
- #connect — PulsarSdk::Client::Connection
- #connecting_through_proxy? — PulsarSdk::Options::Connection
- #connection — PulsarSdk::Client::Rpc
- #create — PulsarSdk::Client
- #create — PulsarSdk::Consumer
- #create — PulsarSdk::Producer
- #create_client — PulsarAdmin
- #create_client — PulsarSdk
- #create_consumer — PulsarSdk
- #create_namespace — PulsarAdmin::Api
- #create_producer — PulsarSdk::Client::Rpc
- #create_producer — PulsarSdk
- #create_reader — PulsarSdk::Client::Rpc
- #create_topic — PulsarAdmin::Api
- #decode — PulsarSdk::Protocol::Structure
- #delete — PulsarAdmin::Api
- #delete — PulsarSdk::Tweaks::WaitMap
- #delete_namespace — PulsarAdmin::Api
- #delete_topic — PulsarAdmin::Api
- #disconnect? — PulsarSdk::Consumer::Base
- #disconnect? — PulsarSdk::Producer::Base
- #do_hand_shake — PulsarSdk::Client::Connection
- #each — PulsarSdk::Tweaks::WaitMap
- #ensure_connection — PulsarSdk::Consumer::Manager
- #ensure_connection — PulsarSdk::Producer::Manager
- #ensure_interface_implemented! — PulsarSdk::Protocol::Reader
- #execute — PulsarSdk::Consumer::Base
- #execute — PulsarSdk::Producer::Base
- #execute — PulsarSdk::Producer::Manager
- #execute_async — PulsarSdk::Consumer::Base
- #execute_async — PulsarSdk::Consumer::MessageTracker
- #execute_async — PulsarSdk::Producer::Base
- #execute_async — PulsarSdk::Producer::Manager
- #extract_addr — PulsarSdk::Protocol::Lookup
- #fetch — PulsarSdk::Client::ConnectionPool
- #filling_message — PulsarSdk::Producer::Base
- #find — PulsarSdk::Tweaks::WaitMap
- #find_child_idx — PulsarSdk::Tweaks::BinaryHeap
- #flow — PulsarSdk::Consumer::Base
- #flow — PulsarSdk::Consumer::Manager
- #flow_if_need — PulsarSdk::Consumer::Base
- #fmix — PulsarSdk::Producer::Murmur3
- #get — PulsarAdmin::Api
- #good? — PulsarSdk::Tweaks::BinaryHeap
- #grab_cnx — PulsarSdk::Consumer::Base
- #grab_cnx — PulsarSdk::Producer::Base
- #handle_base_command — PulsarSdk::Client::Connection
- #handle_ids — PulsarSdk::Tweaks::BaseCommand
- #handle_message — PulsarSdk::Client::Connection
- #handle_ping — PulsarSdk::Client::Connection
- #handle_response — PulsarSdk::Client::Connection
- #handle_restful_path — PulsarAdmin::Api
- #handle_send_receipt — PulsarSdk::Client::Connection
- #hash — PulsarSdk::Producer::Murmur3
- #increase_fetched — PulsarSdk::Consumer::Base
- #init_consumer — PulsarSdk::Consumer::Base
- #init_consumer_by — PulsarSdk::Consumer::Manager
- #init_producer — PulsarSdk::Producer::Base
- #init_producer_by — PulsarSdk::Producer::Manager
- #insert — PulsarSdk::Tweaks::BinaryHeap
- #inspect — PulsarSdk::Tweaks::CleanInspect
- #int32_hash — PulsarSdk::Producer::Murmur3
- #json_encode! — PulsarSdk::Producer::Message
- #key= — PulsarSdk::Producer::Message
- #l_idx — PulsarSdk::Tweaks::BinaryHeap
- #lchid — PulsarSdk::Tweaks::BinaryHeap
- #list_namespaces — PulsarAdmin::Api
- #listen — PulsarSdk::Client::Connection
- #listen — PulsarSdk::Consumer::Manager
- #logger — PulsarSdk
- #logger= — PulsarSdk
- #lookup — PulsarSdk::Client::Rpc
- #lookup — PulsarSdk::Protocol::Lookup
- #method_missing — PulsarSdk::Consumer::Base::SeqGenerator
- #method_missing — PulsarSdk::Producer::SeqGenerator
- #mk_domain — PulsarSdk::Protocol::Topic
- #mk_topic — PulsarSdk::Protocol::Topic
- #mmix — PulsarSdk::Producer::Murmur3
- #murmur3_hash — PulsarSdk::Producer::Router
- #nack — PulsarSdk::Protocol::Message
- #namespace_topics — PulsarAdmin::Api
- #namespace_topics — PulsarSdk::Client::Rpc
- #new_consumer_id — PulsarSdk::Consumer::Base::SeqGenerator
- #new_producer_id — PulsarSdk::Producer::SeqGenerator
- #new_sequence_id — PulsarSdk::Producer::SeqGenerator
- #next! — PulsarSdk::Client::Connection::SeqGenerator
- #orig_to_json — Google::Protobuf::MessageExts
- #orig_to_proto — Google::Protobuf::MessageExts
- #p_idx — PulsarSdk::Tweaks::BinaryHeap
- #partition_topics — PulsarSdk::Client::Rpc
- #partitioned? — PulsarSdk::Protocol::Partitioned
- #partitions — PulsarSdk::Protocol::Partitioned
- #peek_message — PulsarAdmin::Api
- #peek_messages — PulsarAdmin::Api
- #ping — PulsarSdk::Client::Connection
- #ping! — PulsarSdk::Client::Connection::Status
- #pop — PulsarSdk::Tweaks::TimeoutQueue
- #port_and_host_from — PulsarSdk::Options::Connection
- #producer_name= — PulsarSdk::Producer::Message
- #proxy_to_broker_url — PulsarSdk::Options::Connection
- #put — PulsarAdmin::Api
- #r_idx — PulsarSdk::Tweaks::BinaryHeap
- #raw_get — PulsarAdmin::Api
- #rchild — PulsarSdk::Tweaks::BinaryHeap
- #read — PulsarSdk::Protocol::Reader
- #read — PulsarSdk::Protocol::Structure
- #read_checksum — PulsarSdk::Protocol::Structure
- #read_command — PulsarSdk::Protocol::Reader
- #read_frame_size — PulsarSdk::Protocol::Reader
- #read_from_connection — PulsarSdk::Client::Connection
- #read_fully — PulsarSdk::Protocol::Reader
- #read_magic_number — PulsarSdk::Protocol::Structure
- #read_metadata — PulsarSdk::Protocol::Structure
- #read_remaining — PulsarSdk::Protocol::Reader
- #read_remaining — PulsarSdk::Protocol::Structure
- #reader — PulsarSdk::Client::Connection
- #real_producer — PulsarSdk::Producer::Manager
- #receipt — PulsarSdk::Producer::Base
- #receive — PulsarSdk::Consumer::Manager
- #receive — PulsarSdk::Consumer::MessageTracker
- #received! — PulsarSdk::Client::Connection::Status
- #remove_empty_instance_variables! — PulsarSdk::Tweaks::AssignAttributes
- #remove_handler! — PulsarSdk::Consumer::Base
- #request — PulsarSdk::Client::Connection
- #request — PulsarSdk::Client::Rpc
- #request_any_broker — PulsarSdk::Client::Rpc
- #request_ok? — PulsarAdmin::Api
- #rewind — PulsarSdk::Protocol::Structure
- #rotl — PulsarSdk::Producer::Murmur3
- #route — PulsarSdk::Producer::Router
- #run_checker — PulsarSdk::Client::ConnectionPool
- #sequence_id= — PulsarSdk::Producer::Message
- #set_default — PulsarSdk::Options::Connection
- #set_default — PulsarSdk::Options::Consumer
- #set_default — PulsarSdk::Options::Producer
- #set_default — PulsarSdk::Tweaks::AssignAttributes
- #set_seq_generator — PulsarSdk::Producer::Base
- #shift — PulsarSdk::Consumer::MessageTracker
- #shift — PulsarSdk::Tweaks::BinaryHeap
- #size — PulsarSdk::Tweaks::TimeoutQueue
- #start — PulsarSdk::Client::Connection
- #string_hash — PulsarSdk::Producer::Router
- #subscribe — PulsarSdk::Client::Rpc
- #subscription — PulsarSdk::Consumer::Base
- #subscription — PulsarSdk::Consumer::Manager
- #success_response? — PulsarSdk::Protocol::Partitioned
- #swap — PulsarSdk::Tweaks::BinaryHeap
- #timestamp — PulsarSdk::Tweaks::TimeAtMicrosecond
- #to_json — Google::Protobuf::MessageExts
- #to_proto — Google::Protobuf::MessageExts
- #to_s — PulsarSdk::Protocol::Topic
- #top — PulsarSdk::Tweaks::BinaryHeap
- #topic_metadata — PulsarSdk::Protocol::Partitioned
- #topics — PulsarSdk::Protocol::Namespace
- #track — PulsarSdk::Consumer::MessageTracker
- #try_decode_body — PulsarAdmin::Api
- #unbind_handler! — PulsarSdk::Producer::Base
- #unsubscribe — PulsarSdk::Consumer::Base
- #unsubscribe — PulsarSdk::Consumer::Manager
- #validate_presence! — Google::Protobuf::MessageExts
- #wait — PulsarSdk::Client::Connection::Status
- #write — PulsarSdk::Client::Connection
- #write — PulsarSdk::Consumer::Base
- #write — PulsarSdk::Producer::Base