require 'flydata/source/source_pos'
require 'flydata/compatibility_check'
require 'flydata-core/mysql/command_generator'
require 'flydata-core/mysql/binlog_pos'

module Flydata
module SourceMysql

class SourcePos < Source::SourcePos
  def create_source_pos(source_pos_str)
    FlydataCore::Mysql::BinlogPos.new(source_pos_str)
  end

  def resume_pos(source_pos)
    #TODO check Binlog file (source_pos.filename) is available
    FlydataCore::Mysql::BinlogPos.new(source_pos.filename, 4) # 4 is the first position of binlog file
  end
end

end
end