ARCHIVE/hpcore
1
0
Fork 0
mirror of https://github.com/EvernodeXRPL/hpcore.git synced 2026-04-29 15:37:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Customer port specifier for signalr streamer.

Browse Source
This commit is contained in:
ravinsp
2021-11-17 16:52:13 +05:30
parent 9a87307329
commit 1cdec2f9fa
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
test/vm-cluster/stream.js
View File

@@ -172,9 +172,15 @@ function metricsTracker() {
async function streamCluster(cluster) {
console.log(`Starting to stream cluster '${cluster.name}'...`);
// TODO: Resolve Vultr vm groups.
cluster.hosts.forEach((h, idx) => streamNode(cluster.name, (idx + 1), h, cluster.userPort));
cluster.hosts.forEach((host, idx) => {
let port = cluster.userPort;
if (host.includes(":")) {
const parts = host.split(":");
host = parts[0];
port = parseInt(parts[1]);
}
streamNode(cluster.name, (idx + 1), host, cluster.userPort);
});
}
function streamNode(clusterName, nodeIdx, host, port) {