Index

A

assign_replication_rules() (datamanwithvan.replication.replicationjob.ReplicationJob method)

B

backenddatabase_dbname (datamanwithvan.config.config.datamanwithvanConfig attribute) backenddatabase_dbtype (datamanwithvan.config.config.datamanwithvanConfig attribute) backenddatabase_log_table_prefix (datamanwithvan.config.config.datamanwithvanConfig attribute) backenddatabase_port (datamanwithvan.config.config.datamanwithvanConfig attribute) backenddatabase_pwd (datamanwithvan.config.config.datamanwithvanConfig attribute)

backenddatabase_region (datamanwithvan.config.config.datamanwithvanConfig attribute) backenddatabase_repl_rules_table (datamanwithvan.config.config.datamanwithvanConfig attribute) backenddatabase_schema (datamanwithvan.config.config.datamanwithvanConfig attribute) backenddatabase_server (datamanwithvan.config.config.datamanwithvanConfig attribute) backenddatabase_uid (datamanwithvan.config.config.datamanwithvanConfig attribute)

C

conf_loading_success (datamanwithvan.utils.statuscodes.StatusCodes attribute) config (datamanwithvan.replication.replicationtask.ReplicationTask attribute) configuration (datamanwithvan.replication.replicationjob.ReplicationJob attribute)

consume() (datamanwithvan.replication.replicationjob.ReplicationJob method) (in module datamanwithvan.datamanwithvan) content (datamanwithvan.replication.replicationjob.ReplicationJob attribute)

D

datamanwithvan module datamanwithvan.config module datamanwithvan.config.config module datamanwithvan.data module datamanwithvan.data.datavanquery module datamanwithvan.datamanwithvan module datamanwithvan.replication module datamanwithvan.replication.replicationjob module

datamanwithvan.replication.replicationtask module datamanwithvan.utils module datamanwithvan.utils.messages module datamanwithvan.utils.statuscodes module datamanwithvan.utils.utils module datamanwithvan_entry() (in module datamanwithvan.datamanwithvan) datamanwithvanConfig (class in datamanwithvan.config.config) DatamanwithvanMessages (class in datamanwithvan.utils.messages) DatamanwithvanQuery (class in datamanwithvan.data.datavanquery) datapeers (datamanwithvan.config.config.datamanwithvanConfig attribute) dummy_attribute (datamanwithvan.utils.utils.Utils attribute)

E

err_fn_no_found (datamanwithvan.utils.messages.DatamanwithvanMessages attribute)

err_no_quiet_and_verbose (datamanwithvan.utils.messages.DatamanwithvanMessages attribute)

G

general_app_log_file (datamanwithvan.config.config.datamanwithvanConfig attribute) general_job_log_path (datamanwithvan.config.config.datamanwithvanConfig attribute) general_job_log_store (datamanwithvan.config.config.datamanwithvanConfig attribute)

general_nativersync (datamanwithvan.config.config.datamanwithvanConfig attribute) general_samepeerreplications (datamanwithvan.config.config.datamanwithvanConfig attribute) generate_random_string() (datamanwithvan.utils.utils.Utils method) get_query_1() (datamanwithvan.data.datavanquery.DatamanwithvanQuery method)

H

has_enough_disk_space() (datamanwithvan.utils.utils.Utils method)

J

job_metadata (datamanwithvan.replication.replicationjob.ReplicationJob attribute)

job_task_channel (datamanwithvan.replication.replicationjob.ReplicationJob attribute)

M

main_to_job_channel (datamanwithvan.replication.replicationjob.ReplicationJob attribute) mainprogram_job_channel (datamanwithvan.replication.replicationjob.ReplicationJob attribute) module datamanwithvan datamanwithvan.config datamanwithvan.config.config datamanwithvan.data datamanwithvan.data.datavanquery datamanwithvan.datamanwithvan datamanwithvan.replication datamanwithvan.replication.replicationjob datamanwithvan.replication.replicationtask datamanwithvan.utils datamanwithvan.utils.messages datamanwithvan.utils.statuscodes datamanwithvan.utils.utils

msg_error_cant_fetch_rep_rule (datamanwithvan.utils.messages.DatamanwithvanMessages attribute) msg_error_no_cnf_pro (datamanwithvan.utils.messages.DatamanwithvanMessages attribute) msg_error_no_conf (datamanwithvan.utils.messages.DatamanwithvanMessages attribute) msg_info_load_conf (datamanwithvan.utils.messages.DatamanwithvanMessages attribute) msg_info_repl_rule_exist (datamanwithvan.utils.messages.DatamanwithvanMessages attribute) msg_info_version_number (datamanwithvan.utils.messages.DatamanwithvanMessages attribute) msg_info_welcome (datamanwithvan.utils.messages.DatamanwithvanMessages attribute) msg_info_welcome_footer (datamanwithvan.utils.messages.DatamanwithvanMessages attribute) msg_warn_no_rep_rule (datamanwithvan.utils.messages.DatamanwithvanMessages attribute)

P

pkgname (datamanwithvan.utils.messages.DatamanwithvanMessages attribute)

produce() (datamanwithvan.replication.replicationjob.ReplicationJob method) (in module datamanwithvan.datamanwithvan)

Q

query_1 (datamanwithvan.data.datavanquery.DatamanwithvanQuery attribute)

query_engine (datamanwithvan.replication.replicationjob.ReplicationJob attribute)

R

replication_item (datamanwithvan.replication.replicationtask.ReplicationTask attribute) replication_job_id (datamanwithvan.replication.replicationjob.ReplicationJob attribute) ReplicationJob (class in datamanwithvan.replication.replicationjob)

ReplicationTask (class in datamanwithvan.replication.replicationtask) run_job() (datamanwithvan.replication.replicationjob.ReplicationJob method) run_task() (datamanwithvan.replication.replicationtask.ReplicationTask method)

S

select_random_element() (datamanwithvan.utils.utils.Utils method) start_consuming() (in module datamanwithvan.datamanwithvan) start_producing() (in module datamanwithvan.datamanwithvan) start_replication_tasks() (datamanwithvan.replication.replicationjob.ReplicationJob method) stat_code_cnf_not_exist (datamanwithvan.utils.statuscodes.StatusCodes attribute) stat_code_conf_not_provided (datamanwithvan.utils.statuscodes.StatusCodes attribute) stat_code_enough_disk_space (datamanwithvan.utils.statuscodes.StatusCodes attribute) stat_code_generic (datamanwithvan.utils.statuscodes.StatusCodes attribute)

stat_code_not_enough_disk_space (datamanwithvan.utils.statuscodes.StatusCodes attribute) stat_code_quiet_verbose (datamanwithvan.utils.statuscodes.StatusCodes attribute) status_cnf_not_load (datamanwithvan.utils.statuscodes.StatusCodes attribute) StatusCodes (class in datamanwithvan.utils.statuscodes) StatusCodesObj (datamanwithvan.data.datavanquery.DatamanwithvanQuery attribute) (datamanwithvan.replication.replicationjob.ReplicationJob attribute) (datamanwithvan.replication.replicationtask.ReplicationTask attribute) (datamanwithvan.utils.utils.Utils attribute)

T

task_metadata (datamanwithvan.replication.replicationtask.ReplicationTask attribute)

tasks (datamanwithvan.replication.replicationjob.ReplicationJob attribute)

U

Utils (class in datamanwithvan.utils.utils)

V

verbosity (datamanwithvan.replication.replicationjob.ReplicationJob attribute) (datamanwithvan.replication.replicationtask.ReplicationTask attribute)

W

warn_not_implemented (datamanwithvan.utils.messages.DatamanwithvanMessages attribute)