Sha256: 8e945efc2d1a202570c4d3d9849618cc83373f9fbf54c84c853652b1f26e1ee2

Contents?: true

Size: 394 Bytes

Versions: 54

Compression:

Stored size: 394 Bytes

Contents

module Mysql
  class BinLogPosition
    include Comparable
    attr_accessor :file, :pos

    def initialize(binlog_content)
      items = binlog_content.split("\t")
      @file = items[0]
      @pos = items[1].to_i
    end

    def <=>(obj)
      (self.file <=> obj.file) == 0 ? (self.pos <=> obj.pos) : (self.file <=> obj.file)
    end

    def to_s
      "#{file}\t#{pos}"
    end
  end
end

Version data entries

54 entries across 54 versions & 1 rubygems

Version Path
flydata-0.3.16 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.3.15 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.3.14 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.3.13 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.3.12 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.3.11 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.3.10 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.3.9 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.3.8 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.3.7 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.3.6 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.3.5 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.3.4 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.3.3 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.3.2 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.3.1 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.3.0 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.2.30 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.2.29 lib/flydata/fluent-plugins/mysql/binlog_position.rb
flydata-0.2.28 lib/flydata/fluent-plugins/mysql/binlog_position.rb