memory_stream_pause
Pause the persistent memory stream in meMCP to temporarily halt continuous learning and knowledge retention across LLM sessions.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||
Implementation Reference
- src/tools/modules/MemoryStreamingTools.js:117-135 (registration)Registers the 'memory_stream_pause' tool with input schema requiring streamId and delegates to handleStreamPause handler.registerStreamPauseTool(server) { server.registerTool( 'memory_stream_pause', 'Pause an active streaming query', { type: 'object', properties: { streamId: { type: 'string', description: 'The stream ID to pause', }, }, required: ['streamId'], }, async (args) => { return await this.handleStreamPause(args); } ); }
- Tool handler that calls StreamingManager.pauseStream(streamId) and formats the success/error response.async handleStreamPause(args) { try { const result = await this.streamingManager.pauseStream(args.streamId); return { content: [ { type: 'text', text: JSON.stringify({ success: true, streamId: args.streamId, status: result.status, message: 'Stream paused successfully', }), }, ], }; } catch (error) { return { content: [ { type: 'text', text: JSON.stringify({ success: false, error: error.message, }), }, ], isError: true, }; }
- Core pause logic: validates stream exists and is active, sets status to 'paused', records pause time, returns status.async pauseStream(streamId) { const stream = this.activeStreams.get(streamId); if (!stream) { throw new Error(`Stream ${streamId} not found`); } if (stream.status !== 'active') { throw new Error(`Stream ${streamId} is not active`); } stream.status = 'paused'; stream.pausedAt = Date.now(); return { streamId, status: 'paused', progress: { current: stream.currentIndex, total: stream.totalFacts, }, }; }