[v2.1.8]: added ability to disable worker logger

README.md

@@ -63,13 +63,14 @@ Both in-memory and persistent tasks are available at the same time, and can be u
 
 ## prototype
 
-  `constructor(taskMap: Object, { port: Integer, maxAvailableWorkers: Integer, refreshRate: Integer, inMemoryOnly: Boolean, messageBroker: function })`
+  `constructor(taskMap: Object, { port: Integer, maxAvailableWorkers: Integer, refreshRate: Integer, inMemoryOnly: Boolean, messageBroker: function, logs: String })`
   - `taskMap`: a map of functions associated to a `taskType`
   - `maxAvailableWorkers`: maximum number of child process (cores), default is set to system maximum
   - `port`: server port for child process servers, default set to `3008`
   - `refreshRate`: Worker pool refresh rate (in ms), default set to `1000`
   - `inMemoryOnly`: force the cluster to only pull jobs from the in-memory task queue.
   - `messageBroker` is optional, default set to null (see IPC section)<br>
+  - `logs`: is one of `['all', 'error']`, default sets to `all` : if set to `'error'`, will only show the errors and warning logs.
 
   `Cluster.isMaster()`: `true` if this process is the master<br/>
 

package.js

@@ -1,6 +1,6 @@
 Package.describe({
   name: 'nschwarz:cluster',
-  version: '2.1.7',
+  version: '2.1.8',
   summary: 'native nodejs clusterization for meteor server',
   git: 'https://github.com/nathanschwarz/meteor-cluster.git',
   documentation: 'README.md'

src/Cluster/ChildProcess.js

@@ -1,14 +1,21 @@
+const debug = Npm.require('debug')
 import StaticCluster from './StaticCluster'
 const process = require('process')
 import TaskQueue from '../TaskQueue'
 import ChildWorker from '../Worker/ChildWorker'
 
 class ChildProcess extends StaticCluster {
-  constructor(taskMap) {
+  constructor(taskMap, { logs = 'all' } = {}) {
     super()
     Meteor.startup(() => {
       TaskQueue.registerTaskMap(taskMap)
     })
+    // enable / disable logs
+    if (logs === 'all') {
+      debug.enable('nschwarz:cluster:*')
+    } else {
+      debug.enable('nschwarz:cluster:ERROR*,nschwarz:cluster:WARNING*')
+    }
     // register listeners if this process is a worker
     process.on('message', ChildWorker.onMessageFromMaster)
     process.on('disconnect', ChildWorker.onDisconnect)

src/logs.js

@@ -7,6 +7,6 @@ const errorLogger = debug('nschwarz:cluster:ERROR\t')
 logger.log = console.log.bind(console)
 warnLogger.log = console.warn.bind(console)
 
-debug.enable('nschwarz:cluster*')
+debug.enable('nschwarz:cluster:ERROR*,nschwarz:cluster:WARNING*')
 
 export { logger, warnLogger, errorLogger }