From b0a322671267d5e91a7d8613f3eb94d35e7a6d4e Mon Sep 17 00:00:00 2001 From: Dmytro Haidashenko Date: Mon, 10 Feb 2025 22:01:05 +0100 Subject: [PATCH] fallback to log --- pkg/solana/logpoller/blocks_sorter.go | 13 +++---------- 1 file changed, 3 insertions(+), 10 deletions(-) diff --git a/pkg/solana/logpoller/blocks_sorter.go b/pkg/solana/logpoller/blocks_sorter.go index 5af44d865..d19edd76d 100644 --- a/pkg/solana/logpoller/blocks_sorter.go +++ b/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 }