import type { MetaMemoryEvent, SerializedMetamemoryState, TopicTagMetadata, MessageMetadata } from '@just-every/task'; export interface MetaMemoryEventData { events: MetaMemoryEvent[]; taggingEvents: MemoryTaggingEvent[]; currentState?: SerializedMetamemoryState; stats: MetaMemoryStats; } export interface MemoryTaggingEvent { eventId: string; startedAt: number; completedAt?: number; messageCount: number; processingTime?: number; newTopicCount?: number; updatedTopicCount?: number; newMessageCount?: number; updatedMessageCount?: number; state?: SerializedMetamemoryState; isRunning: boolean; affectedTopics?: string[]; affectedMessages?: string[]; } export interface MetaMemoryStats { totalTaggingSessions: number; completedTaggingSessions: number; totalTopics: number; totalTaggedMessages: number; totalNewTopics: number; totalNewMessages: number; averageProcessingTime: number; lastProcessingTime?: number; } export declare class MetaMemoryEventProcessor { private events; private taggingEvents; private currentState?; private processingTimes; private stats; /** * Process a MetaMemory event and update internal state */ processEvent(event: MetaMemoryEvent): MetaMemoryEventData; private handleTaggingStart; private handleTaggingComplete; /** * Get all processed data */ getProcessedData(): MetaMemoryEventData; /** * Get events filtered by operation */ getEventsByOperation(operation: MetaMemoryEvent['operation']): MetaMemoryEvent[]; /** * Get all completed tagging sessions */ getCompletedTaggingSessions(): MemoryTaggingEvent[]; /** * Get running tagging sessions */ getRunningTaggingSessions(): MemoryTaggingEvent[]; /** * Get the latest tagging session */ getLatestTaggingSession(): MemoryTaggingEvent | undefined; /** * Get current state */ getCurrentState(): SerializedMetamemoryState | undefined; /** * Get all topic tags */ getTopicTags(): Map | undefined; /** * Get all tagged messages */ getTaggedMessages(): Map | undefined; /** * Get messages by topic */ getMessagesByTopic(topic: string): MessageMetadata[]; /** * Get statistics */ getStats(): MetaMemoryStats; /** * Reset the processor */ reset(): void; } /** * Create a new MetaMemory event processor instance */ export declare function createMetaMemoryEventProcessor(): MetaMemoryEventProcessor; //# sourceMappingURL=metaMemoryEventProcessor.d.ts.map