UNPKG

3.14 kBTypeScriptView Raw
1import * as D from '@jayesol/jayeson.lib.delivery';
2import { RuleCombination } from "@jayesol/jayeson.model";
3import { FSRepo, Mergeable, RecycleBin } from "./core";
4import { SportsFeedMessageGroup, StartSubscribeFeed } from "./message_class";
5import { Incoming, IndexedSnapshot, Outgoing, MergeableWrapper } from "./data_structure";
6import 'reflect-metadata';
7import { FilterRequest } from './codec';
8export 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}
36export 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}
67export 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}
82export 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}