module Sidekiq::Logstash

Main level module for Sidekiq::Logstash. Provides integration between Sidekiq and Logstash by changing the way Sidekiq jobs are logged.

Constants

VERSION

Public Class Methods

configuration() click to toggle source
# File lib/sidekiq/logstash.rb, line 14
def self.configuration
  @configuration ||= Configuration.new
end
configure() { |configuration| ... } click to toggle source
# File lib/sidekiq/logstash.rb, line 18
def self.configure
  yield(configuration)
end
setup(_opts = {}) click to toggle source
# File lib/sidekiq/logstash.rb, line 22
def self.setup(_opts = {})
  # Calls Sidekiq.configure_server to inject logics
  Sidekiq.configure_server do |config|
    # Remove default Sidekiq error_handler that logs errors
    config.error_handlers.delete_if { |h| h.is_a?(Sidekiq::ExceptionHandler::Logger) }

    # Add logstash support
    config.options[:job_logger] = Sidekiq::LogstashJobLogger

    # Set custom formatter for Sidekiq logger
    config.logger.formatter = Sidekiq::Logging::LogstashFormatter.new
  end
end