import { IComponentContext, IDisposable, ILogger, IMessage, IMessageEncoder, IOutputSinkGuarantees, IRequireInitialization, RetrierContext, StateRef } from "@walmartlabs/cookie-cutter-core"; import { SpanContext, Tracer } from "opentracing"; import { CosmosClient, ICosmosDocument } from "."; import { ICosmosConfiguration } from ".."; export declare class CosmosOutputSinkBase implements IRequireInitialization, IDisposable { protected readonly client: CosmosClient; protected readonly encoder: IMessageEncoder; protected logger: ILogger; protected tracer: Tracer; constructor(config: ICosmosConfiguration); initialize(context: IComponentContext): Promise; dispose(): Promise; get guarantees(): IOutputSinkGuarantees; protected doBulkInsert(documents: ICosmosDocument[], verifySn: boolean, retry: RetrierContext): Promise; protected formatData(msg: IMessage): any; protected verifyState(stateRef: StateRef, spanContext: SpanContext, retry: RetrierContext): Promise; }