123456789_123456789_123456789_123456789_123456789_

Class: Mongo::Operation::OpMsgBase Private

Do not use. This class is for internal use only.
Relationships & Source Files
Extension / Inclusion / Inheritance Descendants
Subclasses:
Mongo::Operation::Aggregate::OpMsg, Mongo::Operation::Command::OpMsg, Mongo::Operation::Count::OpMsg, Mongo::Operation::Create::OpMsg, Mongo::Operation::CreateIndex::OpMsg, Mongo::Operation::CreateSearchIndexes::OpMsg, Mongo::Operation::CreateUser::OpMsg, Mongo::Operation::Delete::OpMsg, Mongo::Operation::Distinct::OpMsg, Mongo::Operation::Drop::OpMsg, Mongo::Operation::DropDatabase::OpMsg, Mongo::Operation::DropIndex::OpMsg, Mongo::Operation::DropSearchIndex::OpMsg, Mongo::Operation::Explain::OpMsg, Mongo::Operation::Find::OpMsg, Mongo::Operation::GetMore::OpMsg, Mongo::Operation::Indexes::OpMsg, Mongo::Operation::Insert::OpMsg, Mongo::Operation::KillCursors::OpMsg, Mongo::Operation::ListCollections::OpMsg, Mongo::Operation::MapReduce::OpMsg, Mongo::Operation::ParallelScan::OpMsg, Mongo::Operation::RemoveUser::OpMsg, Mongo::Operation::Update::OpMsg, Mongo::Operation::UpdateSearchIndex::OpMsg, Mongo::Operation::UpdateUser::OpMsg, Mongo::Operation::UsersInfo::OpMsg, Mongo::Operation::WriteCommand::OpMsg
Super Chains via Extension / Inclusion / Inheritance
Instance Chain:
self, Timed, SessionsSupported, Executable, ResponseHandling, Specifiable
Inherits: Object
Defined in: lib/mongo/operation/op_msg_base.rb

Constant Summary

Specifiable - Included

BYPASS_DOC_VALIDATION, COLLATION, COLL_NAME, CURSOR_COUNT, CURSOR_ID, DB_NAME, DELETE, DELETES, DOCUMENTS, INDEX, INDEXES, INDEX_NAME, MAX_TIME_MS, OPERATION_ID, OPTIONS, READ, READ_CONCERN, SELECTOR, TO_RETURN, UPDATE, UPDATES, USER, USER_NAME, WRITE_CONCERN

Executable - Included

NETWORK_ERRORS

SessionsSupported - Included

READ_COMMANDS, ZERO_TIMESTAMP

Instance Attribute Summary

Executable - Included

#context

Specifiable - Included

#acknowledged_write?

Does the operation have an acknowledged write concern.
#ordered?

Whether the operation is ordered.
#spec

Instance Method Summary

Timed - Included

#apply_relevant_timeouts_to

If a timeout is active (as defined by the current context), and it has not yet expired, add :maxTimeMS to the spec.
#with_max_time

A helper method that computes the remaining timeout (in seconds) and yields it to the associated block.

SessionsSupported - Included

#add_read_preference

Adds $readPreference field to the command document.
#add_write_concern!, #apply_autocommit!,
#apply_causal_consistency!

Adds causal consistency document to the selector, if one can be constructed and the selector is for a startTransaction command.
#apply_causal_consistency_if_possible

Adds causal consistency document to the selector, if one can be constructed.
#apply_cluster_time!, #apply_read_pref!, #apply_session_options, #apply_start_transaction!, #apply_txn_num!, #apply_txn_opts!, #build_message, #command, #flags, #read_command?, #suppress_read_write_concern!, #validate_read_preference!

Executable - Included

#do_execute, #execute, #build_message, #check_for_network_error,
#dispatch_message

Returns a ::Mongo::Protocol::Message or nil as reply.
#get_result, #process_result, #process_result_for_sdam, #result_class

ResponseHandling - Included

#add_error_labels

Adds error labels to exceptions raised in the yielded to block, which should perform MongoDB operations and raise Mongo::Errors on failure.
#add_server_diagnostics

Yields to the block and, if the block raises an exception, adds a note to the exception with the address of the specified server.
#maybe_add_retryable_write_error_label!

A method that will add the RetryableWriteError label to an error if any of the following conditions are true:
#unpin_maybe

Unpins the session and/or the connection if the yielded to block raises errors that are required to unpin the session and the connection.
#validate_result

Specifiable - Included

#==

Check equality of two specifiable operations.
#apply_collation,
#array_filters

The array filters.
#bypass_document_validation

Whether or not to bypass document level validation.
#coll_name

The name of the collection to which the operation should be sent.
#collation

The collation to apply to the operation.
#command

The command.
#cursor_count

Get the cursor count from the spec.
#cursor_id

The id of the cursor created on the server.
#db_name

The name of the database to which the operation should be sent.
#delete

Get the delete document from the specification.
#deletes

Get the deletes from the specification.
#documents

The documents to in the specification.
#eql?

Alias for Specifiable#==.
#index

Get the index from the specification.
#index_id

Get the index id from the spec.
#index_name

Get the index name from the spec.
#indexes

Get the indexes from the specification.
#initialize

Create the new specifiable operation.
#max_time_ms

Get the max time ms value from the spec.
#namespace

The namespace, consisting of the db name and collection name.
#operation_id

Get the operation id for the operation.
#options

Get the options for executing the operation on a particular connection.
#read

The read preference for this operation.
#read_concern

Get the read concern document from the spec.
#selector

The selector from the specification for execution on a particular connection.
#session

The session to use for the operation.
#to_return

The number of documents to request from the server.
#txn_num

The transaction number for the operation.
#update

The update document from the spec.
#updates

The update documents from the spec.
#user

The user for user related operations.
#user_name

The user name from the specification.
#write_concern

The write concern to use for this operation.

Instance Method Details

#message(connection) (private)

[ GitHub ] 

  


# File 'lib/mongo/operation/op_msg_base.rb', line 29



def message(connection)
  cmd = apply_relevant_timeouts_to(command(connection), connection)
  Protocol::Msg.new(flags, options(connection), cmd)
end