import * as D from '@jayesol/jayeson.lib.delivery';
import { RuleCombination } from "@jayesol/jayeson.model";
import { FSRepo, Mergeable, RecycleBin } from "./core";
import { SportsFeedMessageGroup, StartSubscribeFeed } from "./message_class";
import { Incoming, IndexedSnapshot, Outgoing, MergeableWrapper } from "./data_structure";
import 'reflect-metadata';
import { FilterRequest } from './codec';
export declare class InEndPointEventHandler {
    private _streamSources;
    private _exclude;
    private _wireFormat;
    private _filterData;
    private _startMessage;
    private _sportsMsgGrp;
    private _streamNameCode;
    constructor(startMessage: StartSubscribeFeed, sportsMsgGrp: SportsFeedMessageGroup, streamNameCode: D.StreamNameCode);
    setfilterData(rule: RuleCombination): void;
    streamSources(): any;
    exclude(): string[];
    wireFormat(): string;
    startMessage(): StartSubscribeFeed;
    sportsMsgGrp(): SportsFeedMessageGroup;
    streamNameCode(): any;
    filterData(): RuleCombination;
    onEvent(event: D.EPEvent): void;
    sendMessage(streamId: string, mw: D.MessageWrapper): void;
    updateFilter(filterRequest: FilterRequest): void;
    /**
     * Sends filter to server
     * @param streamId - sends filter for a particular streamId
     *                   if null, sends filter for all stream ids
     */
    private sendFilter;
    private _sendFilter;
}
export declare class StreamCommandProcessor {
    private _fsRepo;
    private _sportsGrp;
    constructor(_fsRepo: FSRepo, _sportsGrp: SportsFeedMessageGroup);
    process(stream: string, input: Mergeable, overwrite?: Outgoing): void;
    fsRepo(): FSRepo;
    sportsGrp(): SportsFeedMessageGroup;
    messageClassName: {
        0: string;
        1: string;
        2: string;
        3: string;
        4: string;
        5: string;
        6: string;
        7: string;
        8: string;
        9: string;
        10: string;
        11: string;
        13: string;
        14: string;
        16: string;
        17: string;
    };
    private printMessage;
    private getClassName;
    private printMatch;
    private printRecord;
    private printPartitionKeys;
}
export declare class SportsFeedInProcessor extends D.IMessageGroupProcessor {
    private scp;
    private sportsFeedMsgGroup;
    private snCode;
    private recycleBin;
    constructor(scp: StreamCommandProcessor, sportsFeedMsgGroup: SportsFeedMessageGroup, snCode: D.StreamNameCode, recycleBin: RecycleBin);
    process(mw: D.MessageWrapper): void;
    private processIndicatorMessage;
    private triggerTtlRestoreIfApplicable;
    triggerTtlRemove(): void;
    startTtlVerification(): void;
    isFeedMessage(mw: D.MessageWrapper): boolean;
    getScp(): StreamCommandProcessor;
    getRecycleBin(): RecycleBin;
}
export declare class MergeableIncoming extends Incoming implements Mergeable {
    private sportsGrp;
    private beforeSnap;
    private bin;
    constructor(sportsGrp: SportsFeedMessageGroup, snapshotType: D.IMessageClass, streamName: string, data: IndexedSnapshot, bin: RecycleBin);
    apply(before: IndexedSnapshot): MergeableWrapper;
}