crawler

var (
	// crawler host related metrics
	DefaultLogLevel             = "info"
	DefaultDBEndpoint           = "postgresql://user:password@localhost:5432/ragnodb"
	DefaultHostIP               = "0.0.0.0"
	DefaultHostPort             = 9050
	DefaultMetricsIP            = "localhost"
	DefaultMetricsPort          = 9070
	DefaultMetricsEndpoint      = "metrics"
	DefaultConcurrentDialers    = 150
	DefaultConcurrentPersisters = 2
	DefaultConnTimeout          = 30 * time.Second
	DefaultSnapshotInterval     = 30 * time.Minute
	DefaultIPAPIUrl             = "" /* 169-byte string literal not displayed */
	DefaultDeprecationTime      = 48 * time.Hour
)

var (
	ErrorNone    = "none"
	ErrorUnknown = "unknown"

	ErrorEOF                    = "eof"
	ErrorDisconnectRequested    = "disconnect_requested"
	ErrorDecodeRLPdisconnect    = "rlp_decode_disconnect"
	ErrorUselessPeer            = "useless_peer"
	ErrorBadHandshake           = "bad_handshake"
	ErrorBadHandshake2          = "bad_handshake_code_2"
	ErrorTimeout                = "time_out"
	ErrorSnappyCorruptedInput   = "snappy_input_corrupted"
	ErrorSubprotocol            = "subprotocol_error"
	ErrorConnectionRefused      = "connection_refused"
	ErrorConnectionReset        = "connection_reset_by_peer"
	ErrorTooManyPeers           = "too_many_peers"
	ErrorIOTimeout              = "i/o_timeout"
	ErrorNoRouteToHost          = "no_route_to_host"
	ErrorProtocolNegotiation    = "eth_protocols_negotiation"
	ErrorBadHandshakeDisconnect = "bad_handshake_disconnect"
)

var (

	// List of metrics that we are going to export
	ClientDistribution = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: moduleName,
		Name:      "observed_client_distribution",
		Help:      "Number of nodes using the clients seen",
	},
		[]string{"client"},
	)
	VersionDistribution = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: moduleName,
		Name:      "observed_client_version_distribution",
		Help:      "Number of nodes from each of the client's versions",
	},
		[]string{"client_version"},
	)
	GeoDistribution = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: moduleName,
		Name:      "geographical_distribution",
		Help:      "Number of nodes from each country",
	},
		[]string{"country"},
	)
	NodeDistribution = prometheus.NewGauge(prometheus.GaugeOpts{
		Namespace: moduleName,
		Name:      "node_distribution",
		Help:      "Total number of nodes",
	})
	DeprecatedCount = prometheus.NewGauge(prometheus.GaugeOpts{
		Namespace: moduleName,
		Name:      "deprecated_nodes",
		Help:      "Total number of deprecated nodes",
	})
	OsDistribution = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: moduleName,
		Name:      "os_distribution",
		Help:      "OS distribution of connected nodes",
	},
		[]string{"os"},
	)
	ArchDistribution = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: moduleName,
		Name:      "arch_distribution",
		Help:      "Architecture distribution of the active nodes in the network",
	},
		[]string{"arch"},
	)
	HostedPeers = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: moduleName,
		Name:      "hosted_peers_distribution",
		Help:      "Distribution of nodes that are hosted on non-residential networks",
	},
		[]string{"ip_host"},
	)
	RttDist = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: moduleName,
		Name:      "observed_rtt_distribution",
		Help:      "Distribution of RTT between the crawler and nodes in the network",
	},
		[]string{"secs"},
	)
	IPDist = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: moduleName,
		Name:      "observed_ip_distribution",
		Help:      "Distribution of IPs hosting nodes in the network",
	},
		[]string{"numbernodes"},
	)
)

var KnownErrors = map[string]string{
	ErrorNone:                   "None",
	ErrorEOF:                    "EOF",
	ErrorDisconnectRequested:    "disconnect requested",
	ErrorDecodeRLPdisconnect:    "rlp: expected input list for ethtest.Disconnect",
	ErrorUselessPeer:            "useless peer",
	ErrorBadHandshake:           "bad handshake: ",
	ErrorBadHandshake2:          "bad status handshake code: 2",
	ErrorTimeout:                "connect: connection timed out",
	ErrorSnappyCorruptedInput:   "snappy: corrupt input",
	ErrorSubprotocol:            "subprotocol error",
	ErrorConnectionRefused:      "connect: connection refused",
	ErrorConnectionReset:        "connection reset by peer",
	ErrorTooManyPeers:           "too many peers",
	ErrorIOTimeout:              "i/o timeout",
	ErrorNoRouteToHost:          "connect: no route to host",
	ErrorProtocolNegotiation:    "eth protocols negotiation",
	ErrorBadHandshakeDisconnect: "bad status handshake disconnect: ",
}