Package londiste :: Module table_copy :: Class CopyTable

Class CopyTable

                 object --+                
                          |                
skytools.scripting.DBScript --+            
                              |            
          pgq.consumer.Consumer --+        
                                  |        
        pgq.consumer.SerialConsumer --+    
                                      |    
                    playback.Replicator --+
                                          |
                                         CopyTable

Known Subclasses:: file_read.FileRead

Instance Methods

__init__(self, args, copy_thread=1)

source code

init_optparse(self, parser=None)

source code

do_copy(self, tbl_stat)

source code

real_copy(self, srccurs, dstcurs, tablename)
Main copy logic.

source code

Inherited from playback.Replicator: change_table_state, fill_mirror_queue, flush_sql, get_table_by_name, get_table_by_state, handle_data_event, handle_events, handle_seqs, handle_system_event, interesting, launch_copy, load_table_state, process_remote_batch, remove_table, save_table_state, sync_from_copy_thread, sync_from_main_thread, sync_tables

Inherited from pgq.consumer.SerialConsumer: attach, clean_completed_tick, detach, dst_reset, is_batch_done, process_batch, rewind, set_batch_done, startup

Inherited from pgq.consumer.Consumer: get_batch_info, process_event, register_consumer, stat_end, stat_start, unregister_consumer, work

Inherited from skytools.scripting.DBScript: close_database, get_database, hook_sighup, hook_sigint, reload, reset, run, run_once, send_signal, send_stats, set_single_loop, start, stat_add, stat_increase, stat_put, stop

Inherited from object: __delattr__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __str__

Class Variables

Inherited from playback.Replicator: cur_tick, prev_tick, sql_command

Inherited from skytools.scripting.DBScript: cf, job_name, log, service_name

Properties
Inherited from `object`: `__class__`

Method Details

init(self, args, copy_thread=1)
(Constructor)

source code

Overrides: playback.Replicator.__init__

init_optparse(self, parser=None)

source code

Overrides: pgq.consumer.SerialConsumer.init_optparse

Class CopyTable

__init__(self, args, copy_thread=1) (Constructor)

init_optparse(self, parser=None)

init(self, args, copy_thread=1)
(Constructor)