Contents

module Fozzie
  class BulkDsl
    include Fozzie::Interface

    def initialize(&block)
      @metrics = []
      block.arity < 1 ? instance_eval(&block) : block.call(self) if block_given?
      send_bulk
    end

    private

    # Cache the requested metrics for bulk sending
    #
    def send(stat, value, type, sample_rate = 1)
     val = { :bin => stat, :value => value, :type => type, :sample_rate => sample_rate }

     @metrics.push(val)
    end

    def send_bulk
      return if @metrics.empty?

      adapter.register(@metrics)
    end

  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
fozzie-1.0.2	lib/fozzie/bulk_dsl.rb
fozzie-1.0.1	lib/fozzie/bulk_dsl.rb
fozzie-1.0.0	lib/fozzie/bulk_dsl.rb