lib/services/storm.js
Function storm
has 84 lines of code (exceeds 25 allowed). Consider refactoring. Open
Open
var storm = function (stormConfig, zookeeperUrl, kafkaUrl) {
var genYMLAndLaunch = function (src, ymlPath, stormJar, config) {
var deferred = Q.defer();
Function genYMLAndLaunch
has 33 lines of code (exceeds 25 allowed). Consider refactoring. Open
Open
var genYMLAndLaunch = function (src, ymlPath, stormJar, config) {
var deferred = Q.defer();
var configTemplate = Handlebars.compile(src);
Fs.writeFile(ymlPath, configTemplate(config), function (err) {
Function startTopology
has 28 lines of code (exceeds 25 allowed). Consider refactoring. Open
Open
startTopology: function (topologyName, analysisFolder, kafkaTopicName) {
var config = {
topologyName: topologyName,
kafkaTopicName: kafkaTopicName,
zookeeperURL: zookeeperUrl,