import deliver = require('@jayesol/jayeson.lib.delivery'); import { PartitionKey, SportType, IBetMatch } from '@jayesol/jayeson.lib.record'; import * as proto from './protobuf_bundle'; import * as Collections from 'typescript-collections'; import { ICodec } from './codec'; export declare abstract class AbstractMessageClass extends deliver.IMessageClass { private _msgGroup; private _id; private _instanceClass; private _sportCodecs; private _partitionCodec; constructor(_msgGroup: deliver.IMessageGroup, _id: number, _instanceClass: any, _sportCodecs: SportsCodecs, _partitionCodec: PartitionCodec); id(): number; SportsFeedMessageGroup(): deliver.IMessageGroup; instanceClass(): any; sportCodecs(): SportsCodecs; partitionCodec(): PartitionCodec; abstract read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[]; private unpack; inHandlers(): deliver.MsgHandler[]; outHandlers(): deliver.MsgHandler[]; private asSportType; } export declare class FilterMessageClass extends deliver.JSonMessageClass { constructor(msgGroup: deliver.IMessageGroup, id: number); } export declare class SportsCodecs { readonly sportsMappings: Collections.Dictionary; constructor(sportsMappings?: Collections.Dictionary); getCodec(sportType: SportType): ICodec; } export declare class PartitionCodec { decode(key: proto.PartitionKey, pool: string[]): PartitionKey; } export declare class InsertMatchMessageClass extends AbstractMessageClass { constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec); read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[]; } export declare class InsertEventMessageClass extends AbstractMessageClass { constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec); read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[]; } export declare class InsertOddMessageClass extends AbstractMessageClass { constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec); read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[]; } export declare class UpdateMatchMessageClass extends AbstractMessageClass { constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec); read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[]; } export declare class UpdateEventMessageClass extends AbstractMessageClass { constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec); read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[]; } export declare class UpdateOddMessageClass extends AbstractMessageClass { constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec); read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[]; } export declare class DeleteMatchMessageClass extends AbstractMessageClass { constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec); read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[]; } export declare class DeleteEventMessageClass extends AbstractMessageClass { constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec); read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[]; } export declare class DeleteOddMessageClass extends AbstractMessageClass { constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec); read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[]; } export declare class ResetMessageClass extends AbstractMessageClass { constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec); read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[]; } export declare class TTLRemoveMessageClass extends AbstractMessageClass { constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec); read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[]; } export declare class TTLRestoreMessageClass extends AbstractMessageClass { constructor(group: deliver.IMessageGroup, id: number, sportCodec: SportsCodecs, partitionCodec: PartitionCodec); read(msg: proto.DataMessage, codec: ICodec, pool: string[], key: PartitionKey): IBetMatch[]; } export declare class SwitchFilterStartMessageClass extends deliver.EmptyMessageClass { constructor(group: deliver.IMessageGroup, id: number); } export declare class SwitchFilterEndMessageClass extends deliver.EmptyMessageClass { constructor(group: deliver.IMessageGroup, id: number); } export declare class SwitchFilterFailMessageClass extends deliver.EmptyMessageClass { constructor(group: deliver.IMessageGroup, id: number); } export declare class StartSubscribeFeed { exclude: string[]; wireFormat: string; constructor(exclude: string[], wireFormat: string); } export declare class RefreshMessageClass extends deliver.JSonMessageClass { constructor(msgGroup: deliver.IMessageGroup, id: number); inHandlers(): deliver.MsgHandler[]; private unpack; } export declare class SportsFeedMessageGroup extends deliver.IMessageGroup { private _DATA_RESET; private _DATA_INSERT_ODD; private _DATA_UPDATE_ODD; private _DATA_DELETE_ODD; private _DATA_INSERT_EVENT; private _DATA_UPDATE_EVENT; private _DATA_DELETE_EVENT; private _DATA_INSERT_MATCH; private _DATA_UPDATE_MATCH; private _DATA_DELETE_MATCH; private _TTL_RESTORE; private _TTL_REMOVE; private _FILTER_REMOVE; private _FILTER_SET; private _ADMIN_START_SUBSCRIBE_FEED; private _ADMIN_REFRESH; private _SWITCH_FILTER_START; private _SWITCH_FILTER_END; private _FULLSNAPSHOT_START; private _FULLSNAPSHOT_END; private _SWITCH_FILTER_FAIL; private _TTL_RESTORE_START; private _TTL_RESTORE_END; DATA_RESET(): ResetMessageClass; DATA_INSERT_ODD(): InsertOddMessageClass; DATA_UPDATE_ODD(): UpdateOddMessageClass; DATA_DELETE_ODD(): DeleteOddMessageClass; DATA_INSERT_EVENT(): InsertEventMessageClass; DATA_UPDATE_EVENT(): UpdateEventMessageClass; DATA_DELETE_EVENT(): DeleteEventMessageClass; TTL_REMOVE(): TTLRemoveMessageClass; TTL_RESTORE(): TTLRestoreMessageClass; TTL_RESTORE_START(): TTLRestoreMessageClass; TTL_RESTORE_END(): deliver.EmptyMessageClass; DATA_INSERT_MATCH(): InsertMatchMessageClass; DATA_UPDATE_MATCH(): UpdateMatchMessageClass; DATA_DELETE_MATCH(): DeleteMatchMessageClass; FILTER_REMOVE(): deliver.StringMessageClass; FILTER_SET(): FilterMessageClass; ADMIN_START_SUBSCRIBE_FEED(): deliver.JSonMessageClass; ADMIN_REFRESH(): RefreshMessageClass; SWITCH_FILTER_START(): deliver.StringMessageClass; SWITCH_FILTER_END(): deliver.EmptyMessageClass; FULLSNAPSHOT_START(): deliver.EmptyMessageClass; FULLSNAPSHOT_END(): deliver.EmptyMessageClass; SWITCH_FILTER_FAIL(): deliver.StringMessageClass; isIndicatorMessage(messageClass: deliver.IMessageClass): boolean; isSwitchFilterStatusMsg(messageClass: deliver.IMessageClass): boolean; constructor(sportCodec?: SportsCodecs, partitionCodec?: PartitionCodec); }