Module: Flydata

Includes:
Heroku
Defined in:
lib/flydata/command/sync.rb,
lib/flydata.rb,
lib/flydata/cli.rb,
lib/flydata/cron.rb,
lib/flydata/agent.rb,
lib/flydata/errors.rb,
lib/flydata/heroku.rb,
lib/flydata/parser.rb,
lib/flydata/source.rb,
lib/flydata/helpers.rb,
lib/flydata/api/base.rb,
lib/flydata/api/agent.rb,
lib/flydata/table_ddl.rb,
lib/flydata/api_client.rb,
lib/flydata/table_meta.rb,
lib/flydata/util/shell.rb,
lib/flydata/credentials.rb,
lib/flydata/log_monitor.rb,
lib/flydata/source/sync.rb,
lib/flydata/command/base.rb,
lib/flydata/command/conf.rb,
lib/flydata/command/stop.rb,
lib/flydata/source/setup.rb,
lib/flydata/api/data_port.rb,
lib/flydata/command/login.rb,
lib/flydata/command/setup.rb,
lib/flydata/command/start.rb,
lib/flydata/helper/server.rb,
lib/flydata/helper/worker.rb,
lib/flydata/source/errors.rb,
lib/flydata/api/data_entry.rb,
lib/flydata/command/helper.rb,
lib/flydata/command/sender.rb,
lib/flydata/command/status.rb,
lib/flydata/util/encryptor.rb,
lib/flydata/util/file_util.rb,
lib/flydata/command/crontab.rb,
lib/flydata/command/encrypt.rb,
lib/flydata/command/restart.rb,
lib/flydata/command/routine.rb,
lib/flydata/command/version.rb,
lib/flydata/table_attribute.rb,
lib/flydata/command/kill_all.rb,
lib/flydata/command_loggable.rb,
lib/flydata/helper/scheduler.rb,
lib/flydata/output/forwarder.rb,
lib/flydata/queueable_thread.rb,
lib/flydata/source/component.rb,
lib/flydata/source_file/sync.rb,
lib/flydata/command/setlogdel.rb,
lib/flydata/output/ddl_runner.rb,
lib/flydata/source/data_entry.rb,
lib/flydata/source/source_pos.rb,
lib/flydata/source_file/setup.rb,
lib/flydata/source_mysql/sync.rb,
lib/flydata/sync_file_manager.rb,
lib/flydata/helper/base_action.rb,
lib/flydata/source/sync_repair.rb,
lib/flydata/source_mysql/setup.rb,
lib/flydata/source_oracle/sync.rb,
lib/flydata/compatibility_check.rb,
lib/flydata/helper/action/clear.rb,
lib/flydata/helper/action/reset.rb,
lib/flydata/parser/source_table.rb,
lib/flydata/source_oracle/setup.rb,
lib/flydata/api/redshift_cluster.rb,
lib/flydata/helper/action/repair.rb,
lib/flydata/helper/action/resync.rb,
lib/flydata/helper/config_parser.rb,
lib/flydata/parser/parser_provider.rb,
lib/flydata/plugin_support/context.rb,
lib/flydata/source_file/data_entry.rb,
lib/flydata/source_mysql/table_ddl.rb,
lib/flydata/source_postgresql/sync.rb,
lib/flydata/helper/action/send_logs.rb,
lib/flydata/helper/action_ownership.rb,
lib/flydata/heroku/instance_methods.rb,
lib/flydata/query_based_sync/client.rb,
lib/flydata/source_mysql/data_entry.rb,
lib/flydata/source_mysql/source_pos.rb,
lib/flydata/source_mysql/table_meta.rb,
lib/flydata/source_postgresql/setup.rb,
lib/flydata/helper/action/stop_agent.rb,
lib/flydata/source_mysql/sync_repair.rb,
lib/flydata/source_oracle/data_entry.rb,
lib/flydata/source_oracle/source_pos.rb,
lib/flydata/source_oracle/table_meta.rb,
lib/flydata/helper/action/stop_helper.rb,
lib/flydata/query_based_sync/response.rb,
lib/flydata/command/exclusive_runnable.rb,
lib/flydata/helper/action/agent_action.rb,
lib/flydata/source/parse_dump_and_send.rb,
lib/flydata/source_mysql/command/mysql.rb,
lib/flydata/helper/action/restart_agent.rb,
lib/flydata/source/generate_source_dump.rb,
lib/flydata/heroku/configuration_methods.rb,
lib/flydata/source_postgresql/data_entry.rb,
lib/flydata/source_postgresql/source_pos.rb,
lib/flydata/source_postgresql/table_meta.rb,
lib/flydata/source_mysql/mysql_accessible.rb,
lib/flydata/source_postgresql/sync_repair.rb,
lib/flydata/source/sync_generate_table_ddl.rb,
lib/flydata/source_mysql/command/mysqldump.rb,
lib/flydata/source_oracle/oracle_component.rb,
lib/flydata/source_postgresql/command/psql.rb,
lib/flydata/helper/action_ownership_channel.rb,
lib/flydata/source_mysql/parser/dump_parser.rb,
lib/flydata/preference/data_entry_preference.rb,
lib/flydata/source_mysql/command/mysqlbinlog.rb,
lib/flydata/source_mysql/parse_dump_and_send.rb,
lib/flydata/query_based_sync/response_handler.rb,
lib/flydata/source_mysql/generate_source_dump.rb,
lib/flydata/source_oracle/parse_dump_and_send.rb,
lib/flydata/helper/action/check_remote_actions.rb,
lib/flydata/helper/action/update_helper_config.rb,
lib/flydata/source_oracle/generate_source_dump.rb,
lib/flydata/plugin_support/source_position_file.rb,
lib/flydata/query_based_sync/resource_requester.rb,
lib/flydata/source_mysql/plugin_support/context.rb,
lib/flydata/plugin_support/sync_record_emittable.rb,
lib/flydata/source_mysql/sync_generate_table_ddl.rb,
lib/flydata/source_oracle/plugin_support/context.rb,
lib/flydata/helper/action/check_abnormal_shutdown.rb,
lib/flydata/source_mysql/sync_database_size_check.rb,
lib/flydata/source_oracle/sync_generate_table_ddl.rb,
lib/flydata/source_postgresql/parse_dump_and_send.rb,
lib/flydata/query_based_sync/record_size_estimator.rb,
lib/flydata/source_mysql/mysql_compatibility_check.rb,
lib/flydata/source_postgresql/generate_source_dump.rb,
lib/flydata/source_postgresql/postgresql_component.rb,
lib/flydata/source_zendesk/sync_generate_table_ddl.rb,
lib/flydata/source_mysql/command/mysql_command_base.rb,
lib/flydata/source_postgresql/plugin_support/context.rb,
lib/flydata/source_zendesk/zendesk_flydata_tabledefs.rb,
lib/flydata/source_postgresql/query_based_sync/client.rb,
lib/flydata/source_postgresql/sync_generate_table_ddl.rb,
lib/flydata/source_postgresql/query_based_sync/response.rb,
lib/flydata/source_mysql/plugin_support/ddl_query_handler.rb,
lib/flydata/source_mysql/plugin_support/dml_record_handler.rb,
lib/flydata/source_mysql/plugin_support/binlog_query_handler.rb,
lib/flydata/source_mysql/plugin_support/source_position_file.rb,
lib/flydata/source_mysql/plugin_support/binlog_record_handler.rb,
lib/flydata/source_oracle/plugin_support/source_position_file.rb,
lib/flydata/source_mysql/plugin_support/binlog_query_dispatcher.rb,
lib/flydata/source_oracle/query_based_sync/diff_query_generator.rb,
lib/flydata/source_postgresql/query_based_sync/response_handler.rb,
lib/flydata/source_mysql/plugin_support/binlog_record_dispatcher.rb,
lib/flydata/source_mysql/plugin_support/drop_table_query_handler.rb,
lib/flydata/source_mysql/plugin_support/alter_table_query_handler.rb,
lib/flydata/source_mysql/plugin_support/unsupported_query_handler.rb,
lib/flydata/source_postgresql/plugin_support/source_position_file.rb,
lib/flydata/source_postgresql/query_based_sync/resource_requester.rb,
lib/flydata/source_mysql/plugin_support/create_table_query_handler.rb,
lib/flydata/source_mysql/plugin_support/drop_database_query_handler.rb,
lib/flydata/source_postgresql/query_based_sync/diff_query_generator.rb,
lib/flydata/source_mysql/plugin_support/truncate_table_query_handler.rb,
ext/flydata/source_mysql/parser/dump_parser_ext.cpp

Overview

Command class must be in module Flydata::Command

Defined Under Namespace

Modules: Api, Command, CommandLoggable, Helper, Helpers, Heroku, InitialSyncChecks, Output, Parser, PluginSupport, Preference, QueryBasedSync, Source, SourceFile, SourceMysql, SourceOracle, SourcePostgresql, SourceZendesk, TableAttribute, Util Classes: Agent, AgentCompatibilityCheck, AgentError, AgentInternalError, ApiClient, Cli, CompatibilityCheck, Credentials, Cron, DumpParseError, LogMonitor, QueueableThread, ServerDataProcessingTimeout, SyncFileManager, TableDdl, TableMeta

Constant Summary collapse

FLYDATA_DEBUG = 
!!(ENV['FLYDATA_DEBUG'])
FLYDATA_HOME = 
ENV['FLYDATA_HOME'] || "#{ENV['HOME']}/.flydata"
FLYDATA_TABLE_POSITIONS_DIR = 
ENV['FLYDATA_TABLE_POSITIONS'] || File.join(FLYDATA_HOME, 'positions')
FLYDATA_GEM_HOME = 
File.expand_path(File.join(File.dirname(__FILE__), '..'))
FLYDATA_GEM_BIN = 
File.join(FLYDATA_GEM_HOME, 'bin')
FLYDATA_TMPL_DIR = 
File.join(FLYDATA_GEM_HOME, 'tmpl')
FLYDATA_FLUENT_PLUGIN_DIR = 
File.join(FLYDATA_GEM_HOME, 'lib', 'flydata', 'fluent-plugins')
FLYDATA_DUMP_DIR = 
ENV['FLYDATA_DUMP_DIR'] || File.join(FLYDATA_HOME, 'dump')
FLYDATA_BACKUP_DIR = 
ENV['FLYDATA_BACKUP_DIR'] || File.join(FLYDATA_HOME, 'backup')
FLYDATA_SERVERINFO = 
File.join(FLYDATA_GEM_BIN, 'serverinfo')
FLYDATA_LOG = 
File.join(FLYDATA_HOME, 'flydata.log')
FLYDATA_CONF = 
File.join(FLYDATA_HOME, 'flydata.conf')
FLYDATA_LOCK = 
File.join(FLYDATA_HOME, 'flydata_lock.pid')
FLYDATA_HELPER_HOME = 
File.join(FLYDATA_HOME, 'helper')
FLYDATA_HELPER_CONF = 
File.join(FLYDATA_HELPER_HOME, "helper.conf")
FLYDATA_CMD_PATH = 
ENV['FLYDATA_CMD_PATH'] || "flydata"
FLYDATA_CLIENT_BUFFER_DIR = 
File.join(FLYDATA_HOME, 'buffer')
FLYDATA_DEBUG_FILE = 
File.join(FLYDATA_HOME, '.debug')
VERSION_PATH = 
File.join(FLYDATA_GEM_HOME, 'VERSION')
FLYDATA_API_HOST = 
ENV['FLYDATA_API_HOST'] || 'https://flydata.co'