Class: ActFluentLoggerRails::FluentLogger
- Inherits:
-
ActiveSupport::Logger
- Object
- ActiveSupport::Logger
- ActFluentLoggerRails::FluentLogger
- Defined in:
- lib/act-fluent-logger-rails/logger.rb
Instance Method Summary collapse
- #[](key) ⇒ Object
- #[]=(key, value) ⇒ Object
- #add(severity, message = nil, progname = nil, &block) ⇒ Object
- #add_message(severity, message) ⇒ Object
- #close ⇒ Object
- #flush ⇒ Object
- #format_severity(severity) ⇒ Object
-
#initialize(options, level, log_tags) ⇒ FluentLogger
constructor
A new instance of FluentLogger.
- #level ⇒ Object
- #level=(l) ⇒ Object
Constructor Details
#initialize(options, level, log_tags) ⇒ FluentLogger
Returns a new instance of FluentLogger.
64 65 66 67 68 69 70 71 72 73 74 75 76 77 |
# File 'lib/act-fluent-logger-rails/logger.rb', line 64 def initialize(, level, ) self.level = level port = [:port] host = [:host] @messages_type = ([:messages_type] || :array).to_sym @tag = [:tag] @severity_key = ([:severity_key] || :severity).to_sym @flush_immediately = [:flush_immediately] @fluent_logger = ::Fluent::Logger::FluentLogger.new(nil, host: host, port: port) @severity = 0 @messages = [] @log_tags = @map = {} end |
Instance Method Details
#[](key) ⇒ Object
110 111 112 |
# File 'lib/act-fluent-logger-rails/logger.rb', line 110 def [](key) @map[key] end |
#[]=(key, value) ⇒ Object
114 115 116 |
# File 'lib/act-fluent-logger-rails/logger.rb', line 114 def []=(key, value) @map[key] = value end |
#add(severity, message = nil, progname = nil, &block) ⇒ Object
79 80 81 82 83 84 85 |
# File 'lib/act-fluent-logger-rails/logger.rb', line 79 def add(severity, = nil, progname = nil, &block) return true if severity < level = (block_given? ? block.call : progname) if .blank? return true if .blank? (severity, ) true end |
#add_message(severity, message) ⇒ Object
87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 |
# File 'lib/act-fluent-logger-rails/logger.rb', line 87 def (severity, ) @severity = severity if @severity < severity = case when ::String when ::Exception "#{ . } (#{ .class })\n" << (.backtrace || []).join("\n") else .inspect end if .encoding == Encoding::UTF_8 @messages << else @messages << .dup.force_encoding(Encoding::UTF_8) end flush if @flush_immediately end |
#close ⇒ Object
143 144 145 |
# File 'lib/act-fluent-logger-rails/logger.rb', line 143 def close @fluent_logger.close end |
#flush ⇒ Object
118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 |
# File 'lib/act-fluent-logger-rails/logger.rb', line 118 def flush return if @messages.empty? = if @messages_type == :string @messages.join("\n") else @messages end @map[:messages] = @map[@severity_key] = format_severity(@severity) @log_tags.each do |k, v| @map[k] = case v when Proc v.call(@request) when Symbol @request.send(v) else v end rescue :error end @fluent_logger.post(@tag, @map) @severity = 0 @messages.clear @map.clear end |
#format_severity(severity) ⇒ Object
155 156 157 |
# File 'lib/act-fluent-logger-rails/logger.rb', line 155 def format_severity(severity) ActFluentLoggerRails::Logger::SEV_LABEL[severity] || 'ANY' end |
#level ⇒ Object
147 148 149 |
# File 'lib/act-fluent-logger-rails/logger.rb', line 147 def level @level end |
#level=(l) ⇒ Object
151 152 153 |
# File 'lib/act-fluent-logger-rails/logger.rb', line 151 def level=(l) @level = l end |