Módulo: Mongo::Operation::Result::Aggregatable Privado

Definido en:
lib/mongo/operation/shared/result/aggregatable.rb

Overview

Este módulo es parte de una API privada. Deberías evitar usar este módulo si es posible, ya que puede ser removido o cambiado en el futuro.

Define el comportamiento personalizado de los resultados de guardado por lotes

Desde:

  • 2.0.0

Resumen del método de instancia colapsar

Detalles del método de instancia

#aggregate_write_concern_errors(count) ⇒ arreglo

Este método es parte de una API privada. Se debe evitar el uso de este método si es posible, ya que podría eliminarse o modificarse en el futuro.

Agrega los errores de nivel de confirmación de escritura (write concern) devueltos por este resultado.

Ejemplos:

Agrega los errores de nivel de confirmación de escritura (write concern).

result.aggregate_write_concern_errors(100)

Parámetros:

  • count (Número entero) —

    La cantidad de documentos ya ejecutados.

Devuelve:

  • (arreglo) —

    Los errores de nivel de confirmación de escritura (write concern) agregados.

Desde:

  • 2.0.0



58
59
60
61
62
63
64
65
66
67
68
69
 
# Archivo 'lib/mongo/operación/shared/result/aggregatable.rb', línea 58

def aggregate_write_concern_errors(count)
  return a menos que @replies

  @replies.each_with_index.disminuir(nulo) hacer |errors, (respuesta, _)|
    Next a menos que write_concern_errors = respuesta.Documentos.primero['writeConcernErrors']

    (errors || []) << write_concern_errors.disminuir(nulo) hacer |errs, wce|
      wce.¡Actualizar!('index' => count + wce['index'])
      (errs || []) << write_concern_error
    end
  end
end

#aggregate_write_errors(count) ⇒ arreglo

Este método es parte de una API privada. Se debe evitar el uso de este método si es posible, ya que podría eliminarse o modificarse en el futuro.

Agrega los errores de guardado devueltos de este resultado.

Ejemplos:

Agrega los errores de guardado.

result.aggregate_write_errors(0)

Parámetros:

  • count (Número entero) —

    La cantidad de documentos ya ejecutados.

Devuelve:

  • (arreglo) —

    Los errores de guardado agregados.

Desde:

  • 2.0.0



35
36
37
38
39
40
41
42
43
44
45
46
 
# Archivo 'lib/mongo/operación/shared/result/aggregatable.rb', línea 35

def aggregate_write_errors(count)
  return a menos que @replies

  @replies.disminuir(nulo) hacer |errors, respuesta|
    Next a menos que write_errors = respuesta.Documentos.primero['writeErrors']

    wes = write_errors.collect hacer |nosotros|
      nosotros.¡Actualizar!('index' => count + nosotros['index'])
    end
    (errors || []) << wes si wes
  end
end