collector

package
v1.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 3, 2024 License: GPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const ActiveValidators = "active_validators" //GetAllActiveValidators _PermissionlessNodeRegistry
View Source
const BeaconChainQueuedValidators = "beacon_chain_queued_validators" //BeaconChainQueuedValidators _PermissionlessNodeRegistry
View Source
const CPUUsage = "cpu_usage"
View Source
const CPUUsageTimeSeries = "cpu_usage_time_series"
View Source
const ClaimVaultBalance = "claim_vault_balance"
View Source
const ClaimedSocializingPoolELRewards = "claimed_socializing_pool_el_rewards"
View Source
const ClaimedSocializingPoolSDrewards = "claimed_socializing_pool_sd_rewards"
View Source
const CumulativePenalty = "cumulative_penalty"
View Source
const DiskSpaceUsed = "disk_space_used"
View Source
const ECPeers = "ec_peers"
View Source
const EthCollateral = "eth_collateral"
View Source
const ExitingValidators = "exiting_validators" //GetValidatorStatus
View Source
const FrontRunValidators = "front_run_validators" //GetValidatorStatus
View Source
const FundsSettledValidators = "funds_settled_validators" //GetValidatorStatus
View Source
const HeathFactor = "heath_factor"
View Source
const IOWaiTTime = "io_wait_time"
View Source
const InitializedValidators = "initialized_validators" //GetValidatorStatus
View Source
const InvalidSignatureValidators = "invalid_signature_validators" //GetValidatorStatus
View Source
const LiquidationStatus = "liquidation_status"
View Source
const LockedEth = "eth_locked"
View Source
const NBCPeers = "nbc_peers"
View Source
const NetworkLatency = "network_latency"
View Source
const NetworkUsage = "network_usage"
View Source
const NextRewardCycleTime = "next_reward_cycle_time"
View Source
const NodeSub = "node_health"

Node Health => stader_node_health+ key

View Source
const OperatorSub = "operator"

Validator rewards & performance => stader_validator_rewards_performance + key

View Source
const RAMUsage = "ram_usage"
View Source
const RAMUsageTimeSeries = "ram_usage_time_series"
View Source
const SDUtilized = "sd_utilized"
View Source
const SDUtilizedInterest = "sd_utilized_interest"
View Source
const SSDLatency = "ssd_latency"
View Source
const SdCollateral = "sd_collateral"
View Source
const SdCollateralInEth = "sd_collateral_in_eth"
View Source
const SdCollateralPct = "sd_collateral_pct"
View Source
const SlashedValidators = "slashed_validators" //GetValidatorStatus
View Source
const StaderQueuedValidators = "stader_queued_validators"
View Source
const TotalETHBonded = "total_eth_bonded"
View Source
const TotalIO = "total_io"
View Source
const TotalSDBonded = "total_sd_bonded"
View Source
const TotalSDSelfBonded = "total_sd_self_bonded"
View Source
const TotalSDUtilizationPosition = "sd_utility_position"
View Source
const UnclaimedCLRewards = "unclaimed_cl_rewards"
View Source
const UnclaimedNonSocializingPoolELRewards = "unclaimed_non_socializing_pool_el_rewards"
View Source
const UnclaimedSocializingPoolELRewards = "unclaimed_socializing_pool_el_rewards"
View Source
const UnclaimedSocializingPoolSdRewards = "unclaimed_socializing_pool_sd_rewards"
View Source
const WithdrawnValidators = "withdrawn_validators" //GetValidatorStatus

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(bc beacon.Client, ec stader.ExecutionClient, nodeAddress common.Address, stateLocker *MetricsCacheContainer) *BeaconCollector

Create a new NetworkCollector 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 MetricsCacheContainer

type MetricsCacheContainer struct {
	// contains filtered or unexported fields
}

func NewMetricsCacheContainer

func NewMetricsCacheContainer() *MetricsCacheContainer

func (*MetricsCacheContainer) GetMetricsContainer

func (l *MetricsCacheContainer) GetMetricsContainer() *state.MetricsCache

func (*MetricsCacheContainer) UpdateMetricsContainer

func (l *MetricsCacheContainer) UpdateMetricsContainer(state *state.MetricsCache)

type NetworkCollector

type NetworkCollector struct {
	// The current SD price in Eth
	SdPrice *prometheus.Desc

	// The current Eth price in SD
	EthPrice *prometheus.Desc

	// The total number of validators created
	TotalValidatorsCreated *prometheus.Desc

	// The total number of validators active on beacon chain
	TotalActiveValidators *prometheus.Desc

	// The total number of validators waiting to receive the 28eth
	TotalQueuedValidators *prometheus.Desc

	// The total number of registered operators
	TotalOperators *prometheus.Desc

	// Total SD staked as collateral
	TotalStakedSd *prometheus.Desc

	// Total Eth staked by Users
	TotalStakedEthByUsers *prometheus.Desc

	// Total Eth staked by NOs
	TotalStakedEthByNos *prometheus.Desc

	// Total EthX supply
	TotalEthxSupply *prometheus.Desc

	// The next block at which Sd and socializing el rewards wil be given
	NextRewardBlock *prometheus.Desc

	// The operator collateral ratio in ETH
	CollateralRatio *prometheus.Desc

	// The operator collateral ratio in SD
	CollateralRatioInSd *prometheus.Desc

	// The max amount of sd value that can be staked to get rewards
	MaxEthThreshold *prometheus.Desc

	// The min amount of sd value that can be staked to get rewards
	MinEthThreshold *prometheus.Desc

	// The utilize amount + fee
	SdUtilityPoolBalance *prometheus.Desc

	// Total amount of outstanding SD utilized
	TotalSDUtilized *prometheus.Desc

	TotalValueLocledSDUtilization *prometheus.Desc
	// contains filtered or unexported fields
}

Represents the collector for the stader network metrics

func NewNetworkCollector

func NewNetworkCollector(bc beacon.Client, ec stader.ExecutionClient, nodeAddress common.Address, stateLocker *MetricsCacheContainer) *NetworkCollector

Create a new NetworkCollector instance

func (*NetworkCollector) Collect

func (collector *NetworkCollector) Collect(channel chan<- prometheus.Metric)

Collect the latest metric values and pass them to Prometheus

func (*NetworkCollector) Describe

func (collector *NetworkCollector) Describe(channel chan<- *prometheus.Desc)

Write metric descriptions to the Prometheus channel

type OperatorCollector

type OperatorCollector struct {
	ActiveValidators                     *prometheus.Desc
	BeaconChainQueuedValidators          *prometheus.Desc
	StaderQueuedValidators               *prometheus.Desc
	SlashedValidators                    *prometheus.Desc
	ExitingValidators                    *prometheus.Desc
	WithdrawnValidators                  *prometheus.Desc
	FrontRunValidators                   *prometheus.Desc
	InvalidSignatureValidators           *prometheus.Desc
	IntializedValidators                 *prometheus.Desc
	FundsSettledValidators               *prometheus.Desc
	UnclaimedClRewards                   *prometheus.Desc
	UnclaimedNonSocializingPoolElRewards *prometheus.Desc
	CumulativePenalty                    *prometheus.Desc
	UnclaimedSocializingPoolELRewards    *prometheus.Desc
	UnclaimedSocializingPoolSdRewards    *prometheus.Desc
	ClaimedSocializingPoolSdRewards      *prometheus.Desc
	ClaimedSocializingPoolElRewards      *prometheus.Desc
	TotalSdCollateral                    *prometheus.Desc
	TotalSdCollateralInEth               *prometheus.Desc
	TotalEthColateral                    *prometheus.Desc
	TotalSDUtilizationPosition           *prometheus.Desc
	TotalSDSelfBond                      *prometheus.Desc
	TotalSDUtilized                      *prometheus.Desc
	TotalSDUtilizedInterest              *prometheus.Desc
	SdCollateralPct                      *prometheus.Desc
	LockedEth                            *prometheus.Desc
	HealthFactor                         *prometheus.Desc
	LiquidationStatus                    *prometheus.Desc
	ClaimVaultBalance                    *prometheus.Desc

	SDSelfBond *prometheus.Desc
	// contains filtered or unexported fields
}

Represents the collector for the stader network metrics

func NewOperatorCollector

func NewOperatorCollector(
	bc beacon.Client,
	ec stader.ExecutionClient,
	nodeAddress common.Address,
	stateLocker *MetricsCacheContainer,
) *OperatorCollector

Create a new NetworkCollector instance

func (*OperatorCollector) Collect

func (collector *OperatorCollector) Collect(channel chan<- prometheus.Metric)

Collect the latest metric values and pass them to Prometheus

func (*OperatorCollector) Describe

func (collector *OperatorCollector) Describe(channel chan<- *prometheus.Desc)

Write metric descriptions to the Prometheus channel

Jump to

Keyboard shortcuts

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