import { Dictionary } from 'ts-essentials';
export declare const StreamNameSeparator = "__";
export declare enum Operation {
    UPSERT = "Upsert",
    UPDATE = "Update",
    DELETION = "Deletion",
    FLUSH = "Flush"
}
export interface TimestampedRecord {
    model: string;
    origin: string;
    at: number;
    operation: Operation;
}
export interface UpsertRecord extends TimestampedRecord {
    operation: Operation.UPSERT;
    data: Dictionary<any>;
}
export interface UpdateRecord extends TimestampedRecord {
    operation: Operation.UPDATE;
    where: Dictionary<any>;
    mask: string[];
    patch: Dictionary<any>;
}
export interface DeletionRecord extends TimestampedRecord {
    operation: Operation.DELETION;
    where: Dictionary<any>;
}
export interface Logger {
    info: (msg: string) => void;
    debug: (msg: string) => void;
    warn: (msg: string) => void;
}