metrics

Documentation

Index

• func InitMetrics(cfg config.CollecterServiceConfig, mConfig config.MetricsConfig) (*push.Pusher, error)
• func PushMetrics(ctx context.Context, pusher *push.Pusher, pmetrics *PrometheusMetrics)
• type PrometheusMetrics
  • func NewPrometheusMetrics() *PrometheusMetrics
  • func (m *PrometheusMetrics) AddInPackets(attestorName string, chain string, destinationChain string)
  • func (m *PrometheusMetrics) DeliveredPackets(attestorName string, sourceChain string, destinationChain string)
  • func (m *PrometheusMetrics) HashedAndSignedPacket(attestorName string, sourceChain string, destinationChain string)
  • func (m *PrometheusMetrics) SetAttestorHealth(attestorName string, chain string, value float64)
  • func (m *PrometheusMetrics) SetDBServiceHeatlh(attestorName string, value float64)
  • func (m *PrometheusMetrics) SetSigningServiceHealth(attestorName string, value float64)
  • func (m *PrometheusMetrics) StartVersion(attestorName string, version string)
  • func (m *PrometheusMetrics) StoredSequenceNo(attestorName string, sourceChain string, destinationChain string, ...)
  • func (m *PrometheusMetrics) UpdateAleoRPCStatus(attestorName string, sourceChain string, value float64)
  • func (m *PrometheusMetrics) UpdateEthRPCStatus(attestorName string, sourceChain string, value float64)
  • func (m *PrometheusMetrics) UpdateProcessedSequence(attestorName string, sourceChain string, destinationChain string, ...)

Functions

func InitMetrics

func InitMetrics(cfg config.CollecterServiceConfig, mConfig config.MetricsConfig) (*push.Pusher, error)

func PushMetrics

func PushMetrics(ctx context.Context, pusher *push.Pusher, pmetrics *PrometheusMetrics)

Types

type PrometheusMetrics

type PrometheusMetrics struct {
	Registry                     *prometheus.Registry
	InPacketsCounter             *prometheus.CounterVec
	DeliveredPacketsCounter      *prometheus.CounterVec
	HashedAndSignedPacketCounter *prometheus.CounterVec
	AttestorService              *prometheus.GaugeVec
	DBService                    *prometheus.GaugeVec
	SigningService               *prometheus.GaugeVec
	VersionInfo                  *prometheus.GaugeVec
	StartSequenceNo              *prometheus.GaugeVec
	ProcessedSequenceNo          *prometheus.GaugeVec
	AleoRPCSignal                *prometheus.GaugeVec
	EhtereumRPCSignal            *prometheus.GaugeVec
}

func NewPrometheusMetrics

func NewPrometheusMetrics() *PrometheusMetrics

func (*PrometheusMetrics) AddInPackets

func (m *PrometheusMetrics) AddInPackets(attestorName string, chain string, destinationChain string)

func (*PrometheusMetrics) DeliveredPackets

func (m *PrometheusMetrics) DeliveredPackets(attestorName string, sourceChain string, destinationChain string)

func (*PrometheusMetrics) HashedAndSignedPacket

func (m *PrometheusMetrics) HashedAndSignedPacket(attestorName string, sourceChain string, destinationChain string)

func (*PrometheusMetrics) SetAttestorHealth

func (m *PrometheusMetrics) SetAttestorHealth(attestorName string, chain string, value float64)

func (*PrometheusMetrics) SetDBServiceHeatlh

func (m *PrometheusMetrics) SetDBServiceHeatlh(attestorName string, value float64)

func (*PrometheusMetrics) SetSigningServiceHealth

func (m *PrometheusMetrics) SetSigningServiceHealth(attestorName string, value float64)

func (*PrometheusMetrics) StartVersion

func (m *PrometheusMetrics) StartVersion(attestorName string, version string)

func (*PrometheusMetrics) StoredSequenceNo

func (m *PrometheusMetrics) StoredSequenceNo(attestorName string, sourceChain string, destinationChain string, sequenceNo float64)

func (*PrometheusMetrics) UpdateAleoRPCStatus

func (m *PrometheusMetrics) UpdateAleoRPCStatus(attestorName string, sourceChain string, value float64)

func (*PrometheusMetrics) UpdateEthRPCStatus

func (m *PrometheusMetrics) UpdateEthRPCStatus(attestorName string, sourceChain string, value float64)

func (*PrometheusMetrics) UpdateProcessedSequence

func (m *PrometheusMetrics) UpdateProcessedSequence(attestorName string, sourceChain string, destinationChain string, sequenceNo float64)