metrics

Documentation

Index

• Constants
• type ChainMetrics
  • func DefaultChainMetrics() ChainMetrics
• type ConsensusMetrics
• type MempoolMetrics
• type Metrics
  • func New(log *logger.Logger) *Metrics
  • func (m *Metrics) GetNodeConnectionMetrics() nodeconnmetrics.NodeConnectionMetrics
  • func (m *Metrics) NewChainMetrics(chainID *isc.ChainID) ChainMetrics
  • func (m *Metrics) Start(addr string)
  • func (m *Metrics) Stop() error
• type StateManagerMetrics

Constants

const ReadHeaderTimeout = time.Millisecond * 500

Types

type ChainMetrics

type ChainMetrics interface {
	CountMessages()
	CurrentStateIndex(stateIndex uint32)
	MempoolMetrics
	ConsensusMetrics
	StateManagerMetrics
}

func DefaultChainMetrics

func DefaultChainMetrics() ChainMetrics

type ConsensusMetrics

type ConsensusMetrics interface {
	RecordVMRunTime(time.Duration)
	CountVMRuns()
}

type MempoolMetrics

type MempoolMetrics interface {
	CountOffLedgerRequestIn()
	CountOnLedgerRequestIn()
	CountRequestOut()
	RecordRequestProcessingTime(isc.RequestID, time.Duration)
	CountBlocksPerChain()
}

type Metrics

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

func New

func New(log *logger.Logger) *Metrics

func (*Metrics) GetNodeConnectionMetrics

func (m *Metrics) GetNodeConnectionMetrics() nodeconnmetrics.NodeConnectionMetrics

func (*Metrics) NewChainMetrics

func (m *Metrics) NewChainMetrics(chainID *isc.ChainID) ChainMetrics

func (*Metrics) Start

func (m *Metrics) Start(addr string)

func (*Metrics) Stop

func (m *Metrics) Stop() error

type StateManagerMetrics

type StateManagerMetrics interface {
	RecordBlockSize(blockIndex uint32, size float64)
	LastSeenStateIndex(stateIndex uint32)
}