Class: Flydata::SourceMysql::SourcePos

Inherits:
Flydata::Source::SourcePos show all
Defined in:
lib/flydata/source_mysql/source_pos.rb

Instance Method Summary collapse

Methods inherited from Flydata::Source::SourcePos

inherited, #initialize

Methods inherited from Flydata::Source::Component

#initialize

Constructor Details

This class inherits a constructor from Flydata::Source::SourcePos

Instance Method Details

#create_source_pos(source_pos_str) ⇒ Object 



10
11
12
 
# File 'lib/flydata/source_mysql/source_pos.rb', line 10

def create_source_pos(source_pos_str)
  FlydataCore::Mysql::BinlogPos.new(source_pos_str)
end

#resume_pos(source_pos) ⇒ Object 



14
15
16
17
 
# File 'lib/flydata/source_mysql/source_pos.rb', line 14

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