Module: Pulsar::Internal

Defined in:

lib/pulsar/internal.rb,
lib/pulsar/internal/promise.rb,
lib/pulsar/internal/connection.rb,
lib/pulsar/internal/frame_codec.rb,
lib/pulsar/internal/bounded_queue.rb,
lib/pulsar/internal/consumer_impl.rb,
lib/pulsar/internal/producer_impl.rb,
lib/pulsar/internal/tcp_transport.rb,
lib/pulsar/internal/lookup_service.rb,
lib/pulsar/internal/thread_runtime.rb,
lib/pulsar/internal/command_factory.rb,
lib/pulsar/internal/broker_error_mapper.rb

Overview

Internal implementation namespace; not part of the public API.

Defined Under Namespace

Classes: BoundedQueue, BrokerErrorMapper, CommandFactory, Connection, ConsumerImpl, FrameCodec, LookupService, ProducerImpl, Promise, TcpTransport, ThreadRuntime