remove: prometheus modules

Author: rustcandy

.docs/config.md

@@ -49,7 +49,6 @@ Let's see what each section refers to:
 - [`database`](#database)
 - [`pruning`](#pruning)
 - [`logging`](#logging)
-- [`telemetry`](#telemetry)
 
 ## `chain`
 This section contains the details of the chain configuration regarding the Cosmos SDK.
@@ -63,7 +62,6 @@ This section contains the details of the chain configuration regarding the Cosmo
 Currently, we support the following modules:
 
 - `pruning` to periodically prune the old database data
-- `telemetry` to support a telemetry service
 
 ## `node`
 This section contains the details of the node to which Juno will connect.
@@ -144,16 +142,4 @@ if you add the `"pruning"` entry to the `modules` field of the [`chain` config](
 |:-------------:|:---------:|:-------------------------------------------------------------------------------------------------------|:--------|
 |  `interval`   | `integer` | Number of blocks that should pass between one pruning and the other (default: prune every `10` blocks) | `100`   | 
 | `keep_every`  | `integer` | Keep the state every `nth` block, even if it should have been pruned                                   | `500`   | 
-| `keep_recent` | `integer` | Do not prune this amount of recent states                                                              | `100`   |
-
-## `telemetry`
-This section allows to configure the telemetry details of Juno. Note that this will have effect only if you add
-the `"telemetry"` entry to the `modules` field of the [`chain` config](#chain).
-
-| Attribute |  Type  | Description                                    | Example |
-|:---------:|:------:|:-----------------------------------------------|:--------| 
-|  `port`   | `uint` | Port on which the telemetry server will listen | `8000`  | 
-
-**Note**  
-If the telemetry server is enabled, a new endpoint at the provided port and path `/metrics` will
-expose [Prometheus](https://prometheus.io/) data.
+| `keep_recent` | `integer` | Do not prune this amount of recent states                                                              | `100`   |

cmd/start/cmd.go

@@ -12,7 +12,6 @@ import (
 
 	"github.com/forbole/juno/v5/modules"
 	"github.com/forbole/juno/v5/parser"
-	"github.com/forbole/juno/v5/prometheus"
 	"github.com/forbole/juno/v5/types"
 	cmdtypes "github.com/forbole/juno/v5/types/cmd"
 	"github.com/forbole/juno/v5/utils"
@@ -53,12 +52,6 @@ func NewStartCmd() *cobra.Command {
 func startParsing(ctx *parser.Context) error {
 	// Get the config
 	cfg := ctx.Config.Parser
-	prometheus.StartHeight.Add(float64(cfg.StartHeight))
-
-	// Start the prometheus monitoring
-	if ctx.Prometheus != nil {
-		ctx.Prometheus.Start()
-	}
 
 	// Start periodic operations
 	scheduler := gocron.NewScheduler(time.UTC)
@@ -130,7 +123,6 @@ func enqueueMissingBlocks(exportQueue types.HeightQueue, ctx *parser.Context) {
 	lastDBBlockHeight, err := ctx.Database.GetLastBlockHeight()
 	if err != nil {
 		ctx.Logger.Error("failed to get last block height from database", "error", err)
-		prometheus.SignalDBOperationError()
 	}
 
 	// Get the start height, default to the config's height
@@ -203,8 +195,6 @@ func mustGetLatestHeight(ctx *parser.Context) int64 {
 		}
 
 		ctx.Logger.Error("failed to get last block from rpc client", "err", err, "retry count", retryCount)
-		prometheus.SignalRPCRequestError()
-
 		time.Sleep(ctx.Config.GetAvgBlockTime() * time.Duration(retryCount))
 	}
 
@@ -225,8 +215,5 @@ func trapSignal(ctx *parser.Context) {
 		defer ctx.Node.Stop()
 		defer ctx.Database.Close()
 		defer waitGroup.Done()
-		if ctx.Prometheus != nil {
-			defer ctx.Prometheus.Stop()
-		}
 	}()
 }

go.mod

@@ -17,11 +17,9 @@ require (
 	github.com/gogo/protobuf v1.3.2
 	github.com/golang/protobuf v1.5.4
 	github.com/golangci/golangci-lint v1.52.2
-	github.com/gorilla/mux v1.8.1
 	github.com/grpc-ecosystem/grpc-gateway v1.16.0
 	github.com/jmoiron/sqlx v1.3.5
 	github.com/lib/pq v1.10.9
-	github.com/prometheus/client_golang v1.19.0
 	github.com/rs/zerolog v1.32.0
 	github.com/spf13/cobra v1.8.0
 	github.com/spf13/viper v1.18.2
@@ -169,6 +167,7 @@ require (
 	github.com/pkg/errors v0.9.1 // indirect
 	github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
 	github.com/polyfloyd/go-errorlint v1.4.5 // indirect
+	github.com/prometheus/client_golang v1.19.0 // indirect
 	github.com/prometheus/client_model v0.6.1 // indirect
 	github.com/prometheus/common v0.52.2 // indirect
 	github.com/prometheus/procfs v0.13.0 // indirect

go.sum

@@ -339,8 +339,6 @@ github.com/googleapis/gax-go/v2 v2.0.4/go.mod h1:0Wqv26UfaUD9n4G6kQubkQ+KchISgw+
 github.com/googleapis/gax-go/v2 v2.0.5/go.mod h1:DWXyrwAJ9X0FpwwEdw+IPEYBICEFu5mhpdKc/us6bOk=
 github.com/gordonklaus/ineffassign v0.0.0-20230107090616-13ace0543b28 h1:9alfqbrhuD+9fLZ4iaAVwhlp5PEhmnBt7yvK2Oy5C1U=
 github.com/gordonklaus/ineffassign v0.0.0-20230107090616-13ace0543b28/go.mod h1:Qcp2HIAYhR7mNUVSIxZww3Guk4it82ghYcEXIAk+QT0=
-github.com/gorilla/mux v1.8.1 h1:TuBL49tXwgrFYWhqrNgrUNEY92u81SPhu7sTdzQEiWY=
-github.com/gorilla/mux v1.8.1/go.mod h1:AKf9I4AEqPTmMytcMc0KkNouC66V3BtZ4qD5fmWSiMQ=
 github.com/gorilla/websocket v1.5.0 h1:PPwGk2jz7EePpoHN/+ClbZu8SPxiqlu12wZP/3sWmnc=
 github.com/gorilla/websocket v1.5.0/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
 github.com/gostaticanalysis/analysisutil v0.7.1 h1:ZMCjoue3DtDWQ5WyU16YbjbQEQ3VuzwxALrpYd+HeKk=

logging/default.go

@@ -9,7 +9,6 @@ import (
 	"github.com/rs/zerolog/log"
 
 	sdk "github.com/forbole/juno/v5/cosmos-sdk/types"
-	"github.com/forbole/juno/v5/prometheus"
 
 	"github.com/forbole/juno/v5/modules"
 	"github.com/forbole/juno/v5/types"
@@ -75,7 +74,6 @@ func (d *defaultLogger) Info(msg string, keyVals ...interface{}) {
 
 // Error implements Logger
 func (d *defaultLogger) Error(msg string, keyVals ...interface{}) {
-	prometheus.ErrorsCount.Inc()
 	d.Logger.Error().Fields(getLogFields(keyVals...)).Msg(msg)
 }
 

modules/registrar/registrar.go

@@ -5,7 +5,6 @@ import (
 	"github.com/forbole/juno/v5/logging"
 	"github.com/forbole/juno/v5/modules"
 	"github.com/forbole/juno/v5/modules/pruning"
-	"github.com/forbole/juno/v5/modules/telemetry"
 	"github.com/forbole/juno/v5/node"
 	"github.com/forbole/juno/v5/types"
 	"github.com/forbole/juno/v5/types/config"
@@ -79,7 +78,6 @@ func NewDefaultRegistrar() *DefaultRegistrar {
 func (r *DefaultRegistrar) BuildModules(ctx Context) modules.Modules {
 	return modules.Modules{
 		pruning.NewModule(ctx.JunoConfig, ctx.Database, ctx.Logger),
-		telemetry.NewModule(ctx.JunoConfig),
 	}
 }
 

modules/telemetry/config.go

@@ -5,7 +5,6 @@ import (
 	"github.com/forbole/juno/v5/logging"
 	"github.com/forbole/juno/v5/modules"
 	"github.com/forbole/juno/v5/node"
-	"github.com/forbole/juno/v5/prometheus"
 	"github.com/forbole/juno/v5/types"
 	"github.com/forbole/juno/v5/types/config"
 )
@@ -18,7 +17,6 @@ type Context struct {
 	Database       database.Database
 	Logger         logging.Logger
 	Modules        []modules.Module
-	Prometheus     *prometheus.Server
 }
 
 // NewContext builds a new Context instance
@@ -37,6 +35,5 @@ func NewContext(
 		Database:       db,
 		Modules:        modules,
 		Logger:         logger,
-		Prometheus:     prometheus.NewServer(config.Monitoring),
 	}
 }