import { ObservabilityStorage } from '@mastra/core/storage'; import type { CreateSpanArgs, GetSpanArgs, GetSpanResponse, GetSpansArgs, GetSpansResponse, GetRootSpanArgs, GetRootSpanResponse, GetTraceArgs, GetTraceResponse, GetTraceLightResponse, ListBranchesArgs, ListBranchesResponse, ListTracesArgs, ListTracesLightResponse, ListTracesResponse, BatchCreateSpansArgs, BatchDeleteTracesArgs, BatchCreateLogsArgs, ListLogsArgs, ListLogsResponse, BatchCreateMetricsArgs, ListMetricsArgs, ListMetricsResponse, CreateScoreArgs, BatchCreateScoresArgs, ListScoresArgs, ListScoresResponse, ScoreRecord, GetScoreAggregateArgs, GetScoreAggregateResponse, GetScoreBreakdownArgs, GetScoreBreakdownResponse, GetScoreTimeSeriesArgs, GetScoreTimeSeriesResponse, GetScorePercentilesArgs, GetScorePercentilesResponse, CreateFeedbackArgs, BatchCreateFeedbackArgs, ListFeedbackArgs, ListFeedbackResponse, GetFeedbackAggregateArgs, GetFeedbackAggregateResponse, GetFeedbackBreakdownArgs, GetFeedbackBreakdownResponse, GetFeedbackTimeSeriesArgs, GetFeedbackTimeSeriesResponse, GetFeedbackPercentilesArgs, GetFeedbackPercentilesResponse, GetMetricAggregateArgs, GetMetricAggregateResponse, GetMetricBreakdownArgs, GetMetricBreakdownResponse, GetMetricTimeSeriesArgs, GetMetricTimeSeriesResponse, GetMetricPercentilesArgs, GetMetricPercentilesResponse, GetMetricNamesArgs, GetMetricNamesResponse, GetMetricLabelKeysArgs, GetMetricLabelKeysResponse, GetMetricLabelValuesArgs, GetMetricLabelValuesResponse, GetEntityTypesArgs, GetEntityTypesResponse, GetEntityNamesArgs, GetEntityNamesResponse, GetServiceNamesArgs, GetServiceNamesResponse, GetEnvironmentsArgs, GetEnvironmentsResponse, GetTagsArgs, GetTagsResponse, ObservabilityStorageStrategy } from '@mastra/core/storage'; import type { DuckDBConnection } from '../../db/index.js'; /** Configuration for the DuckDB observability storage domain. */ export interface ObservabilityDuckDBConfig { /** Shared DuckDB instance to use for all observability queries. */ db: DuckDBConnection; } /** * DuckDB-backed observability storage for traces, metrics, logs, scores, and feedback. * Uses an append-only event-sourced model with SQL-based reconstruction for spans. */ export declare class ObservabilityStorageDuckDB extends ObservabilityStorage { private db; constructor(config: ObservabilityDuckDBConfig); /** Create all observability tables if they don't exist. */ init(): Promise; /** * Manually migrate legacy signal tables to the signal-ID primary-key schema. * The public method name is historical; the CLI still calls `migrateSpans()` * for observability migrations even though this now also migrates signal tables. */ migrateSpans(): Promise<{ success: boolean; alreadyMigrated: boolean; duplicatesRemoved: number; message: string; }>; /** Delete all rows from every observability table. Use with caution. */ dangerouslyClearAll(): Promise; get observabilityStrategy(): { preferred: ObservabilityStorageStrategy; supported: ObservabilityStorageStrategy[]; }; getFeatures(): readonly ["delta-polling"] | undefined; createSpan(args: CreateSpanArgs): Promise; batchCreateSpans(args: BatchCreateSpansArgs): Promise; batchDeleteTraces(args: BatchDeleteTracesArgs): Promise; getSpan(args: GetSpanArgs): Promise; getSpans(args: GetSpansArgs): Promise; getRootSpan(args: GetRootSpanArgs): Promise; getTrace(args: GetTraceArgs): Promise; getTraceLight(args: GetTraceArgs): Promise; listTraces(args: ListTracesArgs): Promise; listTracesLight(args: ListTracesArgs): Promise; listBranches(args: ListBranchesArgs): Promise; batchCreateLogs(args: BatchCreateLogsArgs): Promise; listLogs(args: ListLogsArgs): Promise; batchCreateMetrics(args: BatchCreateMetricsArgs): Promise; listMetrics(args: ListMetricsArgs): Promise; getMetricAggregate(args: GetMetricAggregateArgs): Promise; getMetricBreakdown(args: GetMetricBreakdownArgs): Promise; getMetricTimeSeries(args: GetMetricTimeSeriesArgs): Promise; getMetricPercentiles(args: GetMetricPercentilesArgs): Promise; getMetricNames(args: GetMetricNamesArgs): Promise; getMetricLabelKeys(args: GetMetricLabelKeysArgs): Promise; getMetricLabelValues(args: GetMetricLabelValuesArgs): Promise; getEntityTypes(args: GetEntityTypesArgs): Promise; getEntityNames(args: GetEntityNamesArgs): Promise; getServiceNames(args: GetServiceNamesArgs): Promise; getEnvironments(args: GetEnvironmentsArgs): Promise; getTags(args: GetTagsArgs): Promise; createScore(args: CreateScoreArgs): Promise; batchCreateScores(args: BatchCreateScoresArgs): Promise; listScores(args: ListScoresArgs): Promise; getScoreById(scoreId: string): Promise; getScoreAggregate(args: GetScoreAggregateArgs): Promise; getScoreBreakdown(args: GetScoreBreakdownArgs): Promise; getScoreTimeSeries(args: GetScoreTimeSeriesArgs): Promise; getScorePercentiles(args: GetScorePercentilesArgs): Promise; createFeedback(args: CreateFeedbackArgs): Promise; batchCreateFeedback(args: BatchCreateFeedbackArgs): Promise; listFeedback(args: ListFeedbackArgs): Promise; getFeedbackAggregate(args: GetFeedbackAggregateArgs): Promise; getFeedbackBreakdown(args: GetFeedbackBreakdownArgs): Promise; getFeedbackTimeSeries(args: GetFeedbackTimeSeriesArgs): Promise; getFeedbackPercentiles(args: GetFeedbackPercentilesArgs): Promise; } //# sourceMappingURL=index.d.ts.map