Contents

# frozen_string_literal: true

#
# Copyright 2019- Yuto Suzuki
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

require 'fluent/plugin/output'
require 'sentry-ruby'

module Fluent::Plugin
  class RavenOutput < Output
    Fluent::Plugin.register_output('raven', self)

    helpers :inject

    config_param :dsn, :string, default: nil
    config_param :environment, :string, default: 'development'
    config_param :logger_level, :string, default: 'info'
    config_param :default_level, :string, default: 'error'

    def configure(conf)
      super

      raise Fluent::ConfigError, 'Need to Set DSN' if dsn.nil?

      Sentry.init do |config|
        config.logger.level = logger_level
        config.dsn = dsn
        config.environment = environment
      end
    end

    def start
      super
    end

    def write(chunk)
      tag = chunk.metadata.tag
      chunk
        .each do |_time, record|
        next if record['message'].nil?

        Sentry.capture_message record['message'],
                               level: record['level'] || @default_level,
                               tags: {
                                 logger: 'fluent-sentry-logger',
                                 worker: record['worker'] || Socket.gethostname,
                                 tag: tag
                               }
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fluent-plugin-raven-0.1.8	lib/fluent/plugin/out_raven.rb