/** * CosmosDB client implementation. * * Uses the native CosmosDB plugin type from @superblocksteam/types. * Supports SQL queries and point operations (create, read, replace, * upsert, delete) against CosmosDB containers. */ import type { z } from "zod"; import type { QueryExecutor, TraceMetadata } from "../registry.js"; import type { IntegrationConfig, IntegrationClientImpl } from "../types.js"; import type { CosmosDBClient, CosmosDBQueryOptions } from "./types.js"; /** * Internal implementation of CosmosDBClient. * * Communicates with the orchestrator using the native CosmosDB plugin * proto format, supporting SQL queries and point operations. */ export declare class CosmosDBClientImpl implements CosmosDBClient, IntegrationClientImpl { readonly config: IntegrationConfig; private readonly executeQuery; constructor(config: IntegrationConfig, executeQuery: QueryExecutor); get name(): string; get pluginId(): string; /** * Execute a request and wrap errors. */ private exec; /** * Validate a result against a schema. */ private validate; query(containerId: string, sql: string, schema: z.ZodSchema, options?: CosmosDBQueryOptions, metadata?: TraceMetadata): Promise; read(containerId: string, id: string, schema: z.ZodSchema, partitionKey?: string, metadata?: TraceMetadata): Promise; create(containerId: string, body: unknown, partitionKey?: string, metadata?: TraceMetadata): Promise; replace(containerId: string, body: unknown, partitionKey?: string, metadata?: TraceMetadata): Promise; upsert(containerId: string, body: unknown, partitionKey?: string, metadata?: TraceMetadata): Promise; deleteItem(containerId: string, id: string, partitionKey?: string, metadata?: TraceMetadata): Promise; } //# sourceMappingURL=client.d.ts.map