Documentation for a newer release is available. View Latest

Modelo de datos de Mongo Offset

Lista de colecciones

MongoOffset

Esta colección rastrea las últimas entradas del journal que han sido procesadas por un event processor para un tag y eventProcessorId dados.

Diagrama general

A continuación se muestra un diagrama que muestra la colección mongoOffset en su totalidad:

bar

Descripción general de la colección

MongoOffset

Campos

A continuación se muestran los campos de la colección mongoOffset:

Field Description Example

_id

PK - We set this value at the application level to be a complex type referencing the tag and eventProcessorId

{"tag" : "tag-0", "eventProcessorId" : "IpfProcessingDataEventProcessor"}

offset

Stores the latest offset value as a MongoDB ObjectID

{"objectId" : "644a63481ddeb960823f6cac"}

Registro de ejemplo

{
    "_id" : {
        "tag" : "tag-0",
        "eventProcessorId" : "IpfProcessingDataEventProcessor"
    },
    "offset" : {
        "objectId" : "644a63481ddeb960823f6cac",
        "_class" : "com.iconsolutions.akka.persistence.mongodb.MongoDBReadJournal$ObjectIdOffset"
    },
    "_class" : "com.iconsolutions.ipf.core.platform.journal.mongo.MongoOffset"
}

Índices

A continuación se muestran los índices de la colección mongoOffset:

Index Name Fields Description

_id_

_id (ascending)

Complex type consisting of the tag and eventProcessorId