import * as Collections from 'typescript-collections';
import { IMessageClass } from "@jayesol/jayeson.lib.delivery";
import { ISnapshot, Snapshot, PartitionKey, IBetMatch } from "@jayesol/jayeson.lib.record";
export declare class Incoming {
    private _msgType;
    private _stream;
    private _data;
    constructor(_msgType: IMessageClass, _stream: string, _data: IndexedSnapshot);
    msgType(): IMessageClass;
    stream(): string;
    data(): IndexedSnapshot;
}
export interface IndexedSnapshot extends ISnapshot<IBetMatch> {
    getPartitions(): Collections.Set<PartitionKey>;
    getPartitionMap(): Collections.Dictionary<PartitionKey, number>;
}
export declare class IndexedSnapshotImpl extends Snapshot<IBetMatch> implements IndexedSnapshot {
    private partitions;
    static EMPTY_SNAPSHOT: IndexedSnapshotImpl;
    constructor(matches?: {
        [sport: number]: IBetMatch[];
    }, partitions?: Collections.Dictionary<PartitionKey, number>);
    getPartitions(): Collections.Set<PartitionKey>;
    getPartitionMap(): Collections.Dictionary<PartitionKey, number>;
}
export interface Outgoing {
    msgType(): IMessageClass;
}
export interface DeltaOutgoing extends Outgoing {
    /**
     * Indexed snapshot after Merge
     */
    after(): IndexedSnapshot;
    /**
     * Contents of this Delta
     */
    delta(): IndexedSnapshot;
    /**
     * Indexed Snapshot before Merge
     */
    before(): IndexedSnapshot;
}
export declare class OutgoingImpl implements Outgoing {
    private _msgType;
    private _msg;
    constructor(_msgType: IMessageClass, _msg: any);
    msgType(): IMessageClass;
    msg(): any;
}
export declare class DeltaOutgoingImpl extends OutgoingImpl implements DeltaOutgoing {
    private _delta;
    private _after?;
    private _before?;
    constructor(_msgType: IMessageClass, _delta: IndexedSnapshot, _after?: IndexedSnapshot, _before?: IndexedSnapshot);
    after(): IndexedSnapshot;
    delta(): IndexedSnapshot;
    before(): IndexedSnapshot;
}
export declare class MessageBeforeTransform {
    private transformEvent;
    private insertEvent;
    private deleteEvent;
    private suppressMatch;
    private insertMatch;
    private deleteMatch;
    private afterSs;
    private beforeSs;
    constructor();
    getTransformEvent(): string[];
    setTransformEvent(eventId: string): void;
    getSuppressMatch(): string[];
    setSuppressMatch(matchId: string): void;
    setAfterSs(afterSs: IndexedSnapshot): void;
    getAfterSs(): IndexedSnapshot;
    setBeforeSs(beforeSs: IndexedSnapshot): void;
    getBeforeSs(): IndexedSnapshot;
    setInsertEvent(eventId: string): void;
    getInsertEvent(): string[];
    setDeleteEvent(eventId: string): void;
    getDeleteEvent(): string[];
    setInsertMatch(matchId: string): void;
    getInsertMatch(): string[];
    setDeleteMatch(matchId: string): void;
    getDeleteMatch(): string[];
}
export declare enum ConvertedMsg {
    INSERT_EVENT_TO_UPDATE = 0,
    DELETE_EVENT_TO_UPDATE = 1,
    INSERT_MATCH_SUPPRESS = 2,
    DELETE_MATCH_SUPPRESS = 3,
    ORIGINAL = 4
}
export declare class MergeableWrapper {
    private deltaOut;
    private snap;
    constructor();
    setDeltaOut(out: DeltaOutgoing[]): void;
    setAfter(after: IndexedSnapshot): void;
    getDeltaOut(): DeltaOutgoing[];
    getAfter(): IndexedSnapshot;
}
export declare class TTLWrapper {
    private removedSs;
    private remainingSs;
    private restoredSs;
    _RemovedKey(): void;
    setRemovedSs(remove: IndexedSnapshot): void;
    getRemovedSs(): IndexedSnapshot;
    setRemainingSs(remain: IndexedSnapshot): void;
    getRemainingSs(): IndexedSnapshot;
    getRestoredSs(): IndexedSnapshot;
    setRestoredSs(restore: IndexedSnapshot): void;
}