import type { MastraDBMessage } from '@mastra/core/agent';
import { ObservationStrategy } from './base.js';
import type { StrategyDeps } from './base.js';
import type { ObservationRunOpts, ObserverOutput, ProcessedObservation } from './types.js';
export declare class AsyncBufferObservationStrategy extends ObservationStrategy {
    private readonly startedAt;
    private readonly cycleId;
    private priorExtractedValues?;
    constructor(deps: StrategyDeps, opts: ObservationRunOpts);
    get needsLock(): boolean;
    get needsReflection(): boolean;
    get rethrowOnFailure(): boolean;
    protected generateCycleId(): string;
    prepare(): Promise<{
        messages: MastraDBMessage[];
        existingObservations: string;
    }>;
    emitStartMarkers(_cycleId: string): Promise<void>;
    observe(existingObservations: string, messages: MastraDBMessage[]): Promise<{
        extractedValues: Record<string, unknown> | undefined;
        extractionFailures: import("../extracted-values").ExtractionFailure[] | undefined;
        observations: string;
        currentTask?: string;
        suggestedContinuation?: string;
        threadTitle?: string;
        extractors?: readonly import("..").Extractor<any>[];
        usage?: {
            inputTokens?: number;
            outputTokens?: number;
            totalTokens?: number;
        };
        providerMetadata?: import("@mastra/core/stream").ProviderMetadata;
    }>;
    process(output: ObserverOutput, _existingObservations: string): Promise<ProcessedObservation>;
    persist(processed: ProcessedObservation): Promise<void>;
    emitEndMarkers(_cycleId: string, processed: ProcessedObservation): Promise<void>;
    emitFailedMarkers(_cycleId: string, error: unknown): Promise<void>;
}
//# sourceMappingURL=async-buffer.d.ts.map