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