Function logPerf

packages/node-runtime/src/import/perf-logger.ts:35–68

(event: string, messagesProcessed: number, batchSize?: number)

}

export function logPerf(event: string, messagesProcessed: number, batchSize?: number): void {
  const now = Date.now()
  const duration = now - lastLogTime
  const messagesDelta = messagesProcessed - lastMessageCount
  const speed = duration > 0 ? Math.round((messagesDelta / duration) * 1000) : 0

  let memory = 0
  try {
    const used = process.memoryUsage()
    memory = Math.round(used.heapUsed / 1024 / 1024)
  } catch {
    // Ignore
  }

  const logLine =
    `[${new Date().toISOString()}] ${event} | ` +
    `messages: ${messagesProcessed.toLocaleString()} | ` +
    `elapsed: ${duration}ms | ` +
    `speed: ${speed.toLocaleString()}/s | ` +
    `memory: ${memory}MB` +
    (batchSize ? ` | batch: ${batchSize}` : '') +
    '\n'

  if (currentLogFile) {
    try {
      fs.appendFileSync(currentLogFile, logLine, 'utf-8')
    } catch {
      // Ignore write failure
    }
  }

  lastLogTime = now
  lastMessageCount = messagesProcessed
}

export function logPerfDetail(detail: string): void {
  if (currentLogFile) {