From 37061e640696e153e0fa9b8928ffab3df8b46c66 Mon Sep 17 00:00:00 2001
From: Hans Moog <hm@mkjc.net>
Date: Tue, 30 Jul 2019 13:19:46 +0200
Subject: [PATCH] Fix: fixed a few bugs and restructured dashboard
---
plugins/dashboard/plugin.go | 387 +-----------------------------
plugins/dashboard/tps.go | 77 ++++++
plugins/dashboard/tps_template.go | 319 ++++++++++++++++++++++++
plugins/metrics/events.go | 11 +-
plugins/metrics/plugin.go | 30 +--
5 files changed, 415 insertions(+), 409 deletions(-)
create mode 100644 plugins/dashboard/tps.go
create mode 100644 plugins/dashboard/tps_template.go
diff --git a/plugins/dashboard/plugin.go b/plugins/dashboard/plugin.go
index 224aa22c..2d4f992d 100644
--- a/plugins/dashboard/plugin.go
+++ b/plugins/dashboard/plugin.go
@@ -1,395 +1,34 @@
package dashboard
import (
- "html/template"
"log"
"net/http"
- "runtime"
- "github.com/gorilla/websocket"
"github.com/iotaledger/goshimmer/packages/daemon"
+ "github.com/iotaledger/goshimmer/packages/events"
"github.com/iotaledger/goshimmer/packages/node"
+ "github.com/iotaledger/goshimmer/plugins/metrics"
)
-var (
- _, filename, _, runtime_ok = runtime.Caller(0)
- Clients = make(map[*websocket.Conn]bool)
- homeTempl, templ_err = template.New("dashboard").Parse(dashboardHTML)
- upgrader = websocket.Upgrader{
- ReadBufferSize: 1024,
- WriteBufferSize: 1024,
- }
-)
-
-// ServeWs websocket
-func ServeWs(w http.ResponseWriter, r *http.Request) {
- ws, err := upgrader.Upgrade(w, r, nil)
- if err != nil {
- if _, ok := err.(websocket.HandshakeError); !ok {
- log.Println(err)
- }
- return
- }
- Clients = make(map[*websocket.Conn]bool)
- Clients[ws] = true
-}
-
-// ServeHome registration
-func ServeHome(w http.ResponseWriter, r *http.Request) {
- if r.URL.Path != "/dashboard" {
- http.Error(w, "Not found", http.StatusNotFound)
- return
- }
- if r.Method != "GET" {
- http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
- return
- }
- if !runtime_ok {
- panic("Server runtime caller error")
- }
- if templ_err != nil {
- panic("HTML template error")
- }
-
- var v = struct {
- Host string
- Data []uint32
- }{
- r.Host,
- TPSQ,
- }
- homeTempl.Execute(w, &v)
-}
+var PLUGIN = node.NewPlugin("Dashboard", configure, run)
func configure(plugin *node.Plugin) {
+ http.HandleFunc("/dashboard", ServeHome)
+ http.HandleFunc("/ws", ServeWs)
+
+ // send the sampledTPS to client via websocket, use uint32 to save mem
+ metrics.Events.ReceivedTPSUpdated.Attach(events.NewClosure(func(sampledTPS uint64) {
+ TPSQ = append(TPSQ, uint32(sampledTPS))
+ if len(TPSQ) > MAX_Q_SIZE {
+ TPSQ = TPSQ[1:]
+ }
+ }))
}
func run(plugin *node.Plugin) {
daemon.BackgroundWorker("Dashboard Updater", func() {
- http.HandleFunc("/dashboard", ServeHome)
- http.HandleFunc("/ws", ServeWs)
if err := http.ListenAndServe(":8081", nil); err != nil {
log.Fatal(err)
}
})
}
-
-var PLUGIN = node.NewPlugin("Dashboard", configure, run)
-var TPSQ []uint32
-var dashboardHTML = `
-<!DOCTYPE html>
-<html>
-
-<head>
- <script src="https://code.jquery.com/jquery-3.1.1.min.js"></script>
- <script src="https://code.highcharts.com/stock/highstock.js"></script>
- <script src="https://code.highcharts.com/stock/modules/exporting.js"></script>
- <script src="https://code.highcharts.com/stock/modules/export-data.js"></script>
- <div id="container" style="height: 400px; min-width: 310px"></div>
-</head>
-
-<body>
- <script>
- Highcharts.createElement('link', {
- href: 'https://fonts.googleapis.com/css?family=Unica+One',
- rel: 'stylesheet',
- type: 'text/css'
- }, null, document.getElementsByTagName('head')[0]);
-
- Highcharts.theme = {
- colors: ['#2b908f', '#90ee7e', '#f45b5b', '#7798BF', '#aaeeee', '#ff0066',
- '#eeaaee', '#55BF3B', '#DF5353', '#7798BF', '#aaeeee'],
- chart: {
- backgroundColor: {
- linearGradient: { x1: 0, y1: 0, x2: 1, y2: 1 },
- stops: [
- [0, '#2a2a2b'],
- [1, '#3e3e40']
- ]
- },
- // style: {
- // fontFamily: 'sans-serif'
- // },
- plotBorderColor: '#606063'
- },
- title: {
- style: {
- color: '#E0E0E3',
- // textTransform: 'uppercase',
- fontSize: '20px'
- }
- },
- subtitle: {
- style: {
- color: '#E0E0E3',
- // textTransform: 'uppercase'
- }
- },
- xAxis: {
- gridLineColor: '#707073',
- labels: {
- style: {
- color: '#E0E0E3'
- }
- },
- lineColor: '#707073',
- minorGridLineColor: '#505053',
- tickColor: '#707073',
- title: {
- style: {
- color: '#A0A0A3'
-
- }
- }
- },
- yAxis: {
- gridLineColor: '#707073',
- labels: {
- style: {
- color: '#E0E0E3'
- }
- },
- lineColor: '#707073',
- minorGridLineColor: '#505053',
- tickColor: '#707073',
- tickWidth: 1,
- title: {
- style: {
- color: '#A0A0A3'
- }
- }
- },
- tooltip: {
- backgroundColor: 'rgba(0, 0, 0, 0.85)',
- style: {
- color: '#F0F0F0'
- }
- },
- plotOptions: {
- series: {
- dataLabels: {
- color: '#B0B0B3'
- },
- marker: {
- lineColor: '#333'
- }
- },
- boxplot: {
- fillColor: '#505053'
- },
- candlestick: {
- lineColor: 'white'
- },
- errorbar: {
- color: 'white'
- }
- },
- legend: {
- itemStyle: {
- color: '#E0E0E3'
- },
- itemHoverStyle: {
- color: '#FFF'
- },
- itemHiddenStyle: {
- color: '#606063'
- }
- },
- credits: {
- style: {
- color: '#666'
- }
- },
- labels: {
- style: {
- color: '#707073'
- }
- },
-
- drilldown: {
- activeAxisLabelStyle: {
- color: '#F0F0F3'
- },
- activeDataLabelStyle: {
- color: '#F0F0F3'
- }
- },
-
- navigation: {
- buttonOptions: {
- symbolStroke: '#DDDDDD',
- theme: {
- fill: '#505053'
- }
- }
- },
-
- // scroll charts
- rangeSelector: {
- buttonTheme: {
- fill: '#505053',
- stroke: '#000000',
- style: {
- color: '#CCC'
- },
- states: {
- hover: {
- fill: '#707073',
- stroke: '#000000',
- style: {
- color: 'white'
- }
- },
- select: {
- fill: '#000003',
- stroke: '#000000',
- style: {
- color: 'white'
- }
- }
- }
- },
- inputBoxBorderColor: '#505053',
- inputStyle: {
- backgroundColor: '#333',
- color: 'silver'
- },
- labelStyle: {
- color: 'silver'
- }
- },
-
- navigator: {
- handles: {
- backgroundColor: '#666',
- borderColor: '#AAA'
- },
- outlineColor: '#CCC',
- maskFill: 'rgba(255,255,255,0.1)',
- series: {
- color: '#7798BF',
- lineColor: '#A6C7ED'
- },
- xAxis: {
- gridLineColor: '#505053'
- }
- },
-
- scrollbar: {
- barBackgroundColor: '#808083',
- barBorderColor: '#808083',
- buttonArrowColor: '#CCC',
- buttonBackgroundColor: '#606063',
- buttonBorderColor: '#606063',
- rifleColor: '#FFF',
- trackBackgroundColor: '#404043',
- trackBorderColor: '#404043'
- },
-
- // special colors for some of the
- legendBackgroundColor: 'rgba(0, 0, 0, 0.5)',
- background2: '#505053',
- dataLabelsColor: '#B0B0B3',
- textColor: '#C0C0C0',
- contrastTextColor: '#F0F0F3',
- maskColor: 'rgba(255,255,255,0.3)'
- };
-
- // Apply the theme
- Highcharts.setOptions(Highcharts.theme);
-
- // Start Here
- var time = Date.now() - 3000;
- var start_draw = time + 5000;
- const update_rate = 5;
- var counter = 0;
- data = [[time - 5000, 0]];
- var tzoffset = new Date().getTimezoneOffset();
- var chart = Highcharts.stockChart('container', {
- rangeSelector: {
- selected: 1
- },
-
- title: {
- text: 'Transactions per second'
- },
-
- time: {
- timezoneOffset: tzoffset
- },
-
- rangeSelector: {
- buttons: [
- {
- type: 'minute',
- count: 5,
- text: '5m'
- }, {
- type: 'minute',
- count: 15,
- text: '15m'
- }, {
- type: 'minute',
- count: 30,
- text: '30m'
- }, {
- type: 'hour',
- count: 60,
- text: '1h'
- }],
- inputEnabled: false
- },
-
- series: [{
- name: 'Transactions per second',
- data: data,
- type: 'areaspline',
- threshold: null,
- tooltip: {
- valueDecimals: 0
- },
- fillColor: {
- linearGradient: {
- x1: 0,
- y1: 0,
- x2: 0,
- y2: 1
- },
- stops: [
- [0, Highcharts.getOptions().colors[0]],
- [1, Highcharts.Color(Highcharts.getOptions().colors[0]).setOpacity(0).get('rgba')]
- ]
- }
- }]
- });
- const conn = new WebSocket("ws://{{.Host}}/ws");
- conn.binaryType = 'arraybuffer';
- conn.onopen = evt => {
- console.log("WebSocket is open now.");
- const dataStr = '{{.Data}}'
- const data = JSON.parse(dataStr.replace(/ /g, ','));
- time = Date.now() - 1000 * (data.length + 1);
- for (let i = 0; i < data.length; i++) {
- chart.series[0].addPoint([time += 1000, parseInt(data[i], 10)], true);
- }
- console.log(data);
- console.log("WebSocket done.");
- }
- conn.onclose = () => {
- // console.log('Connection closed');
- }
- conn.onmessage = evt => {
- console.log('metric updated');
- const data = evt.data;
- const dv = new DataView(data);
- // var value = dv.getUint32(4, true) << 32 | dv.getUint32(0, true);
- const value = dv.getUint32(0, true);
- chart.series[0].addPoint([time += 1000, value], true); //((counter += 1) % update_rate == 4));
- console.log(value);
- console.log(dv);
- }
- </script>
-</body>
-
-</html>
-`
diff --git a/plugins/dashboard/tps.go b/plugins/dashboard/tps.go
new file mode 100644
index 00000000..8572fa68
--- /dev/null
+++ b/plugins/dashboard/tps.go
@@ -0,0 +1,77 @@
+package dashboard
+
+import (
+ "encoding/binary"
+ "fmt"
+ "html/template"
+ "net/http"
+
+ "github.com/gorilla/websocket"
+ "github.com/iotaledger/goshimmer/packages/events"
+ "github.com/iotaledger/goshimmer/plugins/metrics"
+)
+
+var (
+ homeTempl, templ_err = template.New("dashboard").Parse(tpsTemplate)
+ upgrader = websocket.Upgrader{
+ ReadBufferSize: 1024,
+ WriteBufferSize: 1024,
+ }
+)
+
+// ServeWs websocket
+func ServeWs(w http.ResponseWriter, r *http.Request) {
+ ws, err := upgrader.Upgrade(w, r, nil)
+ if err != nil {
+ return
+ }
+
+ notifyWebsocketClient := events.NewClosure(func(sampledTPS uint64) {
+ p := make([]byte, 4)
+ binary.LittleEndian.PutUint32(p, uint32(sampledTPS))
+ if err := ws.WriteMessage(websocket.BinaryMessage, p); err != nil {
+ return
+ }
+ })
+
+ metrics.Events.ReceivedTPSUpdated.Attach(notifyWebsocketClient)
+
+ for {
+ if _, _, err := ws.ReadMessage(); err != nil {
+ break
+ }
+ }
+
+ fmt.Println("DISCONNECTOR")
+
+ metrics.Events.ReceivedTPSUpdated.Detach(notifyWebsocketClient)
+}
+
+// ServeHome registration
+func ServeHome(w http.ResponseWriter, r *http.Request) {
+ if r.URL.Path != "/dashboard" {
+ http.Error(w, "Not found", http.StatusNotFound)
+ return
+ }
+ if r.Method != "GET" {
+ http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
+ return
+ }
+ if templ_err != nil {
+ panic("HTML template error")
+ }
+
+ _ = homeTempl.Execute(w, &struct {
+ Host string
+ Data []uint32
+ }{
+ r.Host,
+ TPSQ,
+ })
+}
+
+var TPSQ []uint32
+
+const (
+ MAX_Q_SIZE int = 3600
+)
diff --git a/plugins/dashboard/tps_template.go b/plugins/dashboard/tps_template.go
new file mode 100644
index 00000000..69d27e6e
--- /dev/null
+++ b/plugins/dashboard/tps_template.go
@@ -0,0 +1,319 @@
+package dashboard
+
+var tpsTemplate = `
+<!DOCTYPE html>
+<html>
+
+<head>
+ <script src="https://code.jquery.com/jquery-3.1.1.min.js"></script>
+ <script src="https://code.highcharts.com/stock/highstock.js"></script>
+ <script src="https://code.highcharts.com/stock/modules/exporting.js"></script>
+ <script src="https://code.highcharts.com/stock/modules/export-data.js"></script>
+ <div id="container" style="height: 400px; min-width: 310px"></div>
+</head>
+
+<body>
+ <script>
+ Highcharts.createElement('link', {
+ href: 'https://fonts.googleapis.com/css?family=Unica+One',
+ rel: 'stylesheet',
+ type: 'text/css'
+ }, null, document.getElementsByTagName('head')[0]);
+
+ Highcharts.theme = {
+ colors: ['#2b908f', '#90ee7e', '#f45b5b', '#7798BF', '#aaeeee', '#ff0066',
+ '#eeaaee', '#55BF3B', '#DF5353', '#7798BF', '#aaeeee'],
+ chart: {
+ backgroundColor: {
+ linearGradient: { x1: 0, y1: 0, x2: 1, y2: 1 },
+ stops: [
+ [0, '#2a2a2b'],
+ [1, '#3e3e40']
+ ]
+ },
+ // style: {
+ // fontFamily: 'sans-serif'
+ // },
+ plotBorderColor: '#606063'
+ },
+ title: {
+ style: {
+ color: '#E0E0E3',
+ // textTransform: 'uppercase',
+ fontSize: '20px'
+ }
+ },
+ subtitle: {
+ style: {
+ color: '#E0E0E3',
+ // textTransform: 'uppercase'
+ }
+ },
+ xAxis: {
+ gridLineColor: '#707073',
+ labels: {
+ style: {
+ color: '#E0E0E3'
+ }
+ },
+ lineColor: '#707073',
+ minorGridLineColor: '#505053',
+ tickColor: '#707073',
+ title: {
+ style: {
+ color: '#A0A0A3'
+
+ }
+ }
+ },
+ yAxis: {
+ gridLineColor: '#707073',
+ labels: {
+ style: {
+ color: '#E0E0E3'
+ }
+ },
+ lineColor: '#707073',
+ minorGridLineColor: '#505053',
+ tickColor: '#707073',
+ tickWidth: 1,
+ title: {
+ style: {
+ color: '#A0A0A3'
+ }
+ }
+ },
+ tooltip: {
+ backgroundColor: 'rgba(0, 0, 0, 0.85)',
+ style: {
+ color: '#F0F0F0'
+ }
+ },
+ plotOptions: {
+ series: {
+ dataLabels: {
+ color: '#B0B0B3'
+ },
+ marker: {
+ lineColor: '#333'
+ }
+ },
+ boxplot: {
+ fillColor: '#505053'
+ },
+ candlestick: {
+ lineColor: 'white'
+ },
+ errorbar: {
+ color: 'white'
+ }
+ },
+ legend: {
+ itemStyle: {
+ color: '#E0E0E3'
+ },
+ itemHoverStyle: {
+ color: '#FFF'
+ },
+ itemHiddenStyle: {
+ color: '#606063'
+ }
+ },
+ credits: {
+ style: {
+ color: '#666'
+ }
+ },
+ labels: {
+ style: {
+ color: '#707073'
+ }
+ },
+
+ drilldown: {
+ activeAxisLabelStyle: {
+ color: '#F0F0F3'
+ },
+ activeDataLabelStyle: {
+ color: '#F0F0F3'
+ }
+ },
+
+ navigation: {
+ buttonOptions: {
+ symbolStroke: '#DDDDDD',
+ theme: {
+ fill: '#505053'
+ }
+ }
+ },
+
+ // scroll charts
+ rangeSelector: {
+ buttonTheme: {
+ fill: '#505053',
+ stroke: '#000000',
+ style: {
+ color: '#CCC'
+ },
+ states: {
+ hover: {
+ fill: '#707073',
+ stroke: '#000000',
+ style: {
+ color: 'white'
+ }
+ },
+ select: {
+ fill: '#000003',
+ stroke: '#000000',
+ style: {
+ color: 'white'
+ }
+ }
+ }
+ },
+ inputBoxBorderColor: '#505053',
+ inputStyle: {
+ backgroundColor: '#333',
+ color: 'silver'
+ },
+ labelStyle: {
+ color: 'silver'
+ }
+ },
+
+ navigator: {
+ handles: {
+ backgroundColor: '#666',
+ borderColor: '#AAA'
+ },
+ outlineColor: '#CCC',
+ maskFill: 'rgba(255,255,255,0.1)',
+ series: {
+ color: '#7798BF',
+ lineColor: '#A6C7ED'
+ },
+ xAxis: {
+ gridLineColor: '#505053'
+ }
+ },
+
+ scrollbar: {
+ barBackgroundColor: '#808083',
+ barBorderColor: '#808083',
+ buttonArrowColor: '#CCC',
+ buttonBackgroundColor: '#606063',
+ buttonBorderColor: '#606063',
+ rifleColor: '#FFF',
+ trackBackgroundColor: '#404043',
+ trackBorderColor: '#404043'
+ },
+
+ // special colors for some of the
+ legendBackgroundColor: 'rgba(0, 0, 0, 0.5)',
+ background2: '#505053',
+ dataLabelsColor: '#B0B0B3',
+ textColor: '#C0C0C0',
+ contrastTextColor: '#F0F0F3',
+ maskColor: 'rgba(255,255,255,0.3)'
+ };
+
+ // Apply the theme
+ Highcharts.setOptions(Highcharts.theme);
+
+ // Start Here
+ var time = Date.now() - 3000;
+ var start_draw = time + 5000;
+ const update_rate = 5;
+ var counter = 0;
+ data = [[time - 5000, 0]];
+ var tzoffset = new Date().getTimezoneOffset();
+ var chart = Highcharts.stockChart('container', {
+ rangeSelector: {
+ selected: 1
+ },
+
+ title: {
+ text: 'Transactions per second'
+ },
+
+ time: {
+ timezoneOffset: tzoffset
+ },
+
+ rangeSelector: {
+ buttons: [
+ {
+ type: 'minute',
+ count: 5,
+ text: '5m'
+ }, {
+ type: 'minute',
+ count: 15,
+ text: '15m'
+ }, {
+ type: 'minute',
+ count: 30,
+ text: '30m'
+ }, {
+ type: 'hour',
+ count: 60,
+ text: '1h'
+ }],
+ inputEnabled: false
+ },
+
+ series: [{
+ name: 'Transactions per second',
+ data: data,
+ type: 'areaspline',
+ threshold: null,
+ tooltip: {
+ valueDecimals: 0
+ },
+ fillColor: {
+ linearGradient: {
+ x1: 0,
+ y1: 0,
+ x2: 0,
+ y2: 1
+ },
+ stops: [
+ [0, Highcharts.getOptions().colors[0]],
+ [1, Highcharts.Color(Highcharts.getOptions().colors[0]).setOpacity(0).get('rgba')]
+ ]
+ }
+ }]
+ });
+ const conn = new WebSocket("ws://{{.Host}}/ws");
+ conn.binaryType = 'arraybuffer';
+ conn.onopen = evt => {
+ console.log("WebSocket is open now.");
+ const dataStr = '{{.Data}}'
+ const data = JSON.parse(dataStr.replace(/ /g, ','));
+ time = Date.now() - 1000 * (data.length + 1);
+ for (let i = 0; i < data.length; i++) {
+ chart.series[0].addPoint([time += 1000, parseInt(data[i], 10)], true);
+ }
+ console.log(data);
+ console.log("WebSocket done.");
+ }
+ conn.onclose = () => {
+ // console.log('Connection closed');
+ }
+ conn.onmessage = evt => {
+ console.log('metric updated');
+ const data = evt.data;
+ const dv = new DataView(data);
+ // var value = dv.getUint32(4, true) << 32 | dv.getUint32(0, true);
+ const value = dv.getUint32(0, true);
+ chart.series[0].addPoint([time += 1000, value], true); //((counter += 1) % update_rate == 4));
+ console.log(value);
+ console.log(dv);
+ }
+ </script>
+</body>
+
+</html>
+`
diff --git a/plugins/metrics/events.go b/plugins/metrics/events.go
index 1bcab96e..18189674 100644
--- a/plugins/metrics/events.go
+++ b/plugins/metrics/events.go
@@ -4,17 +4,14 @@ import (
"github.com/iotaledger/goshimmer/packages/events"
)
-// define a struct with the available events
+var Events = pluginEvents{
+ ReceivedTPSUpdated: events.NewEvent(uint64EventCaller),
+}
+
type pluginEvents struct {
ReceivedTPSUpdated *events.Event
}
-// define a function that maps our event parameters to the correct type: uint64 (GO has no generics)
func uint64EventCaller(handler interface{}, params ...interface{}) {
handler.(func(uint64))(params[0].(uint64))
}
-
-// expose our event API
-var Events = pluginEvents{
- ReceivedTPSUpdated: events.NewEvent(uint64EventCaller),
-}
diff --git a/plugins/metrics/plugin.go b/plugins/metrics/plugin.go
index 94fd74b0..bcc9310e 100644
--- a/plugins/metrics/plugin.go
+++ b/plugins/metrics/plugin.go
@@ -1,50 +1,24 @@
package metrics
import (
- "encoding/binary"
"time"
- "github.com/gorilla/websocket"
"github.com/iotaledger/goshimmer/packages/daemon"
"github.com/iotaledger/goshimmer/packages/events"
"github.com/iotaledger/goshimmer/packages/model/meta_transaction"
"github.com/iotaledger/goshimmer/packages/node"
"github.com/iotaledger/goshimmer/packages/timeutil"
- "github.com/iotaledger/goshimmer/plugins/dashboard"
"github.com/iotaledger/goshimmer/plugins/gossip"
)
-// create configure handler (get's called when the PLUGIN is "loaded" by the node)
+var PLUGIN = node.NewPlugin("Metrics", configure, run)
+
func configure(plugin *node.Plugin) {
// increase received TPS counter whenever we receive a new transaction
gossip.Events.ReceiveTransaction.Attach(events.NewClosure(func(_ *meta_transaction.MetaTransaction) { increaseReceivedTPSCounter() }))
-
- // send the sampledTPS to client via websocket, use uint32 to save mem
- Events.ReceivedTPSUpdated.Attach(events.NewClosure(func(sampledTPS uint64) {
- for client := range dashboard.Clients {
- p := make([]byte, 4)
- binary.LittleEndian.PutUint32(p, uint32(sampledTPS))
- if err := client.WriteMessage(websocket.BinaryMessage, p); err != nil {
- return
- }
- TPSQ = append(TPSQ, uint32(sampledTPS))
- if len(TPSQ) > MAX_Q_SIZE {
- TPSQ = TPSQ[1:]
- }
- dashboard.TPSQ = TPSQ
- }
- }))
}
-// create run handler (get's called when the PLUGIN is "executed" by the node)
func run(plugin *node.Plugin) {
// create a background worker that "measures" the TPS value every second
daemon.BackgroundWorker("Metrics TPS Updater", func() { timeutil.Ticker(measureReceivedTPS, 1*time.Second) })
}
-
-// export plugin
-var PLUGIN = node.NewPlugin("Metrics", configure, run)
-
-// TPS queue
-var TPSQ []uint32
-var MAX_Q_SIZE int = 3600
--
GitLab