fallback to log

pkg/solana/logpoller/blocks_sorter.go

@@ -5,20 +5,12 @@ import (
 	"context"
 	"sync"
 
-	"github.com/prometheus/client_golang/prometheus"
-	"github.com/prometheus/client_golang/prometheus/promauto"
-
 	"github.com/smartcontractkit/chainlink-common/pkg/logger"
 	"github.com/smartcontractkit/chainlink-common/pkg/services"
 )
 
 const blocksChBuffer = 16
 
-var promPoolRPCNodeHighestSeenBlock = promauto.NewGaugeVec(prometheus.GaugeOpts{
-	Name: "block_sorter_queue",
-	Help: "The highest seen block for the given RPC node",
-}, []string{})
-
 type blocksSorter struct {
 	// service state management
 	services.Service
@@ -77,8 +69,10 @@ func (p *blocksSorter) readBlocks(ctx context.Context) {
 			}
 
 			p.mu.Lock()
-			promPoolRPCNodeHighestSeenBlock.WithLabelValues().Set(float64(len(p.readyBlocks)))
 			p.readyBlocks[block.SlotNumber] = block
+			if len(p.readyBlocks) >= 1024 {
+				p.lggr.Warnf("Number of ready blocks exceeds is too large: %d", len(p.readyBlocks))
+			}
 			p.mu.Unlock()
 			// try leaving a msg that new block is ready
 			select {
@@ -119,7 +113,6 @@ func (p *blocksSorter) readNextReadyBlock() *Block {
 
 	slotNumber := element.Value.(uint64)
 	block, ok := p.readyBlocks[slotNumber]
-	promPoolRPCNodeHighestSeenBlock.WithLabelValues().Set(float64(len(p.readyBlocks)))
 	if !ok {
 		return nil
 	}