Module: Cassandra::Retry::Policy Abstract

Included in:
Cassandra::Retry::Policies::Default, Cassandra::Retry::Policies::DowngradingConsistency, Cassandra::Retry::Policies::Fallthrough
Defined in:
lib/cassandra/retry.rb

Overview

This module is abstract.

Actual retry policies supplied as :retry_policy option to Cassandra.cluster don't need to inherit this class, only implement its methods. This class exists for documentation purposes only.

Instance Method Summary collapse

Instance Method Details

#read_timeout(statement, consistency, required, received, retrieved, retries) ⇒ Cassandra::Policies::Retry::Decision

Note:

this method may be called even if required_responses >= received responses if data_present is false.

Decides wether to retry a read and at what consistency level.

See Also:

  • #try_again
  • #reraise
  • #ignore


46
47
 
# File 'lib/cassandra/retry.rb', line 46

def read_timeout(statement, consistency, required, received, retrieved, retries)
end

#unavailable(statement, consistency, required, alive, retries) ⇒ Cassandra::Policies::Retry::Decision

Decides wether to retry and at what consistency level on an Unavailable exception.

See Also:

  • #try_again
  • #reraise
  • #ignore


85
86
 
# File 'lib/cassandra/retry.rb', line 85

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

#write_timeout(statement, consistency, type, required, received, retries) ⇒ Cassandra::Policies::Retry::Decision

Decides wether to retry a write and at what consistency level.

See Also:

  • #try_again
  • #reraise
  • #ignore


66
67
 
# File 'lib/cassandra/retry.rb', line 66

def write_timeout(statement, consistency, type, required, received, retries)
end