go-ethereum/health/check_peers.go
crypto-services 96968b119e Initial cut
2024-02-15 16:25:35 +08:00

24 lines
463 B
Go

package health
import (
"context"
"errors"
"fmt"
"github.com/ethereum/go-ethereum/ethclient"
)
var (
errNotEnoughPeers = errors.New("not enough peers")
)
func checkMinPeers(ec *ethclient.Client, minPeerCount uint) error {
peerCount, err := ec.PeerCount(context.TODO())
if err != nil {
return err
}
if uint64(peerCount) < uint64(minPeerCount) {
return fmt.Errorf("%w: %d (minimum %d)", errNotEnoughPeers, peerCount, minPeerCount)
}
return nil
}