collector

Documentation

Index

• Constants
• type BeaconCollector
  • func NewBeaconCollector(bc beacon.Client, ec stader.ExecutionClient, nodeAddress common.Address, ...) *BeaconCollector
  • func (collector *BeaconCollector) Collect(channel chan<- prometheus.Metric)
  • func (collector *BeaconCollector) Describe(channel chan<- *prometheus.Desc)
• type MetricsCacheContainer
  • func NewMetricsCacheContainer() *MetricsCacheContainer
  • func (l *MetricsCacheContainer) GetMetricsContainer() *state.MetricsCache
  • func (l *MetricsCacheContainer) UpdateMetricsContainer(state *state.MetricsCache)
• type NetworkCollector
  • func NewNetworkCollector(bc beacon.Client, ec stader.ExecutionClient, nodeAddress common.Address, ...) *NetworkCollector
  • func (collector *NetworkCollector) Collect(channel chan<- prometheus.Metric)
  • func (collector *NetworkCollector) Describe(channel chan<- *prometheus.Desc)
• type OperatorCollector
  • func NewOperatorCollector(bc beacon.Client, ec stader.ExecutionClient, nodeAddress common.Address, ...) *OperatorCollector
  • func (collector *OperatorCollector) Collect(channel chan<- prometheus.Metric)
  • func (collector *OperatorCollector) Describe(channel chan<- *prometheus.Desc)

Constants

const ActiveValidators = "active_validators" //GetAllActiveValidators _PermissionlessNodeRegistry

const BeaconChainQueuedValidators = "beacon_chain_queued_validators" //BeaconChainQueuedValidators _PermissionlessNodeRegistry

const CPUUsage = "cpu_usage"

const CPUUsageTimeSeries = "cpu_usage_time_series"

const ClaimVaultBalance = "claim_vault_balance"

const ClaimedSocializingPoolELRewards = "claimed_socializing_pool_el_rewards"

const ClaimedSocializingPoolSDrewards = "claimed_socializing_pool_sd_rewards"

const CumulativePenalty = "cumulative_penalty"

const DiskSpaceUsed = "disk_space_used"

const ECPeers = "ec_peers"

const EthCollateral = "eth_collateral"

const ExitingValidators = "exiting_validators" //GetValidatorStatus

const FrontRunValidators = "front_run_validators" //GetValidatorStatus

const FundsSettledValidators = "funds_settled_validators" //GetValidatorStatus

const HeathFactor = "heath_factor"

const IOWaiTTime = "io_wait_time"

const InitializedValidators = "initialized_validators" //GetValidatorStatus

const InvalidSignatureValidators = "invalid_signature_validators" //GetValidatorStatus

const LiquidationStatus = "liquidation_status"

const LockedEth = "eth_locked"

const NBCPeers = "nbc_peers"

const NetworkLatency = "network_latency"

const NetworkUsage = "network_usage"

const NextRewardCycleTime = "next_reward_cycle_time"

const NodeSub = "node_health"

Node Health => stader_node_health+ key

const OperatorSub = "operator"

Validator rewards & performance => stader_validator_rewards_performance + key

const RAMUsage = "ram_usage"

const RAMUsageTimeSeries = "ram_usage_time_series"

const SDUtilized = "sd_utilized"

const SDUtilizedInterest = "sd_utilized_interest"

const SSDLatency = "ssd_latency"

const SdCollateral = "sd_collateral"

const SdCollateralInEth = "sd_collateral_in_eth"

const SdCollateralPct = "sd_collateral_pct"

const SlashedValidators = "slashed_validators" //GetValidatorStatus

const StaderQueuedValidators = "stader_queued_validators"

const TotalETHBonded = "total_eth_bonded"

const TotalIO = "total_io"

const TotalSDBonded = "total_sd_bonded"

const TotalSDSelfBonded = "total_sd_self_bonded"

const TotalSDUtilizationPosition = "sd_utility_position"

const UnclaimedCLRewards = "unclaimed_cl_rewards"

const UnclaimedNonSocializingPoolELRewards = "unclaimed_non_socializing_pool_el_rewards"

const UnclaimedSocializingPoolELRewards = "unclaimed_socializing_pool_el_rewards"

const UnclaimedSocializingPoolSdRewards = "unclaimed_socializing_pool_sd_rewards"

const WithdrawnValidators = "withdrawn_validators" //GetValidatorStatus

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