Module: MysqlReplicator

Defined in:
lib/mysql_replicator/error.rb,
lib/mysql_replicator.rb,
lib/mysql_replicator/logger.rb,
lib/mysql_replicator/version.rb,
lib/mysql_replicator/connection.rb,
lib/mysql_replicator/string_util.rb,
lib/mysql_replicator/binlog_client.rb,
lib/mysql_replicator/string_io_util.rb,
lib/mysql_replicator/connections/auth.rb,
lib/mysql_replicator/binlogs/constants.rb,
lib/mysql_replicator/connections/query.rb,
lib/mysql_replicator/binlogs/json_parser.rb,
lib/mysql_replicator/binlogs/event_parser.rb,
lib/mysql_replicator/binlogs/column_parser.rb,
lib/mysql_replicator/connections/handshake.rb,
lib/mysql_replicator/binlogs/xid_event_parser.rb,
lib/mysql_replicator/binlogs/rows_event_parser.rb,
lib/mysql_replicator/binlogs/query_event_parser.rb,
lib/mysql_replicator/binlogs/rotate_event_parser.rb,
lib/mysql_replicator/binlogs/table_map_event_parser.rb,
lib/mysql_replicator/binlogs/format_description_event_parser.rb

Overview

rbs_inline: enabled

Defined Under Namespace

Modules: Binlogs, Connections Classes: BinlogClient, Connection, Error, Logger, StringIOUtil, StringUtil

Constant Summary collapse

VERSION =

: String

'0.2.0'

Class Method Summary collapse

Class Method Details

.logger=(custom_logger) ⇒ Object 



48
49
50
 
# File 'lib/mysql_replicator.rb', line 48

def self.logger=(custom_logger)
  MysqlReplicator::Logger.logger = custom_logger
end

.run(host: '127.0.0.1', port: 3306, user: 'root', password: 'root', database: '', &block) ⇒ Object 



33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/mysql_replicator.rb', line 33

def self.run(host: '127.0.0.1', port: 3306, user: 'root', password: 'root', database: '', &block)
  conn = MysqlReplicator::Connection.new(
    host: host,
    port: port,
    user: user,
    password: password,
    database: database
  )
  client = MysqlReplicator::BinlogClient.new(conn)
  client.on(&block) if block_given?
  client.start_replication
end