Class: Flydata::SourceMysql::SyncRepair
- Inherits:
-
Flydata::Source::SyncRepair
- Object
- Flydata::Source::Component
- Flydata::Source::SyncRepair
- Flydata::SourceMysql::SyncRepair
- 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
Constructor Details
This class inherits a constructor from Flydata::Source::Component
Instance Method Details
#get_oldest_available_source_pos ⇒ Object
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 |