| 1 | import deliver = require('@jayesol/jayeson.lib.delivery');
|
| 2 | import { PartitionKey, SportType, IBetMatch } from '@jayesol/jayeson.lib.record';
|
| 3 | import * as proto from './protobuf_bundle';
|
| 4 | import * as Collections from 'typescript-collections';
|
| 5 | import { ICodec } from './codec';
|
| 6 | export declare abstract class AbstractMessageClass extends deliver.IMessageClass {
|
| 7 | private _msgGroup;
|
| 8 | private _id;
|
| 9 | private _instanceClass;
|
| 10 | private _sportCodecs;
|
| 11 | private _partitionCodec;
|
| 12 | constructor(_msgGroup: deliver.IMessageGroup, _id: number, _instanceClass: any, _sportCodecs: SportsCodecs, _partitionCodec: PartitionCodec);
|
| 13 | id(): number;
|
| 14 | SportsFeedMessageGroup(): deliver.IMessageGroup;
|
| 15 | instanceClass(): any;
|
| 16 | sportCodecs(): SportsCodecs;
|
| 17 | partitionCodec(): PartitionCodec;
|
| 18 | abstract read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[];
|
| 19 | private unpack;
|
| 20 | inHandlers(): deliver.MsgHandler[];
|
| 21 | outHandlers(): deliver.MsgHandler[];
|
| 22 | private asSportType;
|
| 23 | }
|
| 24 | export declare class FilterMessageClass extends deliver.JSonMessageClass {
|
| 25 | constructor(msgGroup: deliver.IMessageGroup, id: number);
|
| 26 | }
|
| 27 | export declare class SportsCodecs {
|
| 28 | readonly sportsMappings: Collections.Dictionary<SportType, ICodec>;
|
| 29 | constructor(sportsMappings?: Collections.Dictionary<SportType, ICodec>);
|
| 30 | getCodec(sportType: SportType): ICodec;
|
| 31 | }
|
| 32 | export declare class PartitionCodec {
|
| 33 | decode(key: proto.PartitionKey, pool: string[]): PartitionKey;
|
| 34 | }
|
| 35 | export declare class InsertMatchMessageClass extends AbstractMessageClass {
|
| 36 | constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec);
|
| 37 | read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[];
|
| 38 | }
|
| 39 | export declare class InsertEventMessageClass extends AbstractMessageClass {
|
| 40 | constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec);
|
| 41 | read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[];
|
| 42 | }
|
| 43 | export declare class InsertOddMessageClass extends AbstractMessageClass {
|
| 44 | constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec);
|
| 45 | read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[];
|
| 46 | }
|
| 47 | export declare class UpdateMatchMessageClass extends AbstractMessageClass {
|
| 48 | constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec);
|
| 49 | read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[];
|
| 50 | }
|
| 51 | export declare class UpdateEventMessageClass extends AbstractMessageClass {
|
| 52 | constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec);
|
| 53 | read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[];
|
| 54 | }
|
| 55 | export declare class UpdateOddMessageClass extends AbstractMessageClass {
|
| 56 | constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec);
|
| 57 | read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[];
|
| 58 | }
|
| 59 | export declare class DeleteMatchMessageClass extends AbstractMessageClass {
|
| 60 | constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec);
|
| 61 | read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[];
|
| 62 | }
|
| 63 | export declare class DeleteEventMessageClass extends AbstractMessageClass {
|
| 64 | constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec);
|
| 65 | read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[];
|
| 66 | }
|
| 67 | export declare class DeleteOddMessageClass extends AbstractMessageClass {
|
| 68 | constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec);
|
| 69 | read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[];
|
| 70 | }
|
| 71 | export declare class ResetMessageClass extends AbstractMessageClass {
|
| 72 | constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec);
|
| 73 | read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[];
|
| 74 | }
|
| 75 | export declare class TTLRemoveMessageClass extends AbstractMessageClass {
|
| 76 | constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec);
|
| 77 | read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[];
|
| 78 | }
|
| 79 | export declare class TTLRestoreMessageClass extends AbstractMessageClass {
|
| 80 | constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec);
|
| 81 | read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[];
|
| 82 | }
|
| 83 | export declare class SwitchFilterStartMessageClass extends deliver.EmptyMessageClass {
|
| 84 | constructor(group: deliver.IMessageGroup, id: number);
|
| 85 | }
|
| 86 | export declare class SwitchFilterEndMessageClass extends deliver.EmptyMessageClass {
|
| 87 | constructor(group: deliver.IMessageGroup, id: number);
|
| 88 | }
|
| 89 | export declare class SwitchFilterFailMessageClass extends deliver.EmptyMessageClass {
|
| 90 | constructor(group: deliver.IMessageGroup, id: number);
|
| 91 | }
|
| 92 | export declare class StartSubscribeFeed {
|
| 93 | exclude: string[];
|
| 94 | wireFormat: string;
|
| 95 | constructor(exclude: string[], wireFormat: string);
|
| 96 | }
|
| 97 | export declare class RefreshMessageClass extends deliver.JSonMessageClass {
|
| 98 | constructor(msgGroup: deliver.IMessageGroup, id: number);
|
| 99 | inHandlers(): deliver.MsgHandler[];
|
| 100 | private unpack;
|
| 101 | }
|
| 102 | export declare class SportsFeedMessageGroup extends deliver.IMessageGroup {
|
| 103 | private _DATA_RESET;
|
| 104 | private _DATA_INSERT_ODD;
|
| 105 | private _DATA_UPDATE_ODD;
|
| 106 | private _DATA_DELETE_ODD;
|
| 107 | private _DATA_INSERT_EVENT;
|
| 108 | private _DATA_UPDATE_EVENT;
|
| 109 | private _DATA_DELETE_EVENT;
|
| 110 | private _DATA_INSERT_MATCH;
|
| 111 | private _DATA_UPDATE_MATCH;
|
| 112 | private _DATA_DELETE_MATCH;
|
| 113 | private _TTL_RESTORE;
|
| 114 | private _TTL_REMOVE;
|
| 115 | private _FILTER_REMOVE;
|
| 116 | private _FILTER_SET;
|
| 117 | private _ADMIN_START_SUBSCRIBE_FEED;
|
| 118 | private _ADMIN_REFRESH;
|
| 119 | private _SWITCH_FILTER_START;
|
| 120 | private _SWITCH_FILTER_END;
|
| 121 | private _FULLSNAPSHOT_START;
|
| 122 | private _FULLSNAPSHOT_END;
|
| 123 | private _SWITCH_FILTER_FAIL;
|
| 124 | private _TTL_RESTORE_START;
|
| 125 | private _TTL_RESTORE_END;
|
| 126 | DATA_RESET(): ResetMessageClass;
|
| 127 | DATA_INSERT_ODD(): InsertOddMessageClass;
|
| 128 | DATA_UPDATE_ODD(): UpdateOddMessageClass;
|
| 129 | DATA_DELETE_ODD(): DeleteOddMessageClass;
|
| 130 | DATA_INSERT_EVENT(): InsertEventMessageClass;
|
| 131 | DATA_UPDATE_EVENT(): UpdateEventMessageClass;
|
| 132 | DATA_DELETE_EVENT(): DeleteEventMessageClass;
|
| 133 | TTL_REMOVE(): TTLRemoveMessageClass;
|
| 134 | TTL_RESTORE(): TTLRestoreMessageClass;
|
| 135 | TTL_RESTORE_START(): TTLRestoreMessageClass;
|
| 136 | TTL_RESTORE_END(): deliver.EmptyMessageClass;
|
| 137 | DATA_INSERT_MATCH(): InsertMatchMessageClass;
|
| 138 | DATA_UPDATE_MATCH(): UpdateMatchMessageClass;
|
| 139 | DATA_DELETE_MATCH(): DeleteMatchMessageClass;
|
| 140 | FILTER_REMOVE(): deliver.StringMessageClass;
|
| 141 | FILTER_SET(): FilterMessageClass;
|
| 142 | ADMIN_START_SUBSCRIBE_FEED(): deliver.JSonMessageClass;
|
| 143 | ADMIN_REFRESH(): RefreshMessageClass;
|
| 144 | SWITCH_FILTER_START(): deliver.StringMessageClass;
|
| 145 | SWITCH_FILTER_END(): deliver.EmptyMessageClass;
|
| 146 | FULLSNAPSHOT_START(): deliver.EmptyMessageClass;
|
| 147 | FULLSNAPSHOT_END(): deliver.EmptyMessageClass;
|
| 148 | SWITCH_FILTER_FAIL(): deliver.StringMessageClass;
|
| 149 | isIndicatorMessage(messageClass: deliver.IMessageClass): boolean;
|
| 150 | isSwitchFilterStatusMsg(messageClass: deliver.IMessageClass): boolean;
|
| 151 | constructor(sportCodec?: SportsCodecs, partitionCodec?: PartitionCodec);
|
| 152 | }
|