execution

Documentation

Index

• Constants
• 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)

Constants

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

const (
	PeerCountMeasurement = "Count"
)

Types

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)