class Cassandra::Retry::Policies::Default

Public Instance Methods

read_timeout(statement, consistency, required, received, retrieved, retries) click to toggle source
   # File lib/cassandra/retry/policies/default.rb
25 def read_timeout(statement, consistency, required, received, retrieved, retries)
26   return reraise if retries > 0
27 
28   if received >= required && !retrieved
29     try_again(consistency)
30   else
31     try_next_host
32   end
33 end
unavailable(statement, consistency, required, alive, retries) click to toggle source
   # File lib/cassandra/retry/policies/default.rb
47 def unavailable(statement, consistency, required, alive, retries)
48   try_next_host
49 end
write_timeout(statement, consistency, type, required, received, retries) click to toggle source
   # File lib/cassandra/retry/policies/default.rb
35 def write_timeout(statement, consistency, type, required, received, retries)
36   return reraise if retries > 0
37 
38   if statement.idempotent? && received.zero?
39     try_next_host
40   elsif type == :batch_log
41     try_again(consistency)
42   else
43     reraise
44   end
45 end