Module: Mongo::Operation::Specifiable

Included in:
Commands::CollectionsInfo, Commands::Command, Commands::Indexes, Commands::UserQuery, KillCursors, Read::GetMore, Read::Query, Write::Bulk::Delete, Write::Bulk::Insert, Write::Bulk::Update, Write::Command::CreateIndex, Write::Command::CreateUser, Write::Command::Delete, Write::Command::DropIndex, Write::Command::Insert, Write::Command::RemoveUser, Write::Command::Update, Write::Command::UpdateUser, Write::CreateIndex, Write::CreateUser, Write::Delete, Write::DropIndex, Write::Insert, Write::RemoveUser, Write::Update, Write::UpdateUser
Defined in:
lib/mongo/operation/specifiable.rb

Overview

This module contains common functionality for convenience methods getting various values from the spec.

Since:

  • 2.0.0

Constant Summary collapse

DB_NAME =

The field for database name.

Since:

  • 2.0.0

:db_name.freeze
DELETES =

The field for deletes.

Since:

  • 2.0.0

:deletes.freeze
DELETE =

The field for delete.

Since:

  • 2.0.0

:delete.freeze
DOCUMENTS =

The field for documents.

Since:

  • 2.0.0

:documents.freeze
COLL_NAME =

The field for collection name.

Since:

  • 2.0.0

:coll_name.freeze
CURSOR_COUNT =

The field for cursor count.

Since:

  • 2.0.0

:cursor_count.freeze
CURSOR_ID =

The field for cursor id.

Since:

  • 2.0.0

:cursor_id.freeze
CURSOR_IDS =

The field for cursor ids.

Since:

  • 2.0.0

:cursor_ids.freeze
INDEX =

The field for an index.

Since:

  • 2.0.0

:index.freeze
INDEXES =

The field for multiple indexes.

Since:

  • 2.0.0

:indexes.freeze
INDEX_NAME =

The field for index names.

Since:

  • 2.0.0

:index_name.freeze
OPERATION_ID =

The operation id constant.

Since:

  • 2.1.0

:operation_id.freeze
OPTIONS =

The field for options.

Since:

  • 2.0.0

:options.freeze
READ_CONCERN =

The read concern option.

Since:

  • 2.2.0

:read_concern.freeze
SELECTOR =

The field for a selector.

Since:

  • 2.0.0

:selector.freeze
TO_RETURN =

The field for number to return.

Since:

  • 2.0.0

:to_return.freeze
UPDATES =

The field for updates.

Since:

  • 2.0.0

:updates.freeze
UPDATE =

The field for update.

Since:

  • 2.0.0

:update.freeze
USER =

The field name for a user.

Since:

  • 2.0.0

:user.freeze
USER_NAME =

The field name for user name.

Since:

  • 2.0.0

:user_name.freeze
WRITE_CONCERN =

The field name for a write concern.

Since:

  • 2.0.0

:write_concern.freeze
READ =

The field name for the read preference.

Since:

  • 2.0.0

:read.freeze
BYPASS_DOC_VALIDATION =

Whether to bypass document level validation.

Since:

  • 2.2.0

:bypass_document_validation.freeze

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#spec ⇒ Hash (readonly)

Returns spec The specification for the operation.

Returns:

  • (Hash) —

    spec The specification for the operation.

Since:

  • 2.0.0



140
141
142
 
# File 'lib/mongo/operation/specifiable.rb', line 140

def spec
  @spec
end

Instance Method Details

#==(other) ⇒ true, false Also known as: eql?

Check equality of two specifiable operations.

Examples:

Are the operations equal?

operation == other

Parameters:

  • other (Object) —

    The other operation.

Returns:

  • (true, false) —

    Whether the objects are equal.

Since:

  • 2.0.0



152
153
154
155
 
# File 'lib/mongo/operation/specifiable.rb', line 152

def ==(other)
  return false unless other.is_a?(Specifiable)
  spec == other.spec
end

#bypass_document_validation ⇒ true, false

Whether or not to bypass document level validation.

Examples:

Get the bypass_document_validation option.

specifiable.bypass_documentation_validation.

Returns:

  • (true, false) —

    Whether to bypass document level validation.

Since:

  • 2.2.0



350
351
352
 
# File 'lib/mongo/operation/specifiable.rb', line 350

def bypass_document_validation
  spec[BYPASS_DOC_VALIDATION]
end

#coll_name ⇒ String

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

Examples:

Get the collection name.

specifiable.coll_name

Returns:

  • (String) —

    Collection name.

Since:

  • 2.0.0



226
227
228
 
# File 'lib/mongo/operation/specifiable.rb', line 226

def coll_name
  spec[COLL_NAME]
end

#cursor_count ⇒ Integer

Get the cursor count from the spec.

Examples:

Get the cursor count.

specifiable.cursor_count

Returns:

  • (Integer) —

    The cursor count.

Since:

  • 2.0.0



166
167
168
 
# File 'lib/mongo/operation/specifiable.rb', line 166

def cursor_count
  spec[CURSOR_COUNT]
end

#cursor_id ⇒ Integer

The id of the cursor created on the server.

Examples:

Get the cursor id.

specifiable.cursor_id

Returns:

  • (Integer) —

    The cursor id.

Since:

  • 2.0.0



238
239
240
 
# File 'lib/mongo/operation/specifiable.rb', line 238

def cursor_id
  spec[CURSOR_ID]
end

#cursor_ids ⇒ Array<Integer>

The ids of the cursors to kill from the spec.

Examples:

Get the cursor ids from the spec.

specifiable.cursor_ids

Returns:

  • (Array<Integer>) —

    The cursor ids.

Since:

  • 2.0.0



250
251
252
 
# File 'lib/mongo/operation/specifiable.rb', line 250

def cursor_ids
  spec[CURSOR_IDS]
end

#db_name ⇒ String

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

Examples:

Get the database name.

specifiable.db_name

Returns:

  • (String) —

    Database name.

Since:

  • 2.0.0



178
179
180
 
# File 'lib/mongo/operation/specifiable.rb', line 178

def db_name
  spec[DB_NAME]
end

#delete ⇒ Hash

Get the delete document from the specification.

Examples:

Get the delete document.

specifiable.delete

Returns:

  • (Hash) —

    The delete document.

Since:

  • 2.0.0



202
203
204
 
# File 'lib/mongo/operation/specifiable.rb', line 202

def delete
  spec[DELETE]
end

#deletes ⇒ Array<BSON::Document>

Get the deletes from the specification.

Examples:

Get the deletes.

specifiable.deletes

Returns:

  • (Array<BSON::Document>) —

    The deletes.

Since:

  • 2.0.0



190
191
192
 
# File 'lib/mongo/operation/specifiable.rb', line 190

def deletes
  spec[DELETES]
end

#documents ⇒ Array<BSON::Document>

The documents to in the specification.

Examples:

Get the documents.

specifiable.documents

Returns:

  • (Array<BSON::Document>) —

    The documents.

Since:

  • 2.0.0



214
215
216
 
# File 'lib/mongo/operation/specifiable.rb', line 214

def documents
  spec[DOCUMENTS]
end

#index ⇒ Hash

Get the index from the specification.

Examples:

Get the index specification.

specifiable.index

Returns:

  • (Hash) —

    The index specification.

Since:

  • 2.0.0



262
263
264
 
# File 'lib/mongo/operation/specifiable.rb', line 262

def index
  spec[INDEX]
end

#index_name ⇒ String

Get the index name from the spec.

Examples:

Get the index name.

specifiable.index_name

Returns:

  • (String) —

    The index name.

Since:

  • 2.0.0



274
275
276
 
# File 'lib/mongo/operation/specifiable.rb', line 274

def index_name
  spec[INDEX_NAME]
end

#indexes ⇒ Hash

Get the indexes from the specification.

Examples:

Get the index specifications.

specifiable.indexes

Returns:

  • (Hash) —

    The index specifications.

Since:

  • 2.0.0



286
287
288
 
# File 'lib/mongo/operation/specifiable.rb', line 286

def indexes
  spec[INDEXES]
end

#initialize(spec) ⇒ Object

Create the new specifiable operation.

Examples:

Create the new specifiable operation.

Specifiable.new(spec)

Parameters:

  • spec (Hash) —

    The operation specification.

See Also:

  • individual operations for the values they require in their specs.

Since:

  • 2.0.0



301
302
303
 
# File 'lib/mongo/operation/specifiable.rb', line 301

def initialize(spec)
  @spec = spec
end

#namespace ⇒ String

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

Examples:

Get the namespace.

specifiable.namespace

Returns:

  • (String) —

    The namespace.

Since:

  • 2.1.0



468
469
470
 
# File 'lib/mongo/operation/specifiable.rb', line 468

def namespace
  "#{db_name}.#{coll_name}"
end

#operation_id ⇒ Integer

Get the operation id for the operation. Used for linking operations in monitoring.

Examples:

Get the operation id.

specifiable.operation_id

Returns:

  • (Integer) —

    The operation id.

Since:

  • 2.1.0



314
315
316
 
# File 'lib/mongo/operation/specifiable.rb', line 314

def operation_id
  spec[OPERATION_ID]
end

#options ⇒ Hash

Get the options for the operation.

Examples:

Get the options.

specifiable.options

Returns:

  • (Hash) —

    The options.

Since:

  • 2.0.0



326
327
328
 
# File 'lib/mongo/operation/specifiable.rb', line 326

def options
  spec[OPTIONS] || {}
end

#ordered? ⇒ true, false

Whether the operation is ordered.

Examples:

Get the ordered value, true is the default.

specifiable.ordered?

Returns:

  • (true, false) —

    Whether the operation is ordered.

Since:

  • 2.1.0



456
457
458
 
# File 'lib/mongo/operation/specifiable.rb', line 456

def ordered?
  !!(@spec.fetch(:ordered, true))
end

#read ⇒ Mongo::ServerSelector

The read preference for this operation.

Examples:

Get the read preference.

specifiable.read

Returns:

Since:

  • 2.0.0



444
445
446
 
# File 'lib/mongo/operation/specifiable.rb', line 444

def read
  @spec[READ] || ServerSelector.get
end

#read_concern ⇒ Hash

Get the read concern from the spec.

Examples:

Get the read concern.

specifiable.read_concern

Returns:

  • (Hash) —

    The read concern.

Since:

  • 2.2.0



338
339
340
 
# File 'lib/mongo/operation/specifiable.rb', line 338

def read_concern
  spec[READ_CONCERN]
end

#selector ⇒ Hash

The selector for from the specification.

Examples:

Get a selector specification.

specifiable.selector.

Returns:

  • (Hash) —

    The selector spec.

Since:

  • 2.0.0



362
363
364
 
# File 'lib/mongo/operation/specifiable.rb', line 362

def selector
  spec[SELECTOR]
end

#to_return ⇒ Integer

The number of documents to request from the server.

Examples:

Get the to return value from the spec.

specifiable.to_return

Returns:

  • (Integer) —

    The number of documents to return.

Since:

  • 2.0.0



374
375
376
 
# File 'lib/mongo/operation/specifiable.rb', line 374

def to_return
  spec[TO_RETURN]
end

#update ⇒ Hash

The update document from the spec.

Examples:

Get the update document.

Returns:

  • (Hash) —

    The update document.

Since:

  • 2.0.0



396
397
398
 
# File 'lib/mongo/operation/specifiable.rb', line 396

def update
  spec[UPDATE]
end

#updates ⇒ Array<BSON::Document>

The update documents from the spec.

Examples:

Get the update documents.

Returns:

  • (Array<BSON::Document>) —

    The update documents.

Since:

  • 2.0.0



385
386
387
 
# File 'lib/mongo/operation/specifiable.rb', line 385

def updates
  spec[UPDATES]
end

#user ⇒ Auth::User

The user for user related operations.

Examples:

Get the user.

specifiable.user

Returns:

Since:

  • 2.0.0



408
409
410
 
# File 'lib/mongo/operation/specifiable.rb', line 408

def user
  spec[USER]
end

#user_name ⇒ String

The user name from the specification.

Examples:

Get the user name.

specifiable.user_name

Returns:

  • (String) —

    The user name.

Since:

  • 2.0.



420
421
422
 
# File 'lib/mongo/operation/specifiable.rb', line 420

def user_name
  spec[USER_NAME]
end

#write_concern ⇒ Mongo::WriteConcern

The write concern to use for this operation.

Examples:

Get the write concern.

specifiable.write_concern

Returns:

Since:

  • 2.0.0



432
433
434
 
# File 'lib/mongo/operation/specifiable.rb', line 432

def write_concern
  @spec[WRITE_CONCERN]
end