import { EngineService } from '../engine';
import { ILogger } from '../logger';
import { QuorumService } from '../quorum';
import { WorkerService } from '../worker';
import { HotMeshConfig } from '../../types/hotmesh';
import { ProviderConfig, ProvidersConfig } from '../../types/provider';
import { RetryPolicy } from '../../types/stream';
interface InitContext {
    namespace: string;
    appId: string;
    guid: string;
    engine: EngineService | null;
    quorum: QuorumService | null;
    workers: WorkerService[];
}
/**
 * @private
 */
export declare function initEngine(instance: InitContext, config: HotMeshConfig, logger: ILogger): Promise<void>;
/**
 * @private
 */
export declare function initQuorum(instance: InitContext, config: HotMeshConfig, engine: EngineService, logger: ILogger): Promise<void>;
/**
 * @private
 */
export declare function doWork(instance: InitContext, config: HotMeshConfig, logger: ILogger): Promise<void>;
/**
 * Initialize task queue with proper precedence:
 * 1. Use component-specific queue if set (engine/worker)
 * 2. Use global config queue if set
 * 3. Use default queue as fallback
 * @private
 */
export declare function initTaskQueue(componentQueue?: string, globalQueue?: string): string;
/**
 * Apply retry policy to the stream connection within a ProviderConfig or ProvidersConfig.
 * Handles both short-form (ProviderConfig) and long-form (ProvidersConfig) connection configs.
 * @private
 */
export declare function applyRetryPolicy(connection: ProviderConfig | ProvidersConfig, retry: RetryPolicy): void;
export {};