Skip to content

Commit 9f71fa3

Browse files
author
Tim Middleton
committed
Add gRPC Proxy data to Cluster snapshot tab
1 parent 81ea79f commit 9f71fa3

File tree

1 file changed

+67
-13
lines changed

1 file changed

+67
-13
lines changed

‎coherence-visualvm-plugin/src/main/java/com/oracle/coherence/plugin/visualvm/panel/CoherenceClusterSnapshotPanel.java‎

Lines changed: 67 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2020, 2021 Oracle and/or its affiliates. All rights reserved.
2+
* Copyright (c) 2020, 2022 Oracle and/or its affiliates. All rights reserved.
33
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
44
*
55
* This code is free software; you can redistribute it and/or modify it
@@ -34,6 +34,7 @@
3434
import com.oracle.coherence.plugin.visualvm.tablemodel.model.Data;
3535
import com.oracle.coherence.plugin.visualvm.tablemodel.model.ExecutorData;
3636
import com.oracle.coherence.plugin.visualvm.tablemodel.model.FederationData;
37+
import com.oracle.coherence.plugin.visualvm.tablemodel.model.GrpcProxyData;
3738
import com.oracle.coherence.plugin.visualvm.tablemodel.model.HttpProxyData;
3839
import com.oracle.coherence.plugin.visualvm.tablemodel.model.MachineData;
3940
import com.oracle.coherence.plugin.visualvm.tablemodel.model.MemberData;
@@ -139,8 +140,11 @@ public void updateGUI()
139140
}
140141
if (f_model.isExecutorConfigured())
141142
{
142-
sb.append(executorOverview())
143-
.append("<hr>");
143+
sb.append(executorOverview()).append("<hr>");
144+
}
145+
if (f_model.isGrpcProxyConfigured())
146+
{
147+
sb.append(grpcOverview()).append("<hr>");
144148
}
145149

146150
String sCurrent = sb.append("</body></html>").toString();
@@ -352,7 +356,7 @@ private String cachesOverview()
352356
.append(td(getMemoryFormat(entry.getValue().getColumn(CacheData.MEMORY_USAGE_BYTES))))
353357
.append(td(getMemoryFormat(entry.getValue().getColumn(CacheData.MEMORY_USAGE_MB))))
354358
.append(td(getMemoryFormat(entry.getValue().getColumn(CacheData.AVG_OBJECT_SIZE))))
355-
.append(td(entry.getValue().getColumn(CacheData.UNIT_CALCULATOR).toString()))
359+
.append(td((String) entry.getValue().getColumn(CacheData.UNIT_CALCULATOR)))
356360
.append("</tr>");
357361
}
358362

@@ -501,6 +505,50 @@ private String executorOverview()
501505
return sb.append(tableEnd()).toString();
502506
}
503507

508+
/**
509+
* Returns a gRPC overview.
510+
*
511+
* @return a gRPC overview
512+
*/
513+
private String grpcOverview()
514+
{
515+
StringBuilder sb = new StringBuilder(title(getLabel("LBL_grpc")));
516+
517+
long nSentCount = 0L;
518+
long nRecCount = 0L;
519+
520+
for (Map.Entry<Object, Data> entry : m_grpcData)
521+
{
522+
nSentCount += (Long) entry.getValue().getColumn(GrpcProxyData.RESPONSES_SENT_COUNT);
523+
nRecCount += (Long) entry.getValue().getColumn(GrpcProxyData.MESSAGES_RECEIVED_COUNT);
524+
}
525+
526+
sb.append(tableStart())
527+
.append(tableRow(getLabel("LBL_total_grpc_servers"), Integer.toString(m_grpcData.size())))
528+
.append(tableRow(getLabel("LBL_total_grpc_msg_rec"), getMemoryFormat(Long.toString(nRecCount))))
529+
.append(tableRow(getLabel("LBL_total_grpc_resp_sent"), getMemoryFormat(Long.toString(nSentCount))))
530+
.append(tableEnd());
531+
532+
sb.append(tableStart());
533+
534+
sb.append(columnHeaders(VisualVMModel.DataType.GRPC_PROXY));
535+
536+
for (Map.Entry<Object, Data> entry : m_grpcData)
537+
{
538+
sb.append("<tr>")
539+
.append(td(getMemoryFormat(entry.getValue().getColumn(GrpcProxyData.NODE_ID).toString())))
540+
.append(td(getMemoryFormat(entry.getValue().getColumn(GrpcProxyData.SUCCESSFUL_REQUEST_COUNT).toString())))
541+
.append(td(getMemoryFormat(entry.getValue().getColumn(GrpcProxyData.ERROR_REQUEST_COUNT).toString())))
542+
.append(td(getMemoryFormat(entry.getValue().getColumn(GrpcProxyData.RESPONSES_SENT_COUNT).toString())))
543+
.append(td(getMemoryFormat(entry.getValue().getColumn(GrpcProxyData.MESSAGES_RECEIVED_COUNT).toString())))
544+
.append(td(getLatencyValue(entry.getValue().getColumn(GrpcProxyData.REQUEST_DURATION_MEAN).toString())))
545+
.append(td(getLatencyValue(entry.getValue().getColumn(GrpcProxyData.MESSAGE_DURATION_MEAN).toString())))
546+
.append("</tr>");
547+
}
548+
549+
return sb.append(tableEnd()).toString();
550+
}
551+
504552
/**
505553
* Returns a federation overview.
506554
*
@@ -729,16 +777,17 @@ public void updateData()
729777
m_fedOriginDetailData = f_model.getData(VisualVMModel.DataType.FEDERATION_ORIGIN_DETAILS);
730778
}
731779

732-
m_hotcacheData = f_model.getData(VisualVMModel.DataType.HOTCACHE);
780+
m_hotcacheData = f_model.getData(VisualVMModel.DataType.HOTCACHE);
733781
m_hotcachepercacheData = f_model.getData(VisualVMModel.DataType.HOTCACHE_PERCACHE);
734-
m_httpProxyData = f_model.getData(VisualVMModel.DataType.HTTP_PROXY);
735-
m_httpProxyMemberData = f_model.getData(VisualVMModel.DataType.HTTP_PROXY_DETAIL);
736-
m_httpSessionData = f_model.getData(VisualVMModel.DataType.HTTP_SESSION);
737-
m_configData = f_model.getData(VisualVMModel.DataType.JCACHE_CONFIG);
738-
m_statsData = f_model.getData(VisualVMModel.DataType.JCACHE_STATS);
739-
m_persistenceData = f_model.getData(VisualVMModel.DataType.PERSISTENCE);
740-
m_topicData = f_model.getData(VisualVMModel.DataType.TOPICS_DETAIL);
741-
m_executorData = f_model.getData(VisualVMModel.DataType.EXECUTOR);
782+
m_httpProxyData = f_model.getData(VisualVMModel.DataType.HTTP_PROXY);
783+
m_httpProxyMemberData = f_model.getData(VisualVMModel.DataType.HTTP_PROXY_DETAIL);
784+
m_httpSessionData = f_model.getData(VisualVMModel.DataType.HTTP_SESSION);
785+
m_configData = f_model.getData(VisualVMModel.DataType.JCACHE_CONFIG);
786+
m_statsData = f_model.getData(VisualVMModel.DataType.JCACHE_STATS);
787+
m_persistenceData = f_model.getData(VisualVMModel.DataType.PERSISTENCE);
788+
m_topicData = f_model.getData(VisualVMModel.DataType.TOPICS_DETAIL);
789+
m_executorData = f_model.getData(VisualVMModel.DataType.EXECUTOR);
790+
m_grpcData = f_model.getData(VisualVMModel.DataType.GRPC_PROXY);
742791
}
743792

744793
// ----- constants ------------------------------------------------------
@@ -854,6 +903,11 @@ public void updateData()
854903
*/
855904
private List<Map.Entry<Object, Data>> m_executorData;
856905

906+
/**
907+
* The gRPC statistics data retrieved from the {@link VisualVMModel}.
908+
*/
909+
private List<Map.Entry<Object, Data>> m_grpcData;
910+
857911
/**
858912
* The machine statistics data retrieved from the {@link VisualVMModel}.
859913
*/

0 commit comments

Comments
 (0)