Module: Poseidon

Defined in:
lib/poseidon.rb,
lib/poseidon/message.rb,
lib/poseidon/version.rb,
lib/poseidon/producer.rb,
lib/poseidon/protocol.rb,
lib/poseidon/connection.rb,
lib/poseidon/broker_pool.rb,
lib/poseidon/compression.rb,
lib/poseidon/message_set.rb,
lib/poseidon/sync_producer.rb,
lib/poseidon/topic_metadata.rb,
lib/poseidon/fetched_message.rb,
lib/poseidon/message_to_send.rb,
lib/poseidon/cluster_metadata.rb,
lib/poseidon/compressed_value.rb,
lib/poseidon/messages_to_send.rb,
lib/poseidon/message_conductor.rb,
lib/poseidon/partition_consumer.rb,
lib/poseidon/messages_for_broker.rb,
lib/poseidon/compression/gzip_codec.rb,
lib/poseidon/messages_to_send_batch.rb,
lib/poseidon/protocol/request_buffer.rb,
lib/poseidon/compression/snappy_codec.rb,
lib/poseidon/protocol/protocol_struct.rb,
lib/poseidon/protocol/response_buffer.rb,
lib/poseidon/producer_compression_config.rb

Overview

Top level Poseidon namespace

Defined Under Namespace

Modules: Errors Classes: FetchedMessage, MessageToSend, PartitionConsumer, Producer

Constant Summary collapse

VERSION =

Unstable! API May Change!

"0.0.13"

Class Method Summary collapse

Class Method Details

.logger ⇒ Object 



84
85
86
 
# File 'lib/poseidon.rb', line 84

def self.logger
  @logger ||= null_logger
end

.logger=(logger) ⇒ Object 



88
89
90
 
# File 'lib/poseidon.rb', line 88

def self.logger=(logger)
  @logger = logger
end

.null_logger ⇒ Object 



93
94
95
96
97
98
 
# File 'lib/poseidon.rb', line 93

def self.null_logger
  devnull = RUBY_PLATFORM =~ /w32/ ? 'nul' : '/dev/null'
  l = Logger.new(devnull)
  l.level = Logger::INFO
  l
end