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
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