From ebbe0ad045320f16565a7dec5efbf2632c260a03 Mon Sep 17 00:00:00 2001 From: agodnic Date: Wed, 12 Apr 2023 17:51:16 -0300 Subject: [PATCH] [analytics] Style fixes, remove duplicated code (#230) --- analytic/metric/metric.go | 22 ++++++++++++++++------ 1 file changed, 16 insertions(+), 6 deletions(-) diff --git a/analytic/metric/metric.go b/analytic/metric/metric.go index 9601b21a..8d68522e 100644 --- a/analytic/metric/metric.go +++ b/analytic/metric/metric.go @@ -36,16 +36,26 @@ func (m *Metric) Close() { // vaaCountMeasurement handle the push of metric point for measurement vaa_count. func (m *Metric) vaaCountMeasurement(ctx context.Context, vaa *vaa.VAA) error { - measurement := "vaa_count" - // create point for measurement vaa_count. - point := influxdb2.NewPointWithMeasurement("vaa_count").AddTag("chain_id", strconv.Itoa(int(vaa.EmitterChain))).AddField("count", 1).SetTime(vaa.Timestamp.Add(time.Nanosecond * time.Duration(vaa.Sequence))) - // write point to influx. + measurement := "vaa_count" + + // Create a new point for the `vaa_count` measurement. + point := influxdb2. + NewPointWithMeasurement(measurement). + AddTag("chain_id", strconv.Itoa(int(vaa.EmitterChain))). + AddField("count", 1). + SetTime(vaa.Timestamp.Add(time.Nanosecond * time.Duration(vaa.Sequence))) + + // Write the point to influx. err := m.writeApi.WritePoint(ctx, point) if err != nil { - m.logger.Error("error write metric", zap.String("measurement", measurement), - zap.Uint16("chain_id", uint16(vaa.EmitterChain)), zap.Error(err)) + m.logger.Error("failed to write metric", + zap.String("measurement", measurement), + zap.Uint16("chain_id", uint16(vaa.EmitterChain)), + zap.Error(err), + ) return err } + return nil }