tmemetrics

Documentation

Overview

Package tmemetrics contains the internals for tmengine metrics.

Index

• type Collector
  • func NewCollector(ctx context.Context, bufSize int, outCh chan<- Metrics) *Collector
  • func (c *Collector) UpdateMirror(m MirrorMetrics)
  • func (c *Collector) UpdateStateMachine(m StateMachineMetrics)
  • func (c *Collector) Wait()
• type Metrics
  • func (m Metrics) LogValue() slog.Value
• type MirrorMetrics
• type StateMachineMetrics

Types

type Collector

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

func NewCollector

func NewCollector(ctx context.Context, bufSize int, outCh chan<- Metrics) *Collector

func (*Collector) UpdateMirror

func (c *Collector) UpdateMirror(m MirrorMetrics)

func (*Collector) UpdateStateMachine

func (c *Collector) UpdateStateMachine(m StateMachineMetrics)

func (*Collector) Wait

func (c *Collector) Wait()

type Metrics

type Metrics struct {
	MirrorCommittingHeight uint64
	MirrorCommittingRound  uint32

	MirrorVotingHeight uint64
	MirrorVotingRound  uint32

	StateMachineHeight uint64
	StateMachineRound  uint32
}

Metrics is the set of metrics for an engine. This type is declared here, but aliased in [tmengine].

func (Metrics) LogValue

func (m Metrics) LogValue() slog.Value

type MirrorMetrics

type MirrorMetrics struct {
	// Voting.
	VH uint64
	VR uint32

	// Committing.
	CH uint64
	CR uint32
}

type StateMachineMetrics

type StateMachineMetrics struct {
	H uint64
	R uint32
}