class DBPurger::MetricSubscriber

DBPurger::MetricSubscriber tracks the progress of the Plan#purge process

Public Class Methods

auto_attach() click to toggle source
# File lib/db-purger/metric_subscriber.rb, line 14
def self.auto_attach
  attach_to :db_purger
end
metrics() click to toggle source
# File lib/db-purger/metric_subscriber.rb, line 6
def self.metrics
  @metrics ||= Metrics.new
end
reset!() click to toggle source
# File lib/db-purger/metric_subscriber.rb, line 10
def self.reset!
  metrics.reset!
end

Public Instance Methods

delete_records(event) click to toggle source
# File lib/db-purger/metric_subscriber.rb, line 26
def delete_records(event)
  self.class.metrics.update_delete_records_stats(
    event.payload[:table_name],
    event.duration,
    event.payload[:records_deleted],
    event.payload[:num_records]
  )
end
next_batch(event) click to toggle source
# File lib/db-purger/metric_subscriber.rb, line 35
def next_batch(event)
  self.class.metrics.update_lookup_stats(
    event.payload[:table_name],
    event.duration,
    event.payload[:num_records]
  )
end
purge(event) click to toggle source
# File lib/db-purger/metric_subscriber.rb, line 18
def purge(event)
  self.class.metrics.update_purge_stats(
    event.payload[:table_name],
    event.duration,
    event.payload[:deleted]
  )
end
search_filter(event) click to toggle source
# File lib/db-purger/metric_subscriber.rb, line 43
def search_filter(event)
  self.class.metrics.update_search_filter_stats(
    event.payload[:table_name],
    event.duration,
    event.payload[:num_records],
    event.payload[:num_records_selected]
  )
end