Sha256: d9031ffe6d5d9607aa36390644ce6187f4837d524812831aca5e180fe78f2b05

Contents?: true

Size: 651 Bytes

Versions: 5

Compression:

Stored size: 651 Bytes

Contents

$:.unshift File.expand_path('../../lib/', __FILE__)

require "pulse-meter"

PulseMeter.redis = Redis.new
PulseMeter.redis.flushdb
PulseMeter.command_aggregator = PulseMeter::CommandAggregator::UDP.new([['127.0.0.1', 33333], ['127.0.0.1', 33334], ['127.0.0.1', 33335],])

ss = PulseMeter::Sensor::Configuration.new(
  cnt: {sensor_type: 'counter'}
)

start = Time.now.to_f

i = 0
loop do
  i += 1 
  ss.cnt(1)
  sleep 0.000005
  if i % 1000 == 0
    t = Time.now.to_f
    passed = t - start
    required_rps = i.to_f / passed
    val = ss.sensor(:cnt){|s| s.value}
    actual_rps = val.to_f / passed
    p [i, required_rps, val, actual_rps]
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version Path
pulse-meter-0.4.9 examples/udp_benchmark.rb
pulse-meter-0.4.8 examples/udp_benchmark.rb
pulse-meter-0.4.7 examples/udp_benchmark.rb
pulse-meter-0.4.6 examples/udp_benchmark.rb
pulse-meter-0.4.5 examples/udp_benchmark.rb