class Cassandra::Protocol::WriteFailureErrorResponse

Attributes

blockfor[R]
consistency[R]
failures_by_node[R]
numfailures[R]
received[R]
write_type[R]

Public Class Methods

new(custom_payload, warnings, code, message, consistency, received, blockfor, numfailures, write_type, failures_by_node) click to toggle source
Calls superclass method Cassandra::Protocol::ErrorResponse::new
   # File lib/cassandra/protocol/responses/write_failure_error_response.rb
24 def initialize(custom_payload,
25                warnings,
26                code,
27                message,
28                consistency,
29                received,
30                blockfor,
31                numfailures,
32                write_type,
33                failures_by_node)
34   super(custom_payload, warnings, code, message)
35 
36   write_type.downcase!
37 
38   @consistency      = consistency
39   @received         = received
40   @blockfor         = blockfor
41   @write_type       = write_type.to_sym
42   @failures_by_node = failures_by_node
43 
44   # If failures_by_node is set, numfailures isn't, and v.v. Set @numfailures to the size of the failure-map
45   # if numfailures is nil.
46   @numfailures = numfailures || @failures_by_node.size
47 end

Public Instance Methods

to_error(keyspace, statement, options, hosts, consistency, retries) click to toggle source
   # File lib/cassandra/protocol/responses/write_failure_error_response.rb
49 def to_error(keyspace, statement, options, hosts, consistency, retries)
50   Errors::WriteError.new(@message,
51                          @custom_payload,
52                          @warnings,
53                          keyspace,
54                          statement,
55                          options,
56                          hosts,
57                          consistency,
58                          retries,
59                          @write_type,
60                          @consistency,
61                          @blockfor,
62                          @numfailures,
63                          @received,
64                          @failures_by_node)
65 end
to_s() click to toggle source
   # File lib/cassandra/protocol/responses/write_failure_error_response.rb
67 def to_s
68   "#{super} #{@write_type} #{@consistency} #{@blockfor} " \
69       "#{@numfailures} #{@received}"
70 end