function processLines(input, e_status) {
e_status = e_status - 1;
var lines = input.split('\n').filter(line => line.trim() !== "");
var threshold = 1.0; // Max acceptable lag in MB
for (var i = 0; i < lines.length; i++) {
var line = lines[i].trim();
var lagValue = parseFloat(line);
if (isNaN(lagValue)) {
return `Invalid lag value detected: "${line}"`;
}
if (lagValue > threshold) {
return `Cluster has lag (${lagValue}MB). Exiting...`;
}
}
return "Cluster is in sync, proceeding";
}





0 comments:
Post a Comment