| 279 | } |
| 280 | |
| 281 | func (n *EsNode) initMetricsServer(ctx context.Context, cfg *Config) error { |
| 282 | if !cfg.Metrics.Enabled { |
| 283 | n.lg.Info("Metrics disabled") |
| 284 | return nil |
| 285 | } |
| 286 | n.lg.Info("Starting metrics server", "addr", cfg.Metrics.ListenAddr, "port", cfg.Metrics.ListenPort) |
| 287 | go func() { |
| 288 | if err := n.metrics.Serve(ctx, cfg.Metrics.ListenAddr, cfg.Metrics.ListenPort); err != nil { |
| 289 | n.lg.Crit("Error starting metrics server", "err", err) |
| 290 | } |
| 291 | }() |
| 292 | return nil |
| 293 | } |
| 294 | |
| 295 | func (n *EsNode) initMiner(ctx context.Context, cfg *Config) error { |
| 296 | if cfg.Mining == nil { |