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