Class: Flydata::SourceMysql::Sync
Instance Method Summary
collapse
inherited
#initialize
Instance Method Details
#data_servers ⇒ Object
28
29
30
|
# File 'lib/flydata/source_mysql/sync.rb', line 28
def data_servers
de['mysql_data_entry_preference']['data_servers']
end
|
#forwarder ⇒ Object
32
33
34
|
# File 'lib/flydata/source_mysql/sync.rb', line 32
def forwarder
de['mysql_data_entry_preference']['forwarder']
end
|
#setup ⇒ Object
7
8
9
10
11
12
13
14
15
16
17
18
|
# File 'lib/flydata/source_mysql/sync.rb', line 7
def setup
mp = de['mysql_data_entry_preference']
setup_table_prefs(mp)
unless mp['ssl_ca_content'].to_s.strip.empty?
sync_fm = SyncFileManager.new(de)
sync_fm.save_ssl_ca(mp['ssl_ca_content'])
mp['ssl_ca'] = sync_fm.ssl_ca_path
mp['sslca'] = mp['ssl_ca']
end
end
|
#supported? ⇒ Boolean
20
21
22
|
# File 'lib/flydata/source_mysql/sync.rb', line 20
def supported?
true
end
|
#table_lists ⇒ Object
24
25
26
|
# File 'lib/flydata/source_mysql/sync.rb', line 24
def table_lists
de['mysql_data_entry_preference'].select {|key, value| %w(tables new_tables invalid_tables tables_append_only).include?(key)}
end
|