Table of Contents - poseidon-0.0.5 Documentation
Classes and Modules
- Poseidon
- Poseidon::BrokerPool
- Poseidon::BrokerPool::UnknownBroker
- Poseidon::ClusterMetadata
- Poseidon::CompressedValue
- Poseidon::Compression
- Poseidon::Compression::GzipCodec
- Poseidon::Compression::SnappyCodec
- Poseidon::Compression::UnrecognizedCompressionCodec
- Poseidon::Connection
- Poseidon::Connection::ConnectionFailedError
- Poseidon::Connection::TimeoutException
- Poseidon::Errors
- Poseidon::Errors::BrokerNotAvailable
- Poseidon::Errors::ChecksumError
- Poseidon::Errors::InvalidMessage
- Poseidon::Errors::InvalidMessageSize
- Poseidon::Errors::InvalidPartitionError
- Poseidon::Errors::LeaderNotAvailable
- Poseidon::Errors::MessageSizeTooLarge
- Poseidon::Errors::NotLeaderForPartition
- Poseidon::Errors::OffsetOutOfRange
- Poseidon::Errors::ProducerShutdownError
- Poseidon::Errors::ProtocolError
- Poseidon::Errors::ReplicaNotAvailable
- Poseidon::Errors::RequestTimedOut
- Poseidon::Errors::UnableToFetchMetadata
- Poseidon::Errors::UnknownError
- Poseidon::Errors::UnknownTopicOrPartition
- Poseidon::Errors::UnrecognizedProtocolError
- Poseidon::FetchedMessage
- Poseidon::Message
- Poseidon::MessageConductor
- Poseidon::MessageSet
- Poseidon::MessageToSend
- Poseidon::MessagesForBroker
- Poseidon::MessagesToSend
- Poseidon::MessagesToSend::InvalidPartitionError
- Poseidon::MessagesToSendBatch
- Poseidon::PartitionConsumer
- Poseidon::Producer
- Poseidon::ProducerCompressionConfig
- Poseidon::Protocol
- Poseidon::Protocol::ProtocolStruct
- Poseidon::Protocol::ProtocolStruct::DecodingError
- Poseidon::Protocol::ProtocolStruct::EncodingError
- Poseidon::Protocol::RequestBuffer
- Poseidon::Protocol::ResponseBuffer
- Poseidon::SyncProducer
- Poseidon::TopicMetadata
Methods
- ::check! — Poseidon::Compression::SnappyCodec
- ::codec_id — Poseidon::Compression::GzipCodec
- ::codec_id — Poseidon::Compression::SnappyCodec
- ::compress — Poseidon::Compression::GzipCodec
- ::compress — Poseidon::Compression::SnappyCodec
- ::consumer_for_partition — Poseidon::PartitionConsumer
- ::decompress — Poseidon::Compression::GzipCodec
- ::decompress — Poseidon::Compression::SnappyCodec
- ::find_codec — Poseidon::Compression
- ::logger — Poseidon
- ::logger= — Poseidon
- ::new — Poseidon::BrokerPool
- ::new — Poseidon::ClusterMetadata
- ::new — Poseidon::CompressedValue
- ::new — Poseidon::Connection
- ::new — Poseidon::FetchedMessage
- ::new — Poseidon::Message
- ::new — Poseidon::MessageConductor
- ::new — Poseidon::MessageSet
- ::new — Poseidon::MessageToSend
- ::new — Poseidon::MessagesForBroker
- ::new — Poseidon::MessagesToSend
- ::new — Poseidon::MessagesToSendBatch
- ::new — Poseidon::PartitionConsumer
- ::new — Poseidon::Producer
- ::new — Poseidon::ProducerCompressionConfig
- ::new — Poseidon::Protocol::ProtocolStruct
- ::new — Poseidon::Protocol::RequestBuffer
- ::new — Poseidon::Protocol::ResponseBuffer
- ::new — Poseidon::SyncProducer
- ::new — Poseidon::TopicMetadata
- ::null_logger — Poseidon
- ::open — Poseidon::BrokerPool
- ::open — Poseidon::Connection
- ::prepend_crc32 — Poseidon::Protocol::ProtocolStruct
- ::prepend_crc32? — Poseidon::Protocol::ProtocolStruct
- ::prepend_size — Poseidon::Protocol::ProtocolStruct
- ::prepend_size? — Poseidon::Protocol::ProtocolStruct
- ::read — Poseidon::Message
- ::read — Poseidon::MessageSet
- ::read — Poseidon::Protocol::ProtocolStruct
- ::read — Poseidon::TopicMetadata
- ::read_without_size — Poseidon::MessageSet
- ::size_bound_array — Poseidon::Protocol::ProtocolStruct
- ::size_bound_array? — Poseidon::Protocol::ProtocolStruct
- ::truncatable — Poseidon::Protocol::ProtocolStruct
- ::truncatable? — Poseidon::Protocol::ProtocolStruct
- ::type_map — Poseidon::Protocol::ProtocolStruct
- ::type_map= — Poseidon::Protocol::ProtocolStruct
- #<< — Poseidon::MessageSet
- #== — Poseidon::Message
- #== — Poseidon::MessageSet
- #== — Poseidon::TopicMetadata
- #add — Poseidon::MessagesForBroker
- #append — Poseidon::Protocol::RequestBuffer
- #attributes — Poseidon::Message
- #available_partition_count — Poseidon::TopicMetadata
- #available_partitions — Poseidon::TopicMetadata
- #broker — Poseidon::ClusterMetadata
- #build_producer — Poseidon::Producer
- #build_protocol_objects — Poseidon::MessagesForBroker
- #build_struct — Poseidon::Message
- #build_topic_fetch_request — Poseidon::PartitionConsumer
- #build_topic_offset_request — Poseidon::PartitionConsumer
- #build_topic_set — Poseidon::MessagesToSend
- #bytes — Poseidon::Protocol::RequestBuffer
- #bytes — Poseidon::Protocol::ResponseBuffer
- #bytes_remaining — Poseidon::Protocol::ResponseBuffer
- #checksum_failed? — Poseidon::Protocol::ProtocolStruct
- #close — Poseidon::BrokerPool
- #close — Poseidon::Connection
- #close — Poseidon::PartitionConsumer
- #close — Poseidon::Producer
- #close — Poseidon::SyncProducer
- #compress — Poseidon::MessageSet
- #compressed? — Poseidon::Message
- #compression_codec — Poseidon::CompressedValue
- #compression_codec — Poseidon::Message
- #compression_codec_for_topic — Poseidon::ProducerCompressionConfig
- #compression_codec_id — Poseidon::Message
- #connection — Poseidon::BrokerPool
- #convert_to_messages_objects — Poseidon::Producer
- #decompressed — Poseidon::CompressedValue
- #decompressed_value — Poseidon::Message
- #destination — Poseidon::MessageConductor
- #determine_partition — Poseidon::MessageConductor
- #ensure_connected — Poseidon::Connection
- #ensure_metadata_available_for_topics — Poseidon::SyncProducer
- #ensure_read_or_timeout — Poseidon::Connection
- #ensure_write_or_timeout — Poseidon::Connection
- #eof? — Poseidon::Protocol::ResponseBuffer
- #eql? — Poseidon::Message
- #eql? — Poseidon::MessageSet
- #eql? — Poseidon::TopicMetadata
- #error_class — Poseidon::Protocol::ProtocolStruct
- #execute_api_call — Poseidon::BrokerPool
- #exists? — Poseidon::TopicMetadata
- #fetch — Poseidon::Connection
- #fetch — Poseidon::PartitionConsumer
- #fetch_metadata — Poseidon::BrokerPool
- #fetch_metadata_from_broker — Poseidon::BrokerPool
- #flatten — Poseidon::MessageSet
- #handle_option — Poseidon::SyncProducer
- #handle_options — Poseidon::PartitionConsumer
- #handle_options — Poseidon::SyncProducer
- #have_header? — Poseidon::Protocol::ProtocolStruct
- #have_metadata_for_topics? — Poseidon::ClusterMetadata
- #int16 — Poseidon::Protocol::RequestBuffer
- #int16 — Poseidon::Protocol::ResponseBuffer
- #int32 — Poseidon::Protocol::RequestBuffer
- #int32 — Poseidon::Protocol::ResponseBuffer
- #int64 — Poseidon::Protocol::RequestBuffer
- #int64 — Poseidon::Protocol::ResponseBuffer
- #int8 — Poseidon::Protocol::RequestBuffer
- #int8 — Poseidon::Protocol::ResponseBuffer
- #key — Poseidon::Message
- #lead_broker_for_partition — Poseidon::ClusterMetadata
- #leader_available? — Poseidon::TopicMetadata
- #max_bytes — Poseidon::PartitionConsumer
- #max_wait_ms — Poseidon::PartitionConsumer
- #maybe_prepend_crc32 — Poseidon::Protocol::ProtocolStruct
- #maybe_prepend_size — Poseidon::Protocol::ProtocolStruct
- #messages — Poseidon::MessageSet
- #messages_for_brokers — Poseidon::MessagesToSend
- #messages_for_brokers — Poseidon::MessagesToSendBatch
- #metadata_for_topics — Poseidon::ClusterMetadata
- #min_bytes — Poseidon::PartitionConsumer
- #name — Poseidon::TopicMetadata
- #needs_metadata? — Poseidon::MessagesToSend
- #new_connection — Poseidon::BrokerPool
- #next_correlation_id — Poseidon::Connection
- #next_offset — Poseidon::PartitionConsumer
- #next_partition_counter — Poseidon::MessageConductor
- #objects_with_errors — Poseidon::Message
- #objects_with_errors — Poseidon::MessageSet
- #objects_with_errors — Poseidon::Protocol::ProtocolStruct
- #objects_with_errors — Poseidon::TopicMetadata
- #offset — Poseidon::Connection
- #offset — Poseidon::Message
- #partition_count — Poseidon::TopicMetadata
- #partition_for_keyed_message — Poseidon::MessageConductor
- #partition_for_keyless_message — Poseidon::MessageConductor
- #partition_leader — Poseidon::TopicMetadata
- #partitions — Poseidon::TopicMetadata
- #partitions_by_id — Poseidon::TopicMetadata
- #peek — Poseidon::Protocol::ResponseBuffer
- #pending_messages? — Poseidon::MessagesToSend
- #prepend_crc32 — Poseidon::Protocol::RequestBuffer
- #prepend_size — Poseidon::Protocol::RequestBuffer
- #produce — Poseidon::Connection
- #raise_connection_failed_error — Poseidon::Connection
- #raise_error — Poseidon::Protocol::ProtocolStruct
- #raise_error_if_one_exists — Poseidon::Protocol::ProtocolStruct
- #read — Poseidon::Protocol::ProtocolStruct
- #read — Poseidon::Protocol::ResponseBuffer
- #read_member — Poseidon::Protocol::ProtocolStruct
- #read_response — Poseidon::Connection
- #read_type — Poseidon::Protocol::ProtocolStruct
- #refresh_interval_elapsed? — Poseidon::SyncProducer
- #refresh_metadata — Poseidon::SyncProducer
- #request_common — Poseidon::Connection
- #resolve_offset_if_necessary — Poseidon::PartitionConsumer
- #send_messages — Poseidon::Producer
- #send_messages — Poseidon::SyncProducer
- #send_request — Poseidon::Connection
- #send_to_broker — Poseidon::SyncProducer
- #shutdown — Poseidon::BrokerPool
- #shutdown — Poseidon::Producer
- #shutdown — Poseidon::SyncProducer
- #string — Poseidon::Protocol::RequestBuffer
- #string — Poseidon::Protocol::ResponseBuffer
- #successfully_sent — Poseidon::MessagesForBroker
- #successfully_sent — Poseidon::MessagesToSend
- #to_compressed_message — Poseidon::MessageSet
- #to_s — Poseidon::ClusterMetadata
- #to_s — Poseidon::Protocol::RequestBuffer
- #to_s — Poseidon::Protocol::ResponseBuffer
- #to_s — Poseidon::TopicMetadata
- #topic_metadata — Poseidon::Connection
- #topic_metadatas — Poseidon::MessageConductor
- #topics — Poseidon::ClusterMetadata
- #truncated? — Poseidon::Protocol::ProtocolStruct
- #type_map — Poseidon::Protocol::ProtocolStruct
- #update — Poseidon::ClusterMetadata
- #update_brokers — Poseidon::ClusterMetadata
- #update_known_brokers — Poseidon::BrokerPool
- #update_topics — Poseidon::ClusterMetadata
- #validate_options — Poseidon::Producer
- #value — Poseidon::Message
- #write — Poseidon::Message
- #write — Poseidon::MessageSet
- #write — Poseidon::Protocol::ProtocolStruct
- #write — Poseidon::TopicMetadata
- #write_member — Poseidon::Protocol::ProtocolStruct
- #write_type — Poseidon::Protocol::ProtocolStruct