class Corm::Retry::Policies::Default

Public Instance Methods

read_timeout(_statement, consistency, _required, _received, retrieved, retries) click to toggle source
# File lib/polipus-cassandra/policies/default.rb, line 10
def read_timeout(_statement, consistency, _required, _received, retrieved, retries)
  return reraise if retries >= 5
  sleep(retries.to_f + Random.rand(0.0..1.0))
  retrieved ? reraise : try_again(consistency)
end
unavailable(_statement, consistency, _required, _alive, retries) click to toggle source
# File lib/polipus-cassandra/policies/default.rb, line 22
def unavailable(_statement, consistency, _required, _alive, retries)
  return reraise if retries >= 5
  sleep(retries.to_f + Random.rand(0.0..1.0))
  try_again(consistency)
end
write_timeout(_statement, consistency, _type, _required, _received, retries) click to toggle source
# File lib/polipus-cassandra/policies/default.rb, line 16
def write_timeout(_statement, consistency, _type, _required, _received, retries)
  return reraise if retries >= 5
  sleep(retries.to_f + Random.rand(0.0..1.0))
  try_again(consistency)
end