KCLManager.prototype._onAction = function()

in lib/kcl/kcl_manager.js [51:69]

• 19 lines of code
• 7 McCabe index (conditional complexity)

KCLManager.prototype._onAction = function(action) {
  var actionType = action.action;
  switch (actionType) {
    case 'initialize':
    case 'processRecords':
    case 'leaseLost':
    case 'shardEnded':
      this._onRecordProcessorAction(action);
      break;
    case 'checkpoint':
      this._onCheckpointAction(action);
      break;
    case 'shutdownRequested':
      this._onShutdownRequested(action);
      break;
    default:
      this._reportError(util.format('Invalid action received: %j', action));
  }
};