class RestashRails::LogSubscriber::Cache

Public Instance Methods

cache_delete(event) click to toggle source
# File lib/restash_rails/log_subscriber/subscribers/cache.rb, line 31
def cache_delete(event)
  log(event)
end
cache_delete_tag_keys(event) click to toggle source
# File lib/restash_rails/log_subscriber/subscribers/cache.rb, line 28
def cache_delete_tag_keys(event)
  log(event)
end
cache_delete_tag_tree(event) click to toggle source
# File lib/restash_rails/log_subscriber/subscribers/cache.rb, line 10
def cache_delete_tag_tree(event)
  log(event)
end
cache_delete_wiled_card(event) click to toggle source
# File lib/restash_rails/log_subscriber/subscribers/cache.rb, line 13
def cache_delete_wiled_card(event)
  log(event)
end
cache_fetch(event) click to toggle source
# File lib/restash_rails/log_subscriber/subscribers/cache.rb, line 25
def cache_fetch(event)
  log(event)
end
cache_read(event) click to toggle source
# File lib/restash_rails/log_subscriber/subscribers/cache.rb, line 7
def cache_read(event)
  log(event)
end
cache_write(event) click to toggle source
# File lib/restash_rails/log_subscriber/subscribers/cache.rb, line 22
def cache_write(event)
  log(event)
end
cache_write_tags(event) click to toggle source
# File lib/restash_rails/log_subscriber/subscribers/cache.rb, line 19
def cache_write_tags(event)
  log(event)
end
cache_write_value(event) click to toggle source
# File lib/restash_rails/log_subscriber/subscribers/cache.rb, line 16
def cache_write_value(event)
  log(event)
end
logger() click to toggle source
# File lib/restash_rails/log_subscriber/subscribers/cache.rb, line 35
def logger
  ::RestashRails.logger
end

Private Instance Methods

exception_formatter(payload) click to toggle source
# File lib/restash_rails/log_subscriber/subscribers/cache.rb, line 62
def exception_formatter(payload)
  return {} if payload[:exception].nil?
  exception_class, message = payload[:exception]
  { exception_class: exception_class, message: message}
end
generate_message(event) click to toggle source
# File lib/restash_rails/log_subscriber/subscribers/cache.rb, line 48
def generate_message(event)
  payload = event.payload
  message = {
      name: event.name,
      duration: event.duration || 0,
      cache_key: payload[:key],
      host: payload[:host],
      port: payload[:port],
      expire_in: payload[:expire_in],
      log_tag: :cache
  }
  message.merge(exception_formatter(payload))
end
log(event) click to toggle source
# File lib/restash_rails/log_subscriber/subscribers/cache.rb, line 41
def log(event)
  message = generate_message(event)
  (message[:duration] > 100) ?
      logger.debug(message.merge({ execution: 'slow' })) :
      logger.debug(message)
end