Commit 3ac905a5 authored by Paul Asmuth's avatar Paul Asmuth
Browse files

widget api merge wip

parent 1302002c

doc/v0.9_example.rb

0 → 100644
+53 −0
Original line number Diff line number Diff line 
$: << ::File.expand_path("../../../fnordmetric/lib/", __FILE__)

require "fnordmetric"



FnordMetric.namespace :ulm do



  gauge :skip_votes, :tick => 1.day.to_i, :title => "Skip-Votes"

  gauge :yes_votes, :tick => 1.day.to_i, :title => "Yes-Votes"

  gauge :maybe_votes, :tick => 1.day.to_i, :title => "Maybe-Votes"



  gauge :messages_sent, :tick => 1.day.to_i, :title => "Messages (sent)"

  gauge :messages_read, :tick => 1.day.to_i, :title => "Messages (read)"

  gauge :winks_sent, :tick => 1.day.to_i, :title => "Winks sent"



  widget 'Overview', {

    :title => "User-Activity",

    :type => :timeline,

    :width => 67,

    :autoupdate => 30,

    :gauges => [:skip_votes, :yes_votes, :maybe_votes]

  }



  widget 'Overview', {

    :title => "Yes/No/Skip-Votes",

    :type => :timeline,

    :gauges => [:skip_votes, :yes_votes, :maybe_votes]

  }



  widget 'Overview', {

    :title => "Yes/No/Skip Numbers",

    :type => :numbers,

    :gauges => [:skip_votes, :yes_votes, :maybe_votes]

  }





  widget 'Overview', {

    :title => "Messages sent/read",

    :type => :timeline,

    :gauges => [:messages_sent, :messages_read, :winks_sent]

  }



  widget 'Overview', {

    :title => "Messages sent+read/Winks Numbers",

    :type => :numbers,

    :gauges => [:messages_sent, :messages_read, :winks_sent]

  }

  

end



FnordMetric.options = {

  :print_stats => 3

}



FnordMetric.standalone

lib/fnordmetric.rb

+1 −1
Original line number Diff line number Diff line
@@ -139,7 +139,7 @@ require "fnordmetric/acceptors/udp_acceptor" 




require "fnordmetric/gauges/dummy_gauge"

require "fnordmetric/gauges/numeric_gauge"

require "fnordmetric/gauges/numeric_timeseries_gauge"

require "fnordmetric/gauges/realtime_gauge"



require "fnordmetric/widgets/widget"

lib/fnordmetric/gauges/numeric_gauge.rb

deleted100644 → 0
+0 −84
Original line number Diff line number Diff line 
class FnordMetric::NumericGauge < FnordMetric::MultiGauge



  def initialize(opts)   

    super(opts)



    validate_series!

    validate_ticks!



    timeline_widget(

      :tab => "Overview",

      :title => "Total #{key_nouns.last}",

      :ticks => @opts[:ticks],

      :series => @opts[:series],

      :series_titles => Hash[@opts[:series].map{|s| [s, s]}],

      :autoupdate => 10,

      :height => 350

    ).on(:values_at) do |_series, _ticks, _tick|

      series_count_metrics[_series][_tick].values_at(_ticks)

    end



    numbers_widget(

      :tab => "Overview",

      :title => "Total #{key_nouns.last}",

      :series => @opts[:series],

      :series_titles => Hash[@opts[:series].map{|s| [s, s]}],

      :autoupdate => 2

    ).on(:values_for) do |_series|

      render_series_numbers(_series.to_sym)

    end



  end



  def react(event)

    if event["_class"] == "incrby" || event["_class"] == "incr"

      series = event["series"]

      series ||= @opts[:series][0] if @opts[:series].size == 1

      incr_series(series.to_sym, event["_time"], event["value"])

    end

  end





private



  def incr_series(series, time, value)

    value = value.to_i == 0 ? 1 : value.to_i

    unless series_count_metrics[series]

      return FnordMetric.error("gauge '#{name}' -> unknown series: #{series}")

    end

    series_count_metrics[series].values.each do |metric|

      metric.incr(time, value)

    end

  end



  def series_count_metrics

    @series_gauges ||= Hash[@opts[:series].map do |series|

      [series, Hash[@opts[:ticks].map do |tick|

        [tick.to_i, FnordMetric::RedisMetric.new(

          :key => "count-#{series}", 

          :key_prefix => key,

          :tick => tick.to_i,

        )]

      end]]

    end]

  end



      

  def render_series_numbers(series)

    _t = Time.now.to_i



    {}.tap do |out|

      @opts[:ticks].each do |tick|

        out["#{tick}-now"]  = { 

          :value => series_count_metrics[series][tick].value_at(_t),

          :desc  => "$formatTimeRangePre(#{tick}, 0)"

        }

        out["#{tick}-last"] = { 

          :value => series_count_metrics[series][tick].value_at(_t-tick),

          :desc  => "$formatTimeRangePre(#{tick}, -1)"

        }

      end

    end

  end



end
 
 No newline at end of file

lib/fnordmetric/gauges/numeric_timeseries_gauge.rb

0 → 100644
+154 −0
Original line number Diff line number Diff line 
class FnordMetric::NumericTimeseriesGauge < FnordMetric::MultiGauge



  #def execute(runner, _backend)

    # super

    # backend = _backend[0].new(_backend[1])



    # colors = ["#2F635E", "#606B36", "#727070", "#936953", "#CD645A", "#FACE4F", "#42436B"]



    # t_since = @opts["since"].to_i

    # t_until = @opts["until"].to_i



    # @tick = (t_until - t_since) / 150



    # @series_timelines = Hash.new

    # @series_queries = Hash.new



    # timeline = Hash[149.times.inject([t_until]) do |a, n|

    #   a + [a.first - n*@tick]

    # end.map do |t|

    #   [t, 0]

    # end]



    # @opts["series"].each do |skey, series|

    #   @opts["series"][skey]["color"] ||= colors.unshift(colors.pop).first

    #   @series_timelines[skey] = timeline.dup

    #   @series_queries[skey] = FnordQuery::Query.new("#{series["query"]}")

    # end



    # query = FnordQuery::Query.new("#{@opts["query"]} since(#{t_since}) until(#{t_until})")



    # puts "tick: #{@tick}"

    # puts "time: #{Time.at(t_since).to_s}-#{Time.at(t_until).to_s}"



    # backend.on_finish do

    #   render_result

    #   runner.send(:shutdown, true)

    # end



    # backend.subscribe(query) do |event|



    #   @series_queries.each do |skey, squery|

    #     if squery.matches?(event)

    #       (event["_time"]-@tick..event["_time"]).to_a.reverse.detect do |t|

    #         if @series_timelines[skey].has_key?(t)

    #           @series_timelines[skey][t] += 1

    #         end

    #       end

    #     end

    #   end



    # end

  #end



private



  # def render_result

  #   @series_render = @opts["series"].map do |skey, sopts|

  #     {

  #       :data  => @series_timelines[skey].map { |t,v| 

  #         { :x => t, :y => v } 

  #       }.reverse,

  #       :name  => sopts["name"],

  #       :color => sopts["color"]

  #     }

  #   end

  #   render_haml(:numeric_timeseries_report, 'report.html')

  # end



end



# class FnordMetric::NumericGauge < FnordMetric::MultiGauge



#   def initialize(opts)   

#     super(opts)



#     validate_series!

#     validate_ticks!



#     timeline_widget(

#       :tab => "Overview",

#       :title => "Total #{key_nouns.last}",

#       :ticks => @opts[:ticks],

#       :series => @opts[:series],

#       :series_titles => Hash[@opts[:series].map{|s| [s, s]}],

#       :autoupdate => 10,

#       :height => 350

#     ).on(:values_at) do |_series, _ticks, _tick|

#       series_count_metrics[_series][_tick].values_at(_ticks)

#     end



#     numbers_widget(

#       :tab => "Overview",

#       :title => "Total #{key_nouns.last}",

#       :series => @opts[:series],

#       :series_titles => Hash[@opts[:series].map{|s| [s, s]}],

#       :autoupdate => 2

#     ).on(:values_for) do |_series|

#       render_series_numbers(_series.to_sym)

#     end



#   end



#   def react(event)

#     if event["_class"] == "incrby" || event["_class"] == "incr"

#       series = event["series"]

#       series ||= @opts[:series][0] if @opts[:series].size == 1

#       incr_series(series.to_sym, event["_time"], event["value"])

#     end

#   end





# private



#   def incr_series(series, time, value)

#     value = value.to_i == 0 ? 1 : value.to_i

#     unless series_count_metrics[series]

#       return FnordMetric.error("gauge '#{name}' -> unknown series: #{series}")

#     end

#     series_count_metrics[series].values.each do |metric|

#       metric.incr(time, value)

#     end

#   end



#   def series_count_metrics

#     @series_gauges ||= Hash[@opts[:series].map do |series|

#       [series, Hash[@opts[:ticks].map do |tick|

#         [tick.to_i, FnordMetric::RedisMetric.new(

#           :key => "count-#{series}", 

#           :key_prefix => key,

#           :tick => tick.to_i,

#         )]

#       end]]

#     end]

#   end



      

#   def render_series_numbers(series)

#     _t = Time.now.to_i



#     {}.tap do |out|

#       @opts[:ticks].each do |tick|

#         out["#{tick}-now"]  = { 

#           :value => series_count_metrics[series][tick].value_at(_t),

#           :desc  => "$formatTimeRangePre(#{tick}, 0)"

#         }

#         out["#{tick}-last"] = { 

#           :value => series_count_metrics[series][tick].value_at(_t-tick),

#           :desc  => "$formatTimeRangePre(#{tick}, -1)"

#         }

#       end

#     end

#   end



# end
 
 No newline at end of file

lib/fnordmetric/web/websocket.rb

+1 −0
Original line number Diff line number Diff line
@@ -37,6 +37,7 @@ private 
        end

        

        socket.onmessage do |message|

          puts "received: #{message}"

          begin

            message = JSON.parse(message)

          rescue

CRA Git | Maintained and supported by SUSTech CRA and CCSE