uforwarder-core/src/main/resources/masterJobs.html [64:143]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
{ "data": "job.job.rpcDispatcherTask.procedure" },
{ "data": "job.job.rpcDispatcherTask.rpcTimeoutMs" },
{ "data": "job.job.rpcDispatcherTask.maxRpcTimeouts" },
{ "data": "job.job.retryConfig.retryEnabled" },
{ "data": "job.job",
"fnCreatedCell": function (nTd, sData, oData, iRow, iCol) {
var retryTopic = oData.job.job.rpcDispatcherTask.retryQueueTopic;
if (oData.job.job.retryConfig.retryQueues.length > 0) {
retryTopic = oData.job.job.retryConfig.retryQueues.map(r => r.retryQueueTopic).join(
',\n');
}
$(nTd).html(retryTopic);
}
},
{ "data": "job.job",
"fnCreatedCell": function (nTd, sData, oData, iRow, iCol) {
var retryCluster = oData.job.job.rpcDispatcherTask.retryCluster;
if (oData.job.job.retryConfig.retryQueues.length > 0) {
retryCluster = oData.job.job.retryConfig.retryQueues.map(r => r.retryCluster).join(
',\n');
}
$(nTd).html(retryCluster);
}
},
{ "data": "job.job",
"fnCreatedCell": function (nTd, sData, oData, iRow, iCol) {
var processingDelay = oData.job.job.kafkaConsumerTask.processingDelayMs;
if (oData.job.job.retryConfig.retryQueues.length > 0) {
processingDelay = oData.job.job.retryConfig.retryQueues.map(
r => r.processingDelayMs).join(',\n');
}
$(nTd).html(processingDelay);
}
},
{ "data": "job.job",
"fnCreatedCell": function (nTd, sData, oData, iRow, iCol) {
var maxRetryCount = '';
if (oData.job.job.retryConfig.retryQueues.length > 0) {
maxRetryCount = oData.job.job.retryConfig.retryQueues.map(
r => r.maxRetryCount).join(',\n');
}
$(nTd).html(maxRetryCount);
}
},
{ "data": "job.job.rpcDispatcherTask.dlqTopic" },
{ "data": "job.job.rpcDispatcherTask.dlqCluster" },
],
"order": [[1, 'asc']],
"pageLength": 100
} );
// Add event listener for opening and closing details
$('#data tbody').on('click', 'td.details-control', function () {
var tr = $(this).closest('tr');
var row = table.row( tr );
if ( row.child.isShown() ) {
// This row is already open - close it
row.child.hide();
tr.removeClass('shown');
}
else {
// Open this row
row.child( format(row.data()) ).show();
tr.addClass('shown');
}
} );
$.ajax({
url: "./navJson",
success: function( result ) {
$( "#title" ).html( result.service + " " + result.role + " on " + result.host );
}
})
} );
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
uforwarder-core/src/main/resources/workerJobs.html [65:144]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
{ "data": "job.job.rpcDispatcherTask.procedure" },
{ "data": "job.job.rpcDispatcherTask.rpcTimeoutMs" },
{ "data": "job.job.rpcDispatcherTask.maxRpcTimeouts" },
{ "data": "job.job.retryConfig.retryEnabled" },
{ "data": "job.job",
"fnCreatedCell": function (nTd, sData, oData, iRow, iCol) {
var retryTopic = oData.job.job.rpcDispatcherTask.retryQueueTopic;
if (oData.job.job.retryConfig.retryQueues.length > 0) {
retryTopic = oData.job.job.retryConfig.retryQueues.map(r => r.retryQueueTopic).join(
',\n');
}
$(nTd).html(retryTopic);
}
},
{ "data": "job.job",
"fnCreatedCell": function (nTd, sData, oData, iRow, iCol) {
var retryCluster = oData.job.job.rpcDispatcherTask.retryCluster;
if (oData.job.job.retryConfig.retryQueues.length > 0) {
retryCluster = oData.job.job.retryConfig.retryQueues.map(r => r.retryCluster).join(
',\n');
}
$(nTd).html(retryCluster);
}
},
{ "data": "job.job",
"fnCreatedCell": function (nTd, sData, oData, iRow, iCol) {
var processingDelay = oData.job.job.kafkaConsumerTask.processingDelayMs;
if (oData.job.job.retryConfig.retryQueues.length > 0) {
processingDelay = oData.job.job.retryConfig.retryQueues.map(
r => r.processingDelayMs).join(',\n');
}
$(nTd).html(processingDelay);
}
},
{ "data": "job.job",
"fnCreatedCell": function (nTd, sData, oData, iRow, iCol) {
var maxRetryCount = '';
if (oData.job.job.retryConfig.retryQueues.length > 0) {
maxRetryCount = oData.job.job.retryConfig.retryQueues.map(
r => r.maxRetryCount).join(',\n');
}
$(nTd).html(maxRetryCount);
}
},
{ "data": "job.job.rpcDispatcherTask.dlqTopic" },
{ "data": "job.job.rpcDispatcherTask.dlqCluster" },
],
"order": [[1, 'asc']],
"pageLength": 100
} );
// Add event listener for opening and closing details
$('#data tbody').on('click', 'td.details-control', function () {
var tr = $(this).closest('tr');
var row = table.row( tr );
if ( row.child.isShown() ) {
// This row is already open - close it
row.child.hide();
tr.removeClass('shown');
}
else {
// Open this row
row.child( format(row.data()) ).show();
tr.addClass('shown');
}
} );
$.ajax({
url: "./navJson",
success: function( result ) {
$( "#title" ).html( result.service + " " + result.role + " on " + result.host );
}
})
} );
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -