export type CoordinatorOwnerScope = { ownedQueue: Promise; }; export type CoordinatorRegistration = { connectionScope: CoordinatorOwnerScope; coordinator: (callback: () => Promise) => Promise; owner: symbol; ownerScopes: Map; }; /** * Registers test-only serialization owned by the active broker. * @param {object} connection - Parent physical connection. * @param {(callback: () => Promise) => Promise} coordinator - Serializer. * @returns {symbol} - Opaque owner for broker-internal connection calls. */ export declare function setSharedTransactionCoordinator(connection: object, coordinator: (callback: () => Promise) => Promise): symbol; /** * Removes a broker-owned coordinator without disturbing a replacement. * @param {object} connection - Parent physical connection. * @param {(callback: () => Promise) => Promise} coordinator - Expected serializer. * @returns {void} */ export declare function clearSharedTransactionCoordinator(connection: object, coordinator: (callback: () => Promise) => Promise): void; /** * Runs parent work through broker serialization when registered. * @template T * @param {import("../database/drivers/base.js").default} connection - Parent physical connection. * @param {() => Promise} callback - Parent operation. * @param {symbol} [operationOwner] - Broker owner for an already-coordinated operation. * @returns {Promise} - Operation result. */ export declare function coordinateSharedTransactionConnection(connection: import("../database/drivers/base.js").default, callback: () => Promise, operationOwner?: symbol): Promise; /** * Runs physical query work without inheriting this connection's coordinator owner. * Unregistered connections have no coordinator ownership to clear. * @template T * @param {import("../database/drivers/base.js").default} connection - Physical connection. * @param {() => Promise} callback - Physical query work. * @returns {Promise} - Callback result. */ export declare function runWithoutSharedTransactionCoordinatorOwner(connection: import("../database/drivers/base.js").default, callback: () => Promise): Promise; //# sourceMappingURL=shared-transaction-connection-coordinator.d.ts.map