Test how long an ElastiCache Redis Failover takes before the app reconnects

test_elasticache_failover.rb

require 'redis'
$redis = Redis.new({url: ENV['REDIS_HOST']})

puts $redis.connected?

failed = false
starting = nil
ending = nil
loop do
  $redis.ping
  if failed
    ending = Time.now
    puts ending - starting
    break
  end
rescue => e
  puts e
  starting = Time.now unless failed
  failed = true
  retry
end

test_elasticache_failover_semian.rb

require 'redis'
require 'semian/redis'
$redis = Redis.new({url: ENV['REDIS_HOST'], semian: {
  name: "inventory",
  tickets: 4,
  success_threshold: 2,
  error_threshold: 4,
  error_timeout: 20
}})

puts $redis.connected?

failed = false
starting = nil
ending = nil
loop do
  $redis.ping
  if failed
    ending = Time.now
    puts ending - starting
    break
  end
rescue => e
  puts e
  starting = Time.now unless failed
  failed = true
  retry
end