Index

A

add_source() (global_lib.replica_engine method) (pg_lib.pg_engine method)

B

begin_tx() (mysql_lib.mysql_source method) build_alter_table() (pg_lib.pg_engine method) build_column_dic() (sql_util.sql_token method)

build_create_index() (pg_lib.pg_engine method) build_enum_ddl() (pg_lib.pg_engine method) build_key_dic() (sql_util.sql_token method)

C

check_auto_maintenance() (pg_lib.pg_engine method) check_postgis() (pg_lib.pg_engine method) check_replica_schema() (pg_lib.pg_engine method) check_schema_mappings() (pg_lib.pg_engine method) check_source() (pg_lib.pg_engine method) check_source_consistent() (pg_lib.pg_engine method) clean_batch_data() (pg_lib.pg_engine method) clean_not_processed_batches() (pg_lib.pg_engine method) cleanup_idx_cons() (pg_lib.pg_engine method) cleanup_replayed_batches() (pg_lib.pg_engine method) cleanup_source_tables() (pg_lib.pg_engine method) cleanup_table_events() (pg_lib.pg_engine method) collect_idx_cons() (pg_lib.pg_engine method) connect_db() (pg_lib.pg_engine method)

connect_db_buffered() (mysql_lib.mysql_source method) connect_db_unbuffered() (mysql_lib.mysql_source method) copy_data() (mysql_lib.mysql_source method) (pg_lib.pg_engine method) copy_schema() (global_lib.replica_engine method) create_database_schema() (pg_lib.pg_engine method) create_destination_schemas() (mysql_lib.mysql_source method) create_destination_tables() (mysql_lib.mysql_source method) create_foreign_keys() (pg_lib.pg_engine method) create_idx_cons() (pg_lib.pg_engine method) create_indices() (pg_lib.pg_engine method) create_replica_schema() (global_lib.replica_engine method) (pg_lib.pg_engine method) create_table() (pg_lib.pg_engine method)

D

default() (pg_lib.pg_encoder method) detach_replica() (global_lib.replica_engine method) (pg_lib.pg_engine method) disconnect_db() (pg_lib.pg_engine method) disconnect_db_buffered() (mysql_lib.mysql_source method) disconnect_db_unbuffered() (mysql_lib.mysql_source method)

drop_database_schema() (pg_lib.pg_engine method) drop_loading_schemas() (mysql_lib.mysql_source method) drop_replica_schema() (global_lib.replica_engine method) (pg_lib.pg_engine method) drop_source() (global_lib.replica_engine method) (pg_lib.pg_engine method)

E

enable_replica() (global_lib.replica_engine method) encode() (pg_lib.pg_encoder method)

end_maintenance() (pg_lib.pg_engine method) end_tx() (mysql_lib.mysql_source method)

G

generate_default_statements() (pg_lib.pg_engine method) generate_select_statements() (mysql_lib.mysql_source method) get_active_sources() (pg_lib.pg_engine method) get_batch_data() (pg_lib.pg_engine method) get_catalog_version() (pg_lib.pg_engine method) get_data_type() (pg_lib.pg_engine method) get_existing_pkey() (pg_lib.pg_engine method) get_foreign_keys_metadata() (mysql_lib.mysql_source method) get_inconsistent_tables() (pg_lib.pg_engine method) get_log_data() (pg_lib.pg_engine method) get_master_coordinates() (mysql_lib.mysql_source method) get_replica_paused() (pg_lib.pg_engine method)

get_replica_status() (pg_lib.pg_engine method) get_schema_list() (pg_lib.pg_engine method) get_schema_mappings() (pg_lib.pg_engine method) get_status() (pg_lib.pg_engine method) get_table_list() (mysql_lib.mysql_source method) get_table_metadata() (mysql_lib.mysql_source method) get_table_pkey() (pg_lib.pg_engine method) get_table_type_map() (mysql_lib.mysql_source method) get_tables_disabled() (pg_lib.pg_engine method) global_lib module grant_select() (pg_lib.pg_engine method)

I

init_replica() (global_lib.replica_engine method) (mysql_lib.mysql_source method) (pg_lib.pgsql_source method) insert_batch() (pg_lib.pg_engine method)

insert_data() (pg_lib.pg_engine method) insert_source_timings() (pg_lib.pg_engine method) insert_table_data() (mysql_lib.mysql_source method) item_separator (pg_lib.pg_encoder attribute) iterencode() (pg_lib.pg_encoder method)

K

key_separator (pg_lib.pg_encoder attribute)

L

load_config() (global_lib.replica_engine method)

lock_table() (mysql_lib.mysql_source method)

M

make_tx_snapshot() (mysql_lib.mysql_source method) module global_lib mysql_lib pg_lib sql_util

mysql_lib module mysql_source (class in mysql_lib)

P

parse_alter_table() (sql_util.sql_token method) parse_column() (sql_util.sql_token method) parse_create_table() (sql_util.sql_token method) parse_rename_table() (sql_util.sql_token method) parse_sql() (sql_util.sql_token method)

pg_encoder (class in pg_lib) pg_engine (class in pg_lib) pg_lib module pgsql_source (class in pg_lib) print_progress() (mysql_lib.mysql_source method)

Q

quote_cols() (sql_util.sql_token method)

R

read_replica() (global_lib.replica_engine method) (mysql_lib.mysql_source method) refresh_schema() (global_lib.replica_engine method) (mysql_lib.mysql_source method) reindex_table() (pg_lib.pg_engine method) replay_replica() (global_lib.replica_engine method) (pg_lib.pg_engine method)

replica_engine (class in global_lib) reset_lists() (sql_util.sql_token method) rollback_upgrade_v1() (pg_lib.pg_engine method) rollbar_notifier (class in global_lib) run_maintenance() (global_lib.replica_engine method) (pg_lib.pg_engine method)

S

save_discarded_row() (pg_lib.pg_engine method) save_master_status() (pg_lib.pg_engine method) send_message() (global_lib.rollbar_notifier method) set_application_name() (pg_lib.pg_engine method) set_autocommit_db() (pg_lib.pg_engine method) set_batch_processed() (pg_lib.pg_engine method) set_configuration_files() (global_lib.replica_engine method) set_consistent_table() (pg_lib.pg_engine method) set_copy_max_memory() (mysql_lib.mysql_source method) set_lock_timeout() (pg_lib.pg_engine method) set_read_paused() (pg_lib.pg_engine method) set_replay_paused() (pg_lib.pg_engine method) set_source_highwatermark() (pg_lib.pg_engine method) set_source_id() (pg_lib.pg_engine method) set_source_status() (pg_lib.pg_engine method)

show_config() (global_lib.replica_engine method) show_errors() (global_lib.replica_engine method) show_sources() (global_lib.replica_engine method) show_status() (global_lib.replica_engine method) sql_token (class in sql_util) sql_util module start_replica() (global_lib.replica_engine method) stop_all_replicas() (global_lib.replica_engine method) stop_replica() (global_lib.replica_engine method) store_table() (pg_lib.pg_engine method) swap_schemas() (pg_lib.pg_engine method) swap_source_log_table() (pg_lib.pg_engine method) swap_tables() (pg_lib.pg_engine method) sync_tables() (global_lib.replica_engine method) (mysql_lib.mysql_source method)

T

terminate_replica() (global_lib.replica_engine method)

truncate_table() (pg_lib.pg_engine method)

U

unlock_tables() (mysql_lib.mysql_source method) unregister_table() (pg_lib.pg_engine method) unset_lock_timeout() (pg_lib.pg_engine method) update_schema_mappings() (global_lib.replica_engine method) (pg_lib.pg_engine method)

upgrade_catalogue_v1() (pg_lib.pg_engine method) upgrade_catalogue_v20() (pg_lib.pg_engine method) upgrade_replica_schema() (global_lib.replica_engine method)

W

write_batch() (pg_lib.pg_engine method)

write_ddl() (pg_lib.pg_engine method)