import { FlinkDirectConfig, MCPServerConfiguration } from "../../../../config/models.js"; import { BaseToolHandler } from "../../../../confluent/tools/base-tools.js"; import { hasFlink } from "../../../../confluent/tools/connection-predicates.js"; /** Intermediate base class for Flink tool handlers */ export declare abstract class FlinkToolHandler extends BaseToolHandler { readonly predicate: typeof hasFlink; /** * Extracts the Flink config block from the sole connection, asserting it exists. * Throws "Wacky -- " if called on a connection without a flink block (should be * impossible in production given the hasFlink gate, but caught here rather than * silently propagating undefined). */ protected getFlinkDirectConfig(config: MCPServerConfiguration): FlinkDirectConfig; protected resolveOrgAndEnvIds(flink: FlinkDirectConfig, orgIdArg: string | undefined, envIdArg: string | undefined): { organization_id: string; environment_id: string; }; protected resolveComputePoolId(flink: FlinkDirectConfig, computePoolIdArg: string | undefined): string; protected resolveOptionalComputePoolId(flink: FlinkDirectConfig, computePoolIdArg: string | undefined): string | undefined; } //# sourceMappingURL=flink-tool-handler.d.ts.map