Sha256: 4e28821035cc255c4da3780e2d22baf21dbbbab2a943f62cf0b6627fe19eeb8f

Contents?: true

Size: 1.18 KB

Versions: 42

Compression:

Stored size: 1.18 KB

Contents

# frozen_string_literal: true

module Rdkafka
  class Consumer
    # Information about a partition, used in {TopicPartitionList}.
    class Partition
      # Partition number
      # @return [Integer]
      attr_reader :partition

      # Partition's offset
      # @return [Integer, nil]
      attr_reader :offset

      # Partition's error code
      # @return [Integer]
      attr_reader :err

      # @private
      def initialize(partition, offset, err = 0)
        @partition = partition
        @offset = offset
        @err = err
      end

      # Human readable representation of this partition.
      # @return [String]
      def to_s
        message = "<Partition #{partition}"
        message += " offset=#{offset}" if offset
        message += " err=#{err}" if err != 0
        message += ">"
        message
      end

      # Human readable representation of this partition.
      # @return [String]
      def inspect
        to_s
      end

      # Whether another partition is equal to this
      # @return [Boolean]
      def ==(other)
        self.class == other.class &&
          self.partition == other.partition &&
          self.offset == other.offset
      end
    end
  end
end

Version data entries

42 entries across 42 versions & 2 rubygems

Version Path
rdkafka-0.20.0 lib/rdkafka/consumer/partition.rb
rdkafka-0.19.0 lib/rdkafka/consumer/partition.rb
rdkafka-0.18.0 lib/rdkafka/consumer/partition.rb
rdkafka-0.17.0 lib/rdkafka/consumer/partition.rb
rdkafka-0.13.1 lib/rdkafka/consumer/partition.rb
rdkafka-0.14.1 lib/rdkafka/consumer/partition.rb
rdkafka-0.15.2 lib/rdkafka/consumer/partition.rb
karafka-rdkafka-0.13.10 lib/rdkafka/consumer/partition.rb
rdkafka-0.16.1 lib/rdkafka/consumer/partition.rb
rdkafka-0.16.0 lib/rdkafka/consumer/partition.rb
rdkafka-0.16.0.beta1 lib/rdkafka/consumer/partition.rb
rdkafka-0.15.1 lib/rdkafka/consumer/partition.rb
karafka-rdkafka-0.14.5 lib/rdkafka/consumer/partition.rb
karafka-rdkafka-0.14.4 lib/rdkafka/consumer/partition.rb
karafka-rdkafka-0.14.3 lib/rdkafka/consumer/partition.rb
karafka-rdkafka-0.14.2 lib/rdkafka/consumer/partition.rb
rdkafka-0.15.0 lib/rdkafka/consumer/partition.rb
karafka-rdkafka-0.14.1 lib/rdkafka/consumer/partition.rb
rdkafka-0.14.0 lib/rdkafka/consumer/partition.rb
rdkafka-0.14.0.rc1 lib/rdkafka/consumer/partition.rb