import { HotMeshEngine, HotMeshWorker } from '../../types/hotmesh'; import { ProviderConfig, ProviderNativeClient } from '../../types/provider'; export declare class ConnectorService { static disconnectAll(): Promise; /** * Connect to a provider (nats, postgres) and return the native * client. Connections are handled by the engine and worker routers at * initialization, but the factory method provided here is useful * for testing provider configurations. */ static connectClient(ProviderConfig: ProviderConfig, taskQueue?: string): Promise; /** * Initialize `store`, `stream`, and `subscription` clients for any provider. * * When the target has `workerCredentials`, the `user` and `password` * in all connection options are overridden with the scoped Postgres * role credentials, and `securedWorker` is set so downstream stream * services use SECURITY DEFINER stored procedures. * * @private */ static initClients(target: HotMeshEngine | HotMeshWorker): Promise; /** * Binds a provider client native instance to the target object. * @private */ static initClient(ProviderConfig: ProviderConfig, target: HotMeshEngine | HotMeshWorker, field: string, taskQueue?: string): Promise; }