Skip to content

Commit 1bff4cf

Browse files
authored
Merge pull request #299 from EventStore/replica-stats
Re-enable replica stats
2 parents a81036f + a9d21b4 commit 1bff4cf

File tree

2 files changed

+13
-13
lines changed

2 files changed

+13
-13
lines changed

src/js/modules/clusterstatus/controllers/ClusterStatusListCtrl.js

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -37,18 +37,17 @@ define(['./_module'], function (app) {
3737
} else {
3838
$scope.errorMessage = '';
3939
$scope.nodes = response.members;
40-
// TODO: Fix the response from the server
41-
// var leader = getLeaderNode();
42-
// if(leader) {
43-
// var leaderUrl = leader.httpEndPointIp + ':' + leader.httpEndPointPort;
44-
// if(!replicaStatsQuery || leaderUrl !== leaderNodeUrl) {
45-
// leaderNodeUrl = leaderUrl;
46-
// setupReplicaStatsPoller();
47-
// }
48-
// }
49-
}
50-
});
51-
}
40+
var leader = getLeaderNode();
41+
if(leader) {
42+
var leaderUrl = leader.httpEndPointIp + ':' + leader.httpEndPointPort;
43+
if(!replicaStatsQuery || leaderUrl !== leaderNodeUrl) {
44+
leaderNodeUrl = leaderUrl;
45+
setupReplicaStatsPoller();
46+
}
47+
}
48+
}
49+
});
50+
}
5251

5352
function setupReplicaStatsPoller() {
5453
replicaStatsQuery = poller.create({
@@ -73,6 +72,7 @@ define(['./_module'], function (app) {
7372
}
7473

7574
function calculateReplicaStats(replica, leader, node, prevStats) {
75+
if (!node) return;
7676
replica.isCatchingUp = node.state === 'CatchingUp';
7777
replica.bytesToCatchUp = leader.writerCheckpoint - node.writerCheckpoint;
7878

src/js/modules/projections/templates/templates.js

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)