Class: Cassandra::Retry::Policies::Default

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

Instance Method Summary collapse

Instance Method Details

#read_timeout(statement, consistency, required, received, retrieved, retries) ⇒ Object 



25
26
27
28
29
30
31
32
33
 
# File 'lib/cassandra/retry/policies/default.rb', line 25

def read_timeout(statement, consistency, required, received, retrieved, retries)
  return reraise if retries > 0

  if received >= required && !retrieved
    try_again(consistency)
  else
    try_next_host
  end
end

#unavailable(statement, consistency, required, alive, retries) ⇒ Object 



47
48
49
 
# File 'lib/cassandra/retry/policies/default.rb', line 47

def unavailable(statement, consistency, required, alive, retries)
  try_next_host
end

#write_timeout(statement, consistency, type, required, received, retries) ⇒ Object 



35
36
37
38
39
40
41
42
43
44
45
 
# File 'lib/cassandra/retry/policies/default.rb', line 35

def write_timeout(statement, consistency, type, required, received, retries)
  return reraise if retries > 0

  if statement.idempotent? && received.zero?
    try_next_host
  elsif type == :batch_log
    try_again(consistency)
  else
    reraise
  end
end