import { IMessageDeduper, IOutputSink, IState, IStateProvider, IStateType, IStoredMessage } from "@walmartlabs/cookie-cutter-core";
import { SpanContext } from "opentracing";
import { IBlobStorageConfiguration, ICosmosConfiguration } from "..";
export interface ISnapshotProvider<TSnapshot> {
    get(spanContext: SpanContext, key: string, atSn?: number): Promise<[number, TSnapshot]>;
}
export interface IBlobStorageSnapshotOutputSinkConfiguration {
    readonly frequency?: number;
}
export declare function cosmosState<TState extends IState<TSnapshot>, TSnapshot>(configuration: ICosmosConfiguration, TState: IStateType<TState, TSnapshot>, aggregator: any, snapshotProvider?: ISnapshotProvider<TSnapshot>): IStateProvider<TState>;
export declare function cosmosSink(configuration: ICosmosConfiguration): IOutputSink<IStoredMessage>;
export declare function blobStorageSnapshotSink(configuration: IBlobStorageConfiguration & IBlobStorageSnapshotOutputSinkConfiguration): IOutputSink<IStoredMessage>;
export declare function blobStorageSnapshotProvider<TSnapshot>(configuration: IBlobStorageConfiguration): ISnapshotProvider<TSnapshot>;
export declare function cosmosDeduper(configuration: ICosmosConfiguration): IMessageDeduper;