1 | import * as D from '@jayesol/jayeson.lib.delivery';
|
2 | import { RuleCombination } from "@jayesol/jayeson.model";
|
3 | import { FSRepo, Mergeable, RecycleBin } from "./core";
|
4 | import { SportsFeedMessageGroup, StartSubscribeFeed } from "./message_class";
|
5 | import { Incoming, IndexedSnapshot, Outgoing, MergeableWrapper } from "./data_structure";
|
6 | import 'reflect-metadata';
|
7 | import { FilterRequest } from './codec';
|
8 | export declare class InEndPointEventHandler {
|
9 | private _streamSources;
|
10 | private _exclude;
|
11 | private _wireFormat;
|
12 | private _filterData;
|
13 | private _startMessage;
|
14 | private _sportsMsgGrp;
|
15 | private _streamNameCode;
|
16 | constructor(startMessage: StartSubscribeFeed, sportsMsgGrp: SportsFeedMessageGroup, streamNameCode: D.StreamNameCode);
|
17 | setfilterData(rule: RuleCombination): void;
|
18 | streamSources(): any;
|
19 | exclude(): string[];
|
20 | wireFormat(): string;
|
21 | startMessage(): StartSubscribeFeed;
|
22 | sportsMsgGrp(): SportsFeedMessageGroup;
|
23 | streamNameCode(): any;
|
24 | filterData(): RuleCombination;
|
25 | onEvent(event: D.EPEvent): void;
|
26 | sendMessage(streamId: string, mw: D.MessageWrapper): void;
|
27 | updateFilter(filterRequest: FilterRequest): void;
|
28 | /**
|
29 | * Sends filter to server
|
30 | * @param streamId - sends filter for a particular streamId
|
31 | * if null, sends filter for all stream ids
|
32 | */
|
33 | private sendFilter;
|
34 | private _sendFilter;
|
35 | }
|
36 | export declare class StreamCommandProcessor {
|
37 | private _fsRepo;
|
38 | private _sportsGrp;
|
39 | constructor(_fsRepo: FSRepo, _sportsGrp: SportsFeedMessageGroup);
|
40 | process(stream: string, input: Mergeable, overwrite?: Outgoing): void;
|
41 | fsRepo(): FSRepo;
|
42 | sportsGrp(): SportsFeedMessageGroup;
|
43 | messageClassName: {
|
44 | 0: string;
|
45 | 1: string;
|
46 | 2: string;
|
47 | 3: string;
|
48 | 4: string;
|
49 | 5: string;
|
50 | 6: string;
|
51 | 7: string;
|
52 | 8: string;
|
53 | 9: string;
|
54 | 10: string;
|
55 | 11: string;
|
56 | 13: string;
|
57 | 14: string;
|
58 | 16: string;
|
59 | 17: string;
|
60 | };
|
61 | private printMessage;
|
62 | private getClassName;
|
63 | private printMatch;
|
64 | private printRecord;
|
65 | private printPartitionKeys;
|
66 | }
|
67 | export declare class SportsFeedInProcessor extends D.IMessageGroupProcessor {
|
68 | private scp;
|
69 | private sportsFeedMsgGroup;
|
70 | private snCode;
|
71 | private recycleBin;
|
72 | constructor(scp: StreamCommandProcessor, sportsFeedMsgGroup: SportsFeedMessageGroup, snCode: D.StreamNameCode, recycleBin: RecycleBin);
|
73 | process(mw: D.MessageWrapper): void;
|
74 | private processIndicatorMessage;
|
75 | private triggerTtlRestoreIfApplicable;
|
76 | triggerTtlRemove(): void;
|
77 | startTtlVerification(): void;
|
78 | isFeedMessage(mw: D.MessageWrapper): boolean;
|
79 | getScp(): StreamCommandProcessor;
|
80 | getRecycleBin(): RecycleBin;
|
81 | }
|
82 | export declare class MergeableIncoming extends Incoming implements Mergeable {
|
83 | private sportsGrp;
|
84 | private beforeSnap;
|
85 | private bin;
|
86 | constructor(sportsGrp: SportsFeedMessageGroup, snapshotType: D.IMessageClass, streamName: string, data: IndexedSnapshot, bin: RecycleBin);
|
87 | apply(before: IndexedSnapshot): MergeableWrapper;
|
88 | }
|