monitoring

package

v0.1.0 Latest Latest Go to latest Published: Sep 24, 2024 License: Apache-2.0 Imports: 3 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/p2p-org/substrate-rpc-proxy

Links

Open Source Insights

Documentation ¶

Constants ¶

View Source

const (
	MetricExtrinsicsBlockGap           = "sub_extrinsics_block_gap"
	MetricExtrinsicsCount              = "sub_extrinsics_seen_count"
	MetricExtrinsicsResubmissionsCount = "sub_extrinsics_resubmitted_count"
	MetricExtrinsicsExpiredCount       = "sub_extrinsics_expired_count"
	MetricExtrinsicsAlreadyAddedCount  = "sub_extrinsics_already_added_count"
	MetricExtrinsicsInvalidCount       = "sub_extrinsics_rejected_by_node_count"
	MetricProxyRPCCalls                = "sub_proxy_rpc_calls"
	MetricProxyEstablishedConnections  = "sub_proxy_established_conn_count"
	MetricProxyRunningRequests         = "sub_proxy_running_requests_count"
	MetricProxyThortleBacklogSize      = "sub_proxy_throttle_available_slots"
	MerticConsumerMessagesInProgress   = "sub_consumer_messages_in_progress"
	MetricUpstreamEndpointsStatus      = "sub_upstream_endpoints"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Observable ¶

type Observable interface {
	GetMonitoringEventTypes() []string
	SetObserver(Observer)
}

type Observer ¶

type Observer interface {
	ProcessEvent(string, float64, ...string)
	Reset(string, ...string)
	Register(Observable)
}

type PrometheusMetrics ¶

type PrometheusMetrics struct {
	ConsumerGap                 prometheus.Histogram
	ExtrinsicsCount             prometheus.Counter
	ResubmissionsCount          prometheus.Counter
	ExpiredCount                prometheus.Counter
	InvalidCount                prometheus.Counter
	AlreadyAddedCount           prometheus.Counter
	ConsumerMessagesInProgress  prometheus.Gauge
	ProxyRPCCalls               *prometheus.HistogramVec
	ProxyEstablishedConnections *prometheus.GaugeVec
	UpstreamEndpointsStatus     *prometheus.GaugeVec
	ProxyThortleBacklogSize     *prometheus.GaugeVec
	ProxyRunningRequests        *prometheus.GaugeVec
}

func (*PrometheusMetrics) ProcessEvent ¶

func (p *PrometheusMetrics) ProcessEvent(name string, value float64, lvs ...string)

func (*PrometheusMetrics) Register ¶

func (p *PrometheusMetrics) Register(t Observable)

func (*PrometheusMetrics) Reset ¶

func (p *PrometheusMetrics) Reset(name string, lvs ...string)

Source Files ¶

View all Source files

monitoring.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL