Index

A

add_source() (global_lib.replica_engine method) (pg_lib.pg_engine method) alter_rename_table_statement (sql_util.sql_token attribute) alter_table_add (sql_util.sql_token attribute) alter_table_add_index (sql_util.sql_token attribute) alter_table_add_multiple (sql_util.sql_token attribute) alter_table_change (sql_util.sql_token attribute)

alter_table_drop (sql_util.sql_token attribute) alter_table_drop_index (sql_util.sql_token attribute) alter_table_ignored (sql_util.sql_token attribute) alter_table_modify (sql_util.sql_token attribute) alter_table_rename_index (sql_util.sql_token attribute) alter_table_statement (sql_util.sql_token attribute) any_key_definition (sql_util.sql_token attribute)

B

begin_tx() (mysql_lib.mysql_source method) build_alter_table() (pg_lib.pg_engine method)

build_create_index() (pg_lib.pg_engine method) build_enum_ddl() (pg_lib.pg_engine 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) ci_string() (in module sql_util) 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) column_definition (sql_util.sql_token attribute) column_definition_in_alter_table (sql_util.sql_token attribute) 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) count_replica_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_index_statement (sql_util.sql_token attribute) 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) create_table_statement (sql_util.sql_token attribute)

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_index_statement (sql_util.sql_token attribute) drop_loading_schemas() (mysql_lib.mysql_source method) drop_primary_key_statement (sql_util.sql_token attribute) 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) drop_table_statement (sql_util.sql_token attribute)

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)

F

fkey_definition (sql_util.sql_token attribute)

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) group_expr (sql_util.sql_token attribute)

I

idx_definition (sql_util.sql_token attribute) init_replica() (global_lib.replica_engine method) (mysql_lib.mysql_source method) (pg_lib.pgsql_source method) inline_expr (sql_util.sql_token attribute)

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_part (sql_util.sql_token attribute)

key_part_group (sql_util.sql_token attribute) 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)

O

optional_space_around() (in module sql_util)

other_key_definition (sql_util.sql_token attribute)

P

parentheses_around() (in module sql_util) 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) pk_definition (sql_util.sql_token attribute) 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) rename_table_item (sql_util.sql_token attribute) rename_table_statement (sql_util.sql_token attribute)

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) simple_expr (sql_util.sql_token attribute) 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) truncate_table_statement (sql_util.sql_token attribute)

U

uk_definition (sql_util.sql_token attribute) 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)