Contents

module Kafka
  PendingMessage = Struct.new(
    "PendingMessage",
    :value,
    :key,
    :topic,
    :partition,
    :partition_key,
    :create_time,
    :bytesize)
end

Version data entries

21 entries across 21 versions & 1 rubygems

Version	Path
ruby-kafka-0.4.0	lib/kafka/pending_message.rb
ruby-kafka-0.4.0.beta1	lib/kafka/pending_message.rb
ruby-kafka-0.3.18.beta2	lib/kafka/pending_message.rb
ruby-kafka-0.3.18.beta1	lib/kafka/pending_message.rb
ruby-kafka-0.3.17	lib/kafka/pending_message.rb
ruby-kafka-0.3.16	lib/kafka/pending_message.rb
ruby-kafka-0.3.16.beta2	lib/kafka/pending_message.rb
ruby-kafka-0.3.16.beta1	lib/kafka/pending_message.rb
ruby-kafka-0.3.15	lib/kafka/pending_message.rb
ruby-kafka-0.3.15.beta3	lib/kafka/pending_message.rb
ruby-kafka-0.3.15.beta2	lib/kafka/pending_message.rb
ruby-kafka-0.3.15.beta1	lib/kafka/pending_message.rb
ruby-kafka-0.3.14	lib/kafka/pending_message.rb
ruby-kafka-0.3.13.beta4	lib/kafka/pending_message.rb
ruby-kafka-0.3.13.beta3	lib/kafka/pending_message.rb
ruby-kafka-0.3.13.beta2	lib/kafka/pending_message.rb
ruby-kafka-0.3.13.beta1	lib/kafka/pending_message.rb
ruby-kafka-0.3.12	lib/kafka/pending_message.rb
ruby-kafka-0.3.11	lib/kafka/pending_message.rb
ruby-kafka-0.3.10	lib/kafka/pending_message.rb