Interface IngestionService

This service is used to ingest data into the database

interface IngestionService {
    updateMany<T extends BaseModel>(
        options: IngestOptions<T>,
    ): Promise<IngestResult>;
}

Index

Methods

Methods

updateMany

updateMany<T extends BaseModel>(
options: IngestOptions<T>,
): Promise<IngestResult>
Updates a document in the destination repository per record of the source data stream
Type Parameters
- T extends BaseModel
Parameters
- options: IngestOptions<T>
  The ingestion options
Returns Promise<IngestResult>
- Defined in packages/services/src/services/Ingestion/IngestionService.ts:14