Statistiques de la queue
queue_statsMonitor task queue performance and status to manage SFTP operations and server workflows effectively.
Instructions
Affiche les statistiques détaillées de la queue de tâches.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||
Implementation Reference
- server.js:637-646 (handler)Handler function for the queue_stats tool. Fetches queue statistics and list of crashed jobs using the queue module, aggregates the data, and returns it as formatted JSON text content.
async () => { const stats = queue.getStats(); const crashed = queue.getCrashedJobs(); const result = { stats, crashedJobs: crashed.length, canRetry: crashed.map(j => ({ id: j.id, type: j.type, crashedAt: j.crashedAt })) }; return { content: [{ type: "text", text: JSON.stringify(result, null, 2) }] }; } - server.js:632-636 (schema)Input schema for queue_stats tool: empty object (no parameters required). Includes title and description in French.
{ title: "Statistiques de la queue", description: "Affiche les statistiques détaillées de la queue de tâches.", inputSchema: z.object({}) }, - server.js:630-647 (registration)Registration of the queue_stats tool using server.registerTool, including schema and inline handler.
server.registerTool( "queue_stats", { title: "Statistiques de la queue", description: "Affiche les statistiques détaillées de la queue de tâches.", inputSchema: z.object({}) }, async () => { const stats = queue.getStats(); const crashed = queue.getCrashedJobs(); const result = { stats, crashedJobs: crashed.length, canRetry: crashed.map(j => ({ id: j.id, type: j.type, crashedAt: j.crashedAt })) }; return { content: [{ type: "text", text: JSON.stringify(result, null, 2) }] }; } ); - queue.js:293-325 (helper)Helper function getStats() that computes detailed statistics for the job queue: total count, breakdown by status and type, average duration of completed jobs, and success rate.
function getStats() { const stats = { total: Object.keys(jobQueue).length, byStatus: {}, byType: {}, avgDuration: 0, successRate: 0 }; let totalDuration = 0; let completedCount = 0; for (const job of Object.values(jobQueue)) { stats.byStatus[job.status] = (stats.byStatus[job.status] || 0) + 1; stats.byType[job.type] = (stats.byType[job.type] || 0) + 1; if (job.duration) { totalDuration += job.duration; completedCount++; } } if (completedCount > 0) { stats.avgDuration = Math.round(totalDuration / completedCount); } const totalFinished = (stats.byStatus.completed || 0) + (stats.byStatus.failed || 0); if (totalFinished > 0) { stats.successRate = Math.round((stats.byStatus.completed || 0) / totalFinished * 100); } return stats; } - queue.js:285-291 (helper)Helper function getCrashedJobs() that filters and returns crashed jobs eligible for retry (status 'crashed', canRetry true, below max retries).
function getCrashedJobs() { return Object.values(jobQueue).filter(job => job.status === 'crashed' && job.canRetry && job.retryCount < job.maxRetries ); }