/** * Engine bootstrap — channel setup, router creation, config validation. * * Called once during `EngineService.init()` to wire the engine to its * backing store, stream, search, and subscription transports. */ import { ExporterService } from '../exporter'; import { Router } from '../router'; import { TaskService } from '../task'; import { ILogger } from '../logger'; import { SearchService } from '../search'; import { StoreService } from '../store'; import { StreamService } from '../stream'; import { SubService } from '../sub'; import { HotMeshConfig, HotMeshSettings } from '../../types/hotmesh'; import { ProviderClient, ProviderTransaction } from '../../types/provider'; import { StreamDataResponse } from '../../types/stream'; interface InitContext { namespace: string; appId: string; guid: string; logger: ILogger; search: SearchService | null; store: StoreService | null; stream: StreamService | null; subscribe: SubService | null; router: Router | null; taskService: TaskService | null; exporter: ExporterService | null; inited: string; processStreamMessage(streamData: StreamDataResponse): Promise; } export declare function verifyEngineFields(config: HotMeshConfig): void; export declare function initSearchChannel(instance: InitContext, search: ProviderClient, store?: ProviderClient): Promise; export declare function initStoreChannel(instance: InitContext, store: ProviderClient): Promise; export declare function initSubChannel(instance: InitContext, sub: ProviderClient, store: ProviderClient): Promise; export declare function initStreamChannel(instance: InitContext, stream: ProviderClient, store: ProviderClient): Promise; export declare function initRouter(instance: InitContext, config: HotMeshConfig): Promise>>; export declare function registerStreamConsumer(instance: InitContext, config: HotMeshConfig): Promise; export declare function initServices(instance: InitContext): void; export declare function getSettings(instance: InitContext): Promise; export {};