Sha256: 9cd9b1850a47a6743d43c2d9b2b24454f8cd00cce911f94bbe81c78e8f4ee0dd

Contents?: true

Size: 553 Bytes

Versions: 8

Compression:

Stored size: 553 Bytes

Contents

require 'rubygems'

require 'rufus/scheduler'
require 'rufus/tokyo/tyrant'
require 'rufus/edo/ntyrant'

SCHEDULER = Rufus::Scheduler.start_new

FFI_TABLE = Rufus::Tokyo::TyrantTable.new('127.0.0.1', 45001)
NET_TABLE = Rufus::Edo::NetTyrantTable.new('127.0.0.1', 45001)

def check_connection (table)
  p [ table.class, table.stat ]
end

$interval = 0

BLOCK = lambda {
  puts "=== #{Time.now}"
  check_connection(FFI_TABLE)
  check_connection(NET_TABLE)
  $interval = $interval + 1
  SCHEDULER.in("#{$interval}h", &BLOCK)
}

BLOCK.call

SCHEDULER.join

Version data entries

8 entries across 8 versions & 2 rubygems

Version Path
rufus-tokyo-1.0.7 test/con0.rb
rufus-tokyo-1.0.6 test/con0.rb
rufus-tokyo-1.0.5 test/con0.rb
rufus-tokyo-1.0.4 test/con0.rb
metry-1.0.0 vendor/rufus-tokyo/test/con0.rb
metry-1.0.1 vendor/rufus-tokyo/test/con0.rb
metry-1.1.0 vendor/rufus-tokyo/test/con0.rb
metry-1.2.0 vendor/rufus-tokyo/test/con0.rb