Reply — Documentation by YARD 0.9.37 (original) (raw)

Class: Mongo::Protocol::Reply

Overview

The MongoDB wire protocol message representing a reply

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 Summarycollapse

Methods inherited from Message

#==, deserialize, #hash, #initialize, #maybe_add_server_api, #maybe_compress, #maybe_decrypt, #maybe_encrypt, #maybe_inflate, #replyable?, #serialize, #set_request_id

Methods included from Id

included

Instance Attribute Details

#cursor_id ⇒ Fixnum

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

103 # File 'lib/mongo/protocol/reply.rb', line 103 field :cursor_id, Int64

#documents ⇒ Array

Returns The documents in this Reply.

115 # File 'lib/mongo/protocol/reply.rb', line 115 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.

98 # File 'lib/mongo/protocol/reply.rb', line 98 field :flags, BitVector.new(FLAGS)

#number_returned ⇒ Fixnum

Returns Number of documents in this Reply.

111 # File 'lib/mongo/protocol/reply.rb', line 111 field :number_returned, Int32

#starting_from ⇒ Fixnum

Returns The starting position of the cursor for this Reply.

107 # File 'lib/mongo/protocol/reply.rb', line 107 field :starting_from, Int32

Instance Method Details

#cursor_not_found? ⇒ true, false

Determine if the reply had a cursor not found flag.

52 53 54 # File 'lib/mongo/protocol/reply.rb', line 52 def cursor_not_found? flags.include?(:cursor_not_found) end

#payload ⇒ BSON::Document

Return the event payload for monitoring.

64 65 66 67 68 69 # File 'lib/mongo/protocol/reply.rb', line 64 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.

40 41 42 # File 'lib/mongo/protocol/reply.rb', line 40 def query_failure? flags.include?(:query_failure) end