import type { ObservabilitySink } from '@cicctencent/agent-core';
import type { ObservabilityStoreProvider } from './observability-store.js';
import type { ObservabilityExporter } from '../service/observability-exporter.js';
/**
 * 导出器只需提供两个入队方法（OtlpExporter 与 ObservabilityExporterManager 都满足）。
 * 用结构化的 Pick 而非完整 ObservabilityExporter，避免 Manager 缺少 name/config/start/stop 而无法传入。
 */
type EnqueueOnlyExporter = Pick<ObservabilityExporter, 'enqueueTrace' | 'enqueueObservation'>;
/**
 * 创建一个将数据转发到 ObservabilityStoreProvider 的 Sink 实现。
 * 所有方法吞掉错误，不影响主业务流程。
 *
 * 共享实现，供 agent-server 和 work-client 复用，避免代码重复。
 *
 * @param provider   存储实现（InMemory / TypeORM / 文件 等）
 * @param exporter   可选。非空时，在 endTrace/endObservation 落库完成后，把**完整**记录
 *                   推入导出器（OTLP / Langfuse），实现真实导出。之前版本只在 endTrace 推
 *                   trace、且从不推 observation，导致 OTLP 导出只有 trace span、缺 generation/tool span。
 */
export declare function createStoreSink(provider: ObservabilityStoreProvider, exporter?: EnqueueOnlyExporter): ObservabilitySink;
export {};
//# sourceMappingURL=store-sink-factory.d.ts.map