Class: Mongo::Protocol::Reply

Inherits:
Message
  • Object
show all
Defined in:
lib/mongo/protocol/reply.rb

Overview

The MongoDB wire protocol message representing a reply

Examples:

socket = TCPSocket.new('localhost', 27017)
query = Protocol::Query.new('xgen', 'users', {:name => 'Tyler'})
socket.write(query)
reply = Protocol::Reply::deserialize(socket)

Defined Under Namespace

Classes: Upconverter

Constant Summary

Constants inherited from Message

Message::BATCH_SIZE, Message::COLLECTION, Message::LIMIT, Message::MAX_MESSAGE_SIZE, Message::ORDERED, Message::Q

Constants included from Serializers

Serializers::HEADER_PACK, Serializers::INT32_PACK, Serializers::INT64_PACK, Serializers::NULL, Serializers::ZERO

Instance Attribute Summary

Attributes inherited from Message

#request_id

Instance Method Summary collapse

Methods inherited from Message

#==, deserialize, deserialize_array, deserialize_field, deserialize_header, field, fields, #hash, #initialize, #maybe_add_server_api, #maybe_compress, #maybe_decrypt, #maybe_encrypt, #maybe_inflate, #replyable?, #serialize, #set_request_id

Methods included from Id

included

Constructor Details

This class inherits a constructor from Mongo::Protocol::Message

Instance Method Details

#cursor_not_found? ⇒ true, false

Determine if the reply had a cursor not found flag.

Examples:

Did the reply have a cursor not found flag.

reply.cursor_not_found?

Returns:

  • (true, false) —

    If the query cursor was not found.

Since:

  • 2.2.3



49
50
51
 
# File 'lib/mongo/protocol/reply.rb', line 49

def cursor_not_found?
  flags.include?(:cursor_not_found)
end

#payload ⇒ BSON::Document

Return the event payload for monitoring.

Examples:

Return the event payload.

message.payload

Returns:

  • (BSON::Document) —

    The event payload.

Since:

  • 2.1.0



61
62
63
64
65
66
 
# File 'lib/mongo/protocol/reply.rb', line 61

def payload
  BSON::Document.new(
    reply: upconverter.command,
    request_id: request_id
  )
end

#query_failure? ⇒ true, false

Determine if the reply had a query failure flag.

Examples:

Did the reply have a query failure.

reply.query_failure?

Returns:

  • (true, false) —

    If the query failed.

Since:

  • 2.0.5



37
38
39
 
# File 'lib/mongo/protocol/reply.rb', line 37

def query_failure?
  flags.include?(:query_failure)
end