Sha256: 2eb8abd24719dcdab4639bd883805053c0ca0e7df6387d8f5d2f1a9c91f22185
Contents?: true
Size: 878 Bytes
Versions: 4
Compression:
Stored size: 878 Bytes
Contents
# encoding: utf-8 require 'cassandra' module Corm module Retry module Policies class Default include Cassandra::Retry::Policy 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 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 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 end end end end
Version data entries
4 entries across 4 versions & 2 rubygems