consensus

Documentation

Index

• Constants
• Variables
• type AttestationMetric
  • func NewAttestationMetric(url, name string, genesisTime time.Time, ...) *AttestationMetric
  • func (a *AttestationMetric) AggregateResults() string
  • func (a *AttestationMetric) Measure(ctx context.Context)
• type ClientMetric
  • func NewClientMetric(url, name string, healthCondition []metric.HealthCondition[string]) *ClientMetric
  • func (c *ClientMetric) AggregateResults() string
  • func (c *ClientMetric) Measure(ctx context.Context)
• type LatencyMetric
  • func NewLatencyMetric(host, name string, interval time.Duration, ...) *LatencyMetric
  • func (l *LatencyMetric) AggregateResults() string
  • func (l *LatencyMetric) Measure(ctx context.Context)
• type PeerMetric
  • func NewPeerMetric(url, name string, interval time.Duration, ...) *PeerMetric
  • func (p *PeerMetric) AggregateResults() string
  • func (p *PeerMetric) Measure(ctx context.Context)
• type SlotData

Constants

const (
	MissedBlockMeasurement       = "MissedBlock"
	ReceivedBlockMeasurement     = "ReceivedBlock"
	MissedAttestationMeasurement = "MissedAttestation"
	FreshAttestationMeasurement  = "FreshAttestation"
	CorrectnessMeasurement       = "Correctness"
)

const (
	DurationMinMeasurement = "DurationMin"
	DurationP10Measurement = "DurationP10"
	DurationP50Measurement = "DurationP50"
	DurationP90Measurement = "DurationP90"
	DurationMaxMeasurement = "DurationMax"
)

const (
	PeerCountMeasurement = "Count"
)

const (
	VersionMeasurement = "Version"
)

Variables

var (
	UnreadyBlockMeasurement = fmt.Sprintf("UnreadyBlockMeasurement%dms", unreadyBlockDelay/time.Millisecond)
)

Types

type AttestationMetric

type AttestationMetric struct {
	metric.Base[float64]
	// contains filtered or unexported fields
}

func NewAttestationMetric

func NewAttestationMetric(url, name string, genesisTime time.Time, healthCondition []metric.HealthCondition[float64]) *AttestationMetric

func (*AttestationMetric) AggregateResults

func (a *AttestationMetric) AggregateResults() string

func (*AttestationMetric) Measure

func (a *AttestationMetric) Measure(ctx context.Context)

type ClientMetric

type ClientMetric struct {
	metric.Base[string]
	// contains filtered or unexported fields
}

func NewClientMetric

func NewClientMetric(url, name string, healthCondition []metric.HealthCondition[string]) *ClientMetric

func (*ClientMetric) AggregateResults

func (c *ClientMetric) AggregateResults() string

func (*ClientMetric) Measure

func (c *ClientMetric) Measure(ctx context.Context)

type LatencyMetric

type LatencyMetric struct {
	metric.Base[time.Duration]
	// contains filtered or unexported fields
}

func NewLatencyMetric

func NewLatencyMetric(host, name string, interval time.Duration, healthCondition []metric.HealthCondition[time.Duration]) *LatencyMetric

func (*LatencyMetric) AggregateResults

func (l *LatencyMetric) AggregateResults() string

func (*LatencyMetric) Measure

func (l *LatencyMetric) Measure(ctx context.Context)

type PeerMetric

type PeerMetric struct {
	metric.Base[uint32]
	// contains filtered or unexported fields
}

func NewPeerMetric

func NewPeerMetric(url, name string, interval time.Duration, healthCondition []metric.HealthCondition[uint32]) *PeerMetric

func (*PeerMetric) AggregateResults

func (p *PeerMetric) AggregateResults() string

func (*PeerMetric) Measure

func (p *PeerMetric) Measure(ctx context.Context)

type SlotData

type SlotData struct {
	Received  time.Time
	RootBlock phase0.Root
}