collectors

package
v2.0.0-prerelease3 Latest Latest
Warning

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

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

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(logger *log.Logger, ctx context.Context, sp *services.ServiceProvider, stateLocker *StateLocker) *BeaconCollector

Create a new BeaconCollector instance

func (*BeaconCollector) Collect

func (c *BeaconCollector) Collect(channel chan<- prometheus.Metric)

Collect the latest metric values and pass them to Prometheus

func (*BeaconCollector) Describe

func (c *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(logger *log.Logger, sp *services.ServiceProvider, stateLocker *StateLocker) *DemandCollector

Create a new DemandCollector instance

func (*DemandCollector) Collect

func (c *DemandCollector) Collect(channel chan<- prometheus.Metric)

Collect the latest metric values and pass them to Prometheus

func (*DemandCollector) Describe

func (c *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(logger *log.Logger, ctx context.Context, sp *services.ServiceProvider, stateLocker *StateLocker) *NodeCollector

Create a new NodeCollector instance

func (*NodeCollector) Collect

func (c *NodeCollector) Collect(channel chan<- prometheus.Metric)

Collect the latest metric values and pass them to Prometheus

func (*NodeCollector) Describe

func (c *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(logger *log.Logger, sp *services.ServiceProvider, stateLocker *StateLocker) *OdaoCollector

Create a new OdaoCollector instance

func (*OdaoCollector) Collect

func (c *OdaoCollector) Collect(channel chan<- prometheus.Metric)

Collect the latest metric values and pass them to Prometheus

func (*OdaoCollector) Describe

func (c *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(logger *log.Logger, sp *services.ServiceProvider, stateLocker *StateLocker) *PerformanceCollector

Create a new PerformanceCollector instance

func (*PerformanceCollector) Collect

func (c *PerformanceCollector) Collect(channel chan<- prometheus.Metric)

Collect the latest metric values and pass them to Prometheus

func (*PerformanceCollector) Describe

func (c *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(logger *log.Logger, sp *services.ServiceProvider, stateLocker *StateLocker) *RplCollector

Create a new RplCollector instance

func (*RplCollector) Collect

func (c *RplCollector) Collect(channel chan<- prometheus.Metric)

Collect the latest metric values and pass them to Prometheus

func (*RplCollector) Describe

func (c *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(logger *log.Logger, sp *services.ServiceProvider, stateLocker *StateLocker) *SmoothingPoolCollector

Create a new SmoothingPoolCollector instance

func (*SmoothingPoolCollector) Collect

func (c *SmoothingPoolCollector) Collect(channel chan<- prometheus.Metric)

Collect the latest metric values and pass them to Prometheus

func (*SmoothingPoolCollector) Describe

func (c *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(logger *log.Logger, sp *services.ServiceProvider) *SnapshotCollector

Create a new SnapshotCollector instance

func (*SnapshotCollector) Collect

func (c *SnapshotCollector) Collect(channel chan<- prometheus.Metric)

Collect the latest metric values and pass them to Prometheus

func (*SnapshotCollector) Describe

func (c *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(logger *log.Logger, sp *services.ServiceProvider, stateLocker *StateLocker) *SupplyCollector

Create a new PerformanceCollector instance

func (*SupplyCollector) Collect

func (c *SupplyCollector) Collect(channel chan<- prometheus.Metric)

Collect the latest metric values and pass them to Prometheus

func (*SupplyCollector) Describe

func (c *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(logger *log.Logger, sp *services.ServiceProvider, stateLocker *StateLocker) *TrustedNodeCollector

Create a new TrustedNodeCollector instance

func (*TrustedNodeCollector) Collect

func (c *TrustedNodeCollector) Collect(channel chan<- prometheus.Metric)

Collect the latest metric values and pass them to Prometheus

func (*TrustedNodeCollector) Describe

func (c *TrustedNodeCollector) 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