import { ErrorResponse } from "@azure/cosmos"; import { ISequenceConflictDetails, MessageRef } from "@walmartlabs/cookie-cutter-core"; import { SpanContext } from "opentracing"; export * from "./BlobClient"; export * from "./CosmosClient"; export * from "./CosmosOutputSinkBase"; export * from "./QueueClient"; export * from "./QueueClientWithLargeItemSupport"; export interface ICosmosMetadata { readonly source?: { readonly stream_id: string; readonly sn: number; }; } export interface ICosmosDocument { readonly id: string; readonly data?: any; readonly encodedData?: Uint8Array; readonly stream_id: string; readonly sn: number; readonly dt: number; readonly event_type: string; readonly metadata?: ICosmosMetadata; readonly trace: SpanContext; readonly ttl?: number; } export declare function cosmosMetadata(msg: MessageRef): ICosmosMetadata; export declare function isRetryableError(e: ErrorResponse): boolean; export declare function isSequenceConflict(e: ErrorResponse): boolean; export declare function getSequenceConflictDetails(e: ErrorResponse): ISequenceConflictDetails;