out_yohoushi.rb in fluent-plugin-yohoushi-0.1.1

- old
+ new

@@ -35,11 +35,11 @@
 
     # Override default parameters of Bufferedoutput options
     config_param :buffer_type, :string, :default => 'memory'
     config_param :flush_interval, :time, :default => 0 # we can not wait 1 minute to create 1 minute graphs (originally, 60)
     config_param :try_flush_interval, :float, :default => 1 # we would be able to shorten more
-    config_param :retry_limit, :integer, :default => 1 # growthforecast requires a realtime post, so retry only once (originally, 17)
+    config_param :retry_limit, :integer, :default => 0 # growthforecast requires a realtime post, so do not retry (originally, 17)
     config_param :retry_wait, :time, :default => 1.0
     config_param :max_retry_wait, :time, :default => nil
     config_param :num_threads, :integer, :default => 1
     config_param :queued_chunk_flush_interval, :time, :default => 1
 
@@ -111,11 +111,11 @@
         @client.post_graph(path, { 'number' => number.to_f, 'mode' => @mode.to_s })
       else
         @client.post_graph(path, { 'number' => number.to_i, 'mode' => @mode.to_s })
       end
     rescue => e
-      $log.warn "out_yohoushi: #{e.class} #{e.message} #{e.backtrace.first}"
+      $log.warn "out_yohoushi: #{e.class} #{e.message} #{path} #{e.backtrace.first}"
     end
 
     def format(tag, time, record)
       [tag, time, record].to_msgpack
     end
@@ -149,9 +149,10 @@
           end
         end
       end
     rescue => e
       $log.warn "out_yohoushi: #{e.class} #{e.message} #{e.backtrace.first}"
+      # Here, no raise of an error, so this BufferedOutput does not retry
     end
 
     def expand_placeholder(value, time, record, opts)
       @placeholder_expander.prepare_placeholders(time, record, opts)
       @placeholder_expander.expand(value)