Class: Dbwatcher::Storage::ChangeProcessor

Inherits:
Object
  • Object
show all
Includes:
Dbwatcher::Storage::Concerns::DataNormalizer
Defined in:
lib/dbwatcher/storage/change_processor.rb

Instance Method Summary collapse

Methods included from Dbwatcher::Storage::Concerns::DataNormalizer

#extract_value, #normalize_change, #normalize_hash_keys, #normalize_operation, #normalize_record_id, #normalize_session_data, #normalize_table_name, #normalize_timestamp

Constructor Details

#initialize(session_storage) ⇒ ChangeProcessor

Returns a new instance of ChangeProcessor.



8
9
10
11
 
# File 'lib/dbwatcher/storage/change_processor.rb', line 8

def initialize(session_storage)
  @session_storage = session_storage
  @session_cache = {}
end

Instance Method Details

#process_table_changes(table_name) ⇒ Object 



13
14
15
16
 
# File 'lib/dbwatcher/storage/change_processor.rb', line 13

def process_table_changes(table_name)
  all_changes = collect_all_changes(table_name)
  sort_changes_by_timestamp(all_changes)
end