Class: Corm::Retry::Policies::Default

Inherits:
Object
  • Object
show all
Includes:
Cassandra::Retry::Policy
Defined in:
lib/polipus-cassandra/policies/default.rb

Instance Method Summary collapse

Instance Method Details

#read_timeout(_statement, consistency, _required, _received, retrieved, retries) ⇒ Object 



10
11
12
13
14
 
# 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) ⇒ Object 



22
23
24
25
26
 
# 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) ⇒ Object 



16
17
18
19
20
 
# 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