Módulo: Mongo::Operación::Resultado::Agregable Privado

Definido en:
lib/mongo/operación/compartido/resultado/agregable.rb

Overview

Este módulo forma parte de una API privada. Debe evitar su uso siempre que sea posible, ya que podría eliminarse o modificarse en el futuro.

Define el comportamiento personalizado de los resultados de escritura masiva

Desde:

  • 2.0.0

Colapso del resumen del método de instancia

Detalles del método de instancia

#errores_de_preocupación_de_escritura_agregados(recuento) ⇒ Matriz

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

Agregue los errores de escritura devueltos a partir de este resultado.

Ejemplos:

Agregue los errores de escritura.

result.aggregate_write_concern_errors(100)

Parámetros:

  • count (Entero)

    El número de documentos ya ejecutados.

Devuelve:

  • (Matriz)

    Los errores de escritura agregados preocupan.

Desde:

  • 2.0.0



60
61
62
63
64
65
66
67
68
69
70
# Archivo 'lib/mongo/operation/shared/result/aggregatable.rb', línea 60

def errores de preocupación por escritura agregada(count)
  return a no ser que @replies
  @replies.cada_con_índice.reducir(nulo) hacer |errors, (respuesta, _)|
    Si errores de escritura preocupantes = respuesta.Documentos.primera['escribirErrores de Preocupación ']
      (errors || []) << errores de escritura preocupantes.reducir(nulo) hacer |errs, wce|
        wce.¡unir!('index' => count + wce['index'])
        (errs || []) << error de escritura preocupante
      end
    end
  end
end

#added_write_errors(conteo) ⇒ Matriz

Este método forma parte de una API privada. Debe evitarlo si es posible, ya que podría eliminarse o modificarse en el futuro.

Agregue los errores de escritura devueltos a partir de este resultado.

Ejemplos:

Agregue los errores de escritura.

result.aggregate_write_errors(0)

Parámetros:

  • count (Entero)

    El número de documentos ya ejecutados.

Devuelve:

  • (Matriz)

    Los errores de escritura agregados.

Desde:

  • 2.0.0



38
39
40
41
42
43
44
45
46
47
48
# Archivo 'lib/mongo/operation/shared/result/aggregatable.rb', línea 38

def errores_de_escritura_agregados(count)
  return a no ser que @replies
  @replies.reducir(nulo) hacer |errors, respuesta|
    Si errores de escritura = respuesta.Documentos.primera['errores de escritura']
      wes = errores de escritura.collect hacer |nos|
        nos.¡unir!('index' => count + nos['index'])
      end
      (errors || []) << wes Si wes
    end
  end
end