Add metrics for uni-watcher (#350)

vulcanize · Feb 8, 2022 · cfd05ea · cfd05ea
1 parent d5171c2
commit cfd05ea
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 3 deletions.
diff --git a/packages/uni-info-watcher/environments/local.toml b/packages/uni-info-watcher/environments/local.toml
@@ -7,7 +7,7 @@
 
 [metrics]
   host = "127.0.0.1"
-  port = 8083
+  port = 8084
 
 [database]
   type = "postgres"

diff --git a/packages/uni-watcher/environments/local.toml b/packages/uni-watcher/environments/local.toml
@@ -2,6 +2,10 @@
   host = "127.0.0.1"
   port = 3003
 
+[metrics]
+  host = "127.0.0.1"
+  port = 8083
+
 [database]
   type = "postgres"
   host = "localhost"

diff --git a/packages/uni-watcher/src/job-runner.ts b/packages/uni-watcher/src/job-runner.ts
@@ -18,7 +18,8 @@ import {
   QUEUE_EVENT_PROCESSING,
   JobQueueConfig,
   DEFAULT_CONFIG_PATH,
-  getCustomProvider
+  getCustomProvider,
+  startMetricsServer
 } from '@vulcanize/util';
 
 import { Indexer } from './indexer';
@@ -72,7 +73,7 @@ export const main = async (): Promise<any> => {
 
   assert(config.server, 'Missing server config');
 
-  const { upstream, database: dbConfig, jobQueue: jobQueueConfig } = config;
+  const { upstream, database: dbConfig, jobQueue: jobQueueConfig, metrics } = config;
 
   assert(dbConfig, 'Missing database config');
 
@@ -111,6 +112,8 @@ export const main = async (): Promise<any> => {
 
   const jobRunner = new JobRunner(jobQueueConfig, indexer, jobQueue);
   await jobRunner.start();
+
+  startMetricsServer(metrics.host, metrics.port);
 };
 
 main().then(() => {

diff --git a/packages/util/src/metrics.ts b/packages/util/src/metrics.ts
@@ -21,6 +21,9 @@ export const lastBlockNumEvents = new promClient.Gauge({
 const app: Application = express();
 
 export async function startMetricsServer (host: string, port: number): Promise<void> {
+  // Add default metrics
+  promClient.collectDefaultMetrics();
+
   app.get('/metrics', async (req, res) => {
     res.setHeader('Content-Type', register.contentType);