import { Dictionary } from 'ts-essentials'; import { GraphQLClient } from './graphql-client'; import { WriteStats } from './write-stats'; interface RecordProcessorHandler { handleRecordProcessingError: (stats: WriteStats, processRecord: () => Promise) => Promise; } export interface OriginProvider { getOrigin: (record?: Dictionary) => string; } export declare class GraphQLWriter { private readonly graphQLClient; private readonly originProvider; private readonly stats; private readonly recordProcessorHandler; private readonly timestampedRecords; constructor(graphQLClient: GraphQLClient, originProvider: OriginProvider, stats: WriteStats, recordProcessorHandler: RecordProcessorHandler); write(result: any): Promise; end(): Promise; private writeTimestampedRecord; } export {};