ethereum

package
v0.3.5 Latest Latest
Warning

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

 Go to latest Published: Jan 26, 2026 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	// Execution configuration
	Execution []*execution.Config `yaml:"execution"`
	// Beacon configuration
	Beacon []*beacon.Config `yaml:"beacon"`
}

func (*Config) Validate 

func (c *Config) Validate() error

type Metrics 

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

func GetMetricsInstance added in v0.1.3 

func GetMetricsInstance(namespace, monitor string) *Metrics

GetMetricsInstance returns a metrics instance for the given namespace and monitor For production use, this will return a singleton for each namespace+monitor combination For testing, include a unique suffix in the namespace to avoid collisions.

func (*Metrics) SetNodesTotal 

func (m *Metrics) SetNodesTotal(count float64, labels []string)

type Pool 

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

func NewPool 

func NewPool(ctx context.Context, log logrus.FieldLogger, name string, config *Config) *Pool

func (*Pool) GetHealthyBeaconNode 

func (p *Pool) GetHealthyBeaconNode() *beacon.Node

func (*Pool) GetHealthyBeaconNodes 

func (p *Pool) GetHealthyBeaconNodes() []*beacon.Node

func (*Pool) GetHealthyExecutionNode 

func (p *Pool) GetHealthyExecutionNode() *execution.Node

func (*Pool) GetHealthyExecutionNodes 

func (p *Pool) GetHealthyExecutionNodes() []*execution.Node

func (*Pool) HasBeaconNodes 

func (p *Pool) HasBeaconNodes() bool

func (*Pool) HasExecutionNodes 

func (p *Pool) HasExecutionNodes() bool

func (*Pool) HasHealthyBeaconNodes 

func (p *Pool) HasHealthyBeaconNodes() bool

func (*Pool) HasHealthyExecutionNodes 

func (p *Pool) HasHealthyExecutionNodes() bool

func (*Pool) Start 

func (p *Pool) Start(ctx context.Context)

func (*Pool) UpdateNodeMetrics 

func (p *Pool) UpdateNodeMetrics()

func (*Pool) WaitForHealthyBeaconNode 

func (p *Pool) WaitForHealthyBeaconNode(ctx context.Context) (*beacon.Node, error)

func (*Pool) WaitForHealthyExecutionNode 

func (p *Pool) WaitForHealthyExecutionNode(ctx context.Context) (*execution.Node, error)

Source Files

View all Source files

Directories

Path Synopsis
services
services

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.