Class: Flydata::SourceMysql::SyncRepair

Inherits:
Flydata::Source::SyncRepair show all
Defined in:
lib/flydata/source_mysql/sync_repair.rb

Defined Under Namespace

Classes: BinarylogsCheck

Instance Method Summary collapse

Methods inherited from Flydata::Source::SyncRepair

get_oldest_available_source_pos, inherited

Methods inherited from Flydata::Source::Component

#initialize

Constructor Details

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

Instance Method Details

#get_oldest_available_source_posObject


9
10
11
12
13
# File 'lib/flydata/source_mysql/sync_repair.rb', line 9

def get_oldest_available_source_pos
  binary_logs = BinarylogsCheck.new(de[Sync::SOURCE_PREFERENCE_NAME]).get_binary_logs
  oldest_binlog_str = binary_logs.first.values.join("\t")
  oldest_binlog =  source.source_pos.create_source_pos(oldest_binlog_str)
end