metrics

Documentation

Index

• type BlockWALMetric
  • func (m *BlockWALMetric) IncFailedReads()
  • func (m *BlockWALMetric) IncFailedWrites()
  • func (m *BlockWALMetric) IncSegments()
• type BlockWALMetrics
  • func NewBlockWALMetrics() *BlockWALMetrics
  • func (m *BlockWALMetrics) PrometheusCollectors() []prometheus.Collector
• type ChainMetric
  • func (c *ChainMetric) IncBlocksPerChain()
  • func (c *ChainMetric) IncMessagesReceived()
  • func (c *ChainMetric) IncRequestsAckMessages()
  • func (c *ChainMetric) IncRequestsProcessed()
  • func (c *ChainMetric) IncRequestsReceived(req isc.Request)
  • func (c *ChainMetric) IncVMRunsCounter()
  • func (c *ChainMetric) SetBlockSize(blockSize float64)
  • func (c *ChainMetric) SetCurrentStateIndex(stateIndex uint32)
  • func (c *ChainMetric) SetLastSeenStateIndex(stateIndex uint32)
  • func (c *ChainMetric) SetRequestProcessingTime(duration time.Duration)
  • func (c *ChainMetric) SetVMRunTime(duration time.Duration)
• type ChainMetrics
  • func NewChainMetrics(nodeConnectionMetrics nodeconnmetrics.NodeConnectionMetrics) *ChainMetrics
  • func (m *ChainMetrics) GetNodeConnectionMetrics() nodeconnmetrics.NodeConnectionMetrics
  • func (m *ChainMetrics) PrometheusCollectors() []prometheus.Collector
• type IBlockWALMetric
  • func NewBlockWALMetric(blockWALMetrics *BlockWALMetrics, chainID isc.ChainID) IBlockWALMetric
  • func NewEmptyBlockWALMetric() IBlockWALMetric
• type IChainMetric
  • func NewChainMetric(chainMetrics *ChainMetrics, chainID isc.ChainID) IChainMetric
  • func NewEmptyChainMetric() IChainMetric
• type IConsensusMetrics
• type IMempoolMetrics
• type IStateManagerMetrics

Types

type BlockWALMetric

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

func (*BlockWALMetric) IncFailedReads

func (m *BlockWALMetric) IncFailedReads()

func (*BlockWALMetric) IncFailedWrites

func (m *BlockWALMetric) IncFailedWrites()

func (*BlockWALMetric) IncSegments

func (m *BlockWALMetric) IncSegments()

type BlockWALMetrics

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

func NewBlockWALMetrics

func NewBlockWALMetrics() *BlockWALMetrics

func (*BlockWALMetrics) PrometheusCollectors

func (m *BlockWALMetrics) PrometheusCollectors() []prometheus.Collector

type ChainMetric

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

func (*ChainMetric) IncBlocksPerChain

func (c *ChainMetric) IncBlocksPerChain()

func (*ChainMetric) IncMessagesReceived

func (c *ChainMetric) IncMessagesReceived()

func (*ChainMetric) IncRequestsAckMessages

func (c *ChainMetric) IncRequestsAckMessages()

func (*ChainMetric) IncRequestsProcessed

func (c *ChainMetric) IncRequestsProcessed()

func (*ChainMetric) IncRequestsReceived

func (c *ChainMetric) IncRequestsReceived(req isc.Request)

func (*ChainMetric) IncVMRunsCounter

func (c *ChainMetric) IncVMRunsCounter()

func (*ChainMetric) SetBlockSize

func (c *ChainMetric) SetBlockSize(blockSize float64)

func (*ChainMetric) SetCurrentStateIndex

func (c *ChainMetric) SetCurrentStateIndex(stateIndex uint32)

func (*ChainMetric) SetLastSeenStateIndex

func (c *ChainMetric) SetLastSeenStateIndex(stateIndex uint32)

func (*ChainMetric) SetRequestProcessingTime

func (c *ChainMetric) SetRequestProcessingTime(duration time.Duration)

func (*ChainMetric) SetVMRunTime

func (c *ChainMetric) SetVMRunTime(duration time.Duration)

type ChainMetrics

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

ChainMetrics holds all metrics for all chains per chain

func NewChainMetrics

func NewChainMetrics(nodeConnectionMetrics nodeconnmetrics.NodeConnectionMetrics) *ChainMetrics

func (*ChainMetrics) GetNodeConnectionMetrics

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

func (*ChainMetrics) PrometheusCollectors

func (m *ChainMetrics) PrometheusCollectors() []prometheus.Collector

type IBlockWALMetric

type IBlockWALMetric interface {
	IncFailedWrites()
	IncFailedReads()
	IncSegments()
}

func NewBlockWALMetric

func NewBlockWALMetric(blockWALMetrics *BlockWALMetrics, chainID isc.ChainID) IBlockWALMetric

func NewEmptyBlockWALMetric

func NewEmptyBlockWALMetric() IBlockWALMetric

type IChainMetric

type IChainMetric interface {
	IStateManagerMetrics
	IConsensusMetrics
	IMempoolMetrics
	IncRequestsAckMessages()
	IncMessagesReceived()
	SetCurrentStateIndex(stateIndex uint32)
}

func NewChainMetric

func NewChainMetric(chainMetrics *ChainMetrics, chainID isc.ChainID) IChainMetric

func NewEmptyChainMetric

func NewEmptyChainMetric() IChainMetric

type IConsensusMetrics

type IConsensusMetrics interface {
	SetVMRunTime(time.Duration)
	IncVMRunsCounter()
}

type IMempoolMetrics

type IMempoolMetrics interface {
	IncRequestsReceived(isc.Request)
	IncRequestsProcessed()
	SetRequestProcessingTime(time.Duration)
	IncBlocksPerChain()
}

type IStateManagerMetrics

type IStateManagerMetrics interface {
	SetBlockSize(size float64)
	SetLastSeenStateIndex(stateIndex uint32)
}