datamanwithvan package

Subpackages

• datamanwithvan.config package
  • Submodules
  • datamanwithvan.config.config module
    • datamanwithvanConfig
      • datamanwithvanConfig.backenddatabase_dbname
      • datamanwithvanConfig.backenddatabase_dbtype
      • datamanwithvanConfig.backenddatabase_log_table_prefix
      • datamanwithvanConfig.backenddatabase_port
      • datamanwithvanConfig.backenddatabase_pwd
      • datamanwithvanConfig.backenddatabase_region
      • datamanwithvanConfig.backenddatabase_repl_rules_table
      • datamanwithvanConfig.backenddatabase_schema
      • datamanwithvanConfig.backenddatabase_server
      • datamanwithvanConfig.backenddatabase_uid
      • datamanwithvanConfig.datapeers
      • datamanwithvanConfig.general_app_log_file
      • datamanwithvanConfig.general_job_log_path
      • datamanwithvanConfig.general_job_log_store
      • datamanwithvanConfig.general_nativersync
      • datamanwithvanConfig.general_samepeerreplications
  • Module contents
• datamanwithvan.data package
  • Submodules
  • datamanwithvan.data.datavanquery module
    • DatamanwithvanQuery
      • DatamanwithvanQuery.StatusCodesObj
      • DatamanwithvanQuery.get_query_1()
      • DatamanwithvanQuery.query_1
  • Module contents
• datamanwithvan.replication package
  • Submodules
  • datamanwithvan.replication.datamanwithvanmover module
  • datamanwithvan.replication.replicationjob module
    • ReplicationJob
      • ReplicationJob.StatusCodesObj
      • ReplicationJob.assign_replication_rules()
      • ReplicationJob.configuration
      • ReplicationJob.consume()
      • ReplicationJob.content
      • ReplicationJob.job_metadata
      • ReplicationJob.job_task_channel
      • ReplicationJob.main_to_job_channel
      • ReplicationJob.mainprogram_job_channel
      • ReplicationJob.produce()
      • ReplicationJob.query_engine
      • ReplicationJob.replication_job_id
      • ReplicationJob.run_job()
      • ReplicationJob.start_replication_tasks()
      • ReplicationJob.tasks
      • ReplicationJob.verbosity
  • datamanwithvan.replication.replicationtask module
    • ReplicationTask
      • ReplicationTask.StatusCodesObj
      • ReplicationTask.config
      • ReplicationTask.replication_item
      • ReplicationTask.run_task()
      • ReplicationTask.task_metadata
      • ReplicationTask.verbosity
  • Module contents
• datamanwithvan.utils package
  • Submodules
  • datamanwithvan.utils.messages module
    • DatamanwithvanMessages
      • DatamanwithvanMessages.err_fn_no_found
      • DatamanwithvanMessages.err_no_quiet_and_verbose
      • DatamanwithvanMessages.msg_error_cant_fetch_rep_rule
      • DatamanwithvanMessages.msg_error_no_cnf_pro
      • DatamanwithvanMessages.msg_error_no_conf
      • DatamanwithvanMessages.msg_info_load_conf
      • DatamanwithvanMessages.msg_info_repl_rule_exist
      • DatamanwithvanMessages.msg_info_version_number
      • DatamanwithvanMessages.msg_info_welcome
      • DatamanwithvanMessages.msg_info_welcome_footer
      • DatamanwithvanMessages.msg_warn_no_rep_rule
      • DatamanwithvanMessages.pkgname
      • DatamanwithvanMessages.warn_not_implemented
  • datamanwithvan.utils.statuscodes module
    • StatusCodes
      • StatusCodes.conf_loading_success
      • StatusCodes.stat_code_cnf_not_exist
      • StatusCodes.stat_code_conf_not_provided
      • StatusCodes.stat_code_enough_disk_space
      • StatusCodes.stat_code_generic
      • StatusCodes.stat_code_not_enough_disk_space
      • StatusCodes.stat_code_quiet_verbose
      • StatusCodes.status_cnf_not_load
  • datamanwithvan.utils.utils module
    • Utils
      • Utils.StatusCodesObj
      • Utils.dummy_attribute
      • Utils.generate_random_string()
      • Utils.has_enough_disk_space()
      • Utils.select_random_element()
  • Module contents

Submodules

datamanwithvan.datamanwithvan module

async datamanwithvan.datamanwithvan.consume(communication, whoami)

datamanwithvan.datamanwithvan.datamanwithvan_entry()

async datamanwithvan.datamanwithvan.produce(communication, sender, message)

async datamanwithvan.datamanwithvan.start_consuming(replication_job_id, mainprogram_job_channel)

async datamanwithvan.datamanwithvan.start_producing(replication_job_id, mainprogram_job_channel)

Module contents