Module: Sidekiq::Logstash

Defined in:
lib/sidekiq/logstash.rb,
lib/sidekiq/logstash/version.rb,
lib/sidekiq/logstash/configuration.rb

Overview

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

Defined Under Namespace

Classes: Configuration

Constant Summary collapse

VERSION = 
'2.0.0'

Class Method Summary collapse

Class Method Details

.configuration ⇒ Object 



14
15
16
 
# File 'lib/sidekiq/logstash.rb', line 14

def self.configuration
  @configuration ||= Configuration.new
end

.configure {|configuration| ... } ⇒ Object

Yields:



18
19
20
 
# File 'lib/sidekiq/logstash.rb', line 18

def self.configure
  yield(configuration)
end

.setup(_opts = {}) ⇒ Object 



22
23
24
25
26
27
28
29
30
31
32
33
34
 
# 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