Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BeaconCollector ¶
type BeaconCollector struct {
// contains filtered or unexported fields
}
Represents the collector for the beaconchain metrics
func NewBeaconCollector ¶
func NewBeaconCollector(rp *rocketpool.RocketPool, bc beacon.Client, ec rocketpool.ExecutionClient, nodeAddress common.Address, stateLocker *StateLocker) *BeaconCollector
Create a new BeaconCollector instance
func (*BeaconCollector) Collect ¶
func (collector *BeaconCollector) Collect(channel chan<- prometheus.Metric)
Collect the latest metric values and pass them to Prometheus
func (*BeaconCollector) Describe ¶
func (collector *BeaconCollector) Describe(channel chan<- *prometheus.Desc)
Write metric descriptions to the Prometheus channel
type DemandCollector ¶
type DemandCollector struct {
// contains filtered or unexported fields
}
Represents the collector for the Demand metrics
func NewDemandCollector ¶
func NewDemandCollector(rp *rocketpool.RocketPool, stateLocker *StateLocker) *DemandCollector
Create a new DemandCollector instance
func (*DemandCollector) Collect ¶
func (collector *DemandCollector) Collect(channel chan<- prometheus.Metric)
Collect the latest metric values and pass them to Prometheus
func (*DemandCollector) Describe ¶
func (collector *DemandCollector) Describe(channel chan<- *prometheus.Desc)
Write metric descriptions to the Prometheus channel
type NodeCollector ¶
type NodeCollector struct {
// contains filtered or unexported fields
}
Represents the collector for the user's node
func NewNodeCollector ¶
func NewNodeCollector(rp *rocketpool.RocketPool, bc beacon.Client, nodeAddress common.Address, cfg *config.RocketPoolConfig, stateLocker *StateLocker) *NodeCollector
Create a new NodeCollector instance
func (*NodeCollector) Collect ¶
func (collector *NodeCollector) Collect(channel chan<- prometheus.Metric)
Collect the latest metric values and pass them to Prometheus
func (*NodeCollector) Describe ¶
func (collector *NodeCollector) Describe(channel chan<- *prometheus.Desc)
Write metric descriptions to the Prometheus channel
type OdaoCollector ¶
type OdaoCollector struct {
// contains filtered or unexported fields
}
Represents the collector for the ODAO metrics
func NewOdaoCollector ¶
func NewOdaoCollector(rp *rocketpool.RocketPool, stateLocker *StateLocker) *OdaoCollector
Create a new DemandCollector instance
func (*OdaoCollector) Collect ¶
func (collector *OdaoCollector) Collect(channel chan<- prometheus.Metric)
Collect the latest metric values and pass them to Prometheus
func (*OdaoCollector) Describe ¶
func (collector *OdaoCollector) Describe(channel chan<- *prometheus.Desc)
Write metric descriptions to the Prometheus channel
type PerformanceCollector ¶
type PerformanceCollector struct {
// contains filtered or unexported fields
}
Represents the collector for the Performance metrics
func NewPerformanceCollector ¶
func NewPerformanceCollector(rp *rocketpool.RocketPool, stateLocker *StateLocker) *PerformanceCollector
Create a new PerformanceCollector instance
func (*PerformanceCollector) Collect ¶
func (collector *PerformanceCollector) Collect(channel chan<- prometheus.Metric)
Collect the latest metric values and pass them to Prometheus
func (*PerformanceCollector) Describe ¶
func (collector *PerformanceCollector) Describe(channel chan<- *prometheus.Desc)
Write metric descriptions to the Prometheus channel
type RplCollector ¶
type RplCollector struct {
// contains filtered or unexported fields
}
Represents the collector for the RPL metrics
func NewRplCollector ¶
func NewRplCollector(rp *rocketpool.RocketPool, cfg *config.RocketPoolConfig, stateLocker *StateLocker) *RplCollector
Create a new RplCollector instance
func (*RplCollector) Collect ¶
func (collector *RplCollector) Collect(channel chan<- prometheus.Metric)
Collect the latest metric values and pass them to Prometheus
func (*RplCollector) Describe ¶
func (collector *RplCollector) Describe(channel chan<- *prometheus.Desc)
Write metric descriptions to the Prometheus channel
type SmoothingPoolCollector ¶
type SmoothingPoolCollector struct {
// contains filtered or unexported fields
}
Represents the collector for Smoothing Pool metrics
func NewSmoothingPoolCollector ¶
func NewSmoothingPoolCollector(rp *rocketpool.RocketPool, ec *services.ExecutionClientManager, stateLocker *StateLocker) *SmoothingPoolCollector
Create a new SmoothingPoolCollector instance
func (*SmoothingPoolCollector) Collect ¶
func (collector *SmoothingPoolCollector) Collect(channel chan<- prometheus.Metric)
Collect the latest metric values and pass them to Prometheus
func (*SmoothingPoolCollector) Describe ¶
func (collector *SmoothingPoolCollector) Describe(channel chan<- *prometheus.Desc)
Write metric descriptions to the Prometheus channel
type SnapshotCollector ¶
type SnapshotCollector struct {
// contains filtered or unexported fields
}
Represents the collector for Snapshot metrics
func NewSnapshotCollector ¶
func NewSnapshotCollector(rp *rocketpool.RocketPool, cfg *config.RocketPoolConfig, nodeAddress common.Address, delegateAddress common.Address) *SnapshotCollector
Create a new SnapshotCollector instance
func (*SnapshotCollector) Collect ¶
func (collector *SnapshotCollector) Collect(channel chan<- prometheus.Metric)
Collect the latest metric values and pass them to Prometheus
func (*SnapshotCollector) Describe ¶
func (collector *SnapshotCollector) Describe(channel chan<- *prometheus.Desc)
Write metric descriptions to the Prometheus channel
type StateLocker ¶
type StateLocker struct {
// contains filtered or unexported fields
}
func NewStateLocker ¶
func NewStateLocker() *StateLocker
func (*StateLocker) GetState ¶
func (l *StateLocker) GetState() *state.NetworkState
func (*StateLocker) GetTotalEffectiveRPLStake ¶
func (l *StateLocker) GetTotalEffectiveRPLStake() *big.Int
func (*StateLocker) UpdateState ¶
func (l *StateLocker) UpdateState(state *state.NetworkState, totalEffectiveStake *big.Int)
type SupplyCollector ¶
type SupplyCollector struct {
// contains filtered or unexported fields
}
Represents the collector for the Supply metrics
func NewSupplyCollector ¶
func NewSupplyCollector(rp *rocketpool.RocketPool, stateLocker *StateLocker) *SupplyCollector
Create a new PerformanceCollector instance
func (*SupplyCollector) Collect ¶
func (collector *SupplyCollector) Collect(channel chan<- prometheus.Metric)
Collect the latest metric values and pass them to Prometheus
func (*SupplyCollector) Describe ¶
func (collector *SupplyCollector) Describe(channel chan<- *prometheus.Desc)
Write metric descriptions to the Prometheus channel
type TrustedNodeCollector ¶
type TrustedNodeCollector struct {
// contains filtered or unexported fields
}
Represents the collector for the user's trusted node
func NewTrustedNodeCollector ¶
func NewTrustedNodeCollector(rp *rocketpool.RocketPool, bc beacon.Client, nodeAddress common.Address, cfg *config.RocketPoolConfig, stateLocker *StateLocker) *TrustedNodeCollector
Create a new NodeCollector instance
func (*TrustedNodeCollector) Collect ¶
func (collector *TrustedNodeCollector) Collect(channel chan<- prometheus.Metric)
Collect the latest metric values and pass them to Prometheus
func (*TrustedNodeCollector) Describe ¶
func (collector *TrustedNodeCollector) Describe(channel chan<- *prometheus.Desc)
Write metric descriptions to the Prometheus channel
Source Files