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

Instance Attribute Summary collapse

Attributes inherited from Message

#request_id

Instance Method Summary collapse

Methods inherited from Message

#==, deserialize, #hash, #replyable?, #serialize, #set_request_id

Instance Attribute Details

#cursor_id ⇒ Fixnum

Returns The cursor id for this response. Will be zero if there are no additional results.

Returns:

  • (Fixnum) —

    The cursor id for this response. Will be zero if there are no additional results.



97
 
# File 'lib/mongo/protocol/reply.rb', line 97

field :cursor_id, Int64

#documents ⇒ Array<Hash>

Returns The documents in this Reply.

Returns:

  • (Array<Hash>) —

    The documents in this Reply.



109
 
# File 'lib/mongo/protocol/reply.rb', line 109

field :documents, Document, :@number_returned

#flags ⇒ Array<Symbol>

Returns The flags for this reply.

Supported flags: :cursor_not_found, :query_failure, :shard_config_stale, :await_capable.

Returns:

  • (Array<Symbol>) —

    The flags for this reply.

    Supported flags: :cursor_not_found, :query_failure, :shard_config_stale, :await_capable



92
 
# File 'lib/mongo/protocol/reply.rb', line 92

field :flags, BitVector.new(FLAGS)

#number_returned ⇒ Fixnum

Returns Number of documents in this Reply.

Returns:

  • (Fixnum) —

    Number of documents in this Reply.



105
 
# File 'lib/mongo/protocol/reply.rb', line 105

field :number_returned, Int32

#starting_from ⇒ Fixnum

Returns The starting position of the cursor for this Reply.

Returns:

  • (Fixnum) —

    The starting position of the cursor for this Reply.



101
 
# File 'lib/mongo/protocol/reply.rb', line 101

field :starting_from, Int32

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 ⇒ Hash

Return the event payload for monitoring.

Examples:

Return the event payload.

message.payload

Returns:

  • (Hash) —

    The event payload.

Since:

  • 2.1.0



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

def payload
  { 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