Sha256: 10f903f6c4720b6caadbc83f251285b799cebab4857025bb77ff1935029ad833
Contents?: true
Size: 548 Bytes
Versions: 45
Compression:
Stored size: 548 Bytes
Contents
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
Version data entries
45 entries across 45 versions & 1 rubygems