require 'flydata/source/sync' module Flydata module SourcePostgresql class Sync < Source::Sync def setup setup_table_prefs(de['postgresql_data_entry_preference']) end def supported? true end def table_lists de['postgresql_data_entry_preference'].select {|key, value| %w(tables new_tables invalid_tables tables_append_only).include?(key)} end def data_servers de['postgresql_data_entry_preference']['data_servers'] end def forwarder de['postgresql_data_entry_preference']['forwarder'] end end end end