import type { Storage } from "../../storage/storage.js"; import { type Context } from "../agents/context.js"; import type { AgentDescriptor } from "../agents/ops/agentDescriptorTypes.js"; import type { ConfigModule } from "../config/configModule.js"; export type MemoryWorkerPostFn = (ctx: Context, target: { descriptor: AgentDescriptor; }, item: { type: "system_message"; text: string; origin: string; }) => Promise; export type MemoryWorkerOptions = { storage: Storage; config: ConfigModule; intervalMs?: number; }; /** * Timer-based worker that polls for invalidated sessions and routes them * to per-agent memory-agents for observation extraction. */ export declare class MemoryWorker { private readonly storage; private readonly config; private readonly intervalMs; private postToAgent; private tickTimer; private started; private stopped; constructor(options: MemoryWorkerOptions); /** * Sets the posting function used to route transcripts to memory-agents. * Must be called before start(). */ setPostFn(fn: MemoryWorkerPostFn): void; start(): void; stop(): void; private scheduleNextTick; private tick; } //# sourceMappingURL=memoryWorker.d.ts.map