measure

Documentation

Index

• func MarshalDesc(d metrics.Desc) []byte
• func PrintDescJson(d metrics.Desc) string
• type AvgTPS
  • func NewAvgTPS() *AvgTPS
  • func (tat *AvgTPS) GetDesc() metrics.Desc
  • func (tat *AvgTPS) OutputMetricName() string
  • func (tat *AvgTPS) OutputRecord() (perEpochTPS []float64, totalTPS float64)
  • func (tat *AvgTPS) UpdateMeasureRecord(b *pbft.BlockInfoMsg)
• type BlockNumCount
  • func NewBlockNumCount() *BlockNumCount
  • func (ttnc *BlockNumCount) GetDesc() metrics.Desc
  • func (ttnc *BlockNumCount) OutputMetricName() string
  • func (ttnc *BlockNumCount) OutputRecord() ([]float64, float64)
  • func (ttnc *BlockNumCount) UpdateMeasureRecord(b *pbft.BlockInfoMsg)
• type CrossTxRate
  • func NewTestCrossTxRate_Pbft() *CrossTxRate
  • func (tctr *CrossTxRate) GetDesc() metrics.Desc
  • func (tctr *CrossTxRate) OutputMetricName() string
  • func (tctr *CrossTxRate) OutputRecord() (perEpochCTXratio []float64, totCTXratio float64)
  • func (tctr *CrossTxRate) UpdateMeasureRecord(b *pbft.BlockInfoMsg)
• type MeasureModule
  • func GetByName(name string) MeasureModule
• type PCL
  • func NewPCL() *PCL
  • func (tml *PCL) GetDesc() metrics.Desc
  • func (tml *PCL) OutputMetricName() string
  • func (tml *PCL) OutputRecord() (perEpochLatency []float64, totLatency float64)
  • func (tml *PCL) UpdateMeasureRecord(b *pbft.BlockInfoMsg)
• type TCL
  • func NewTCL() *TCL
  • func (tml *TCL) GetDesc() metrics.Desc
  • func (tml *TCL) OutputMetricName() string
  • func (tml *TCL) OutputRecord() (perEpochLatency []float64, totLatency float64)
  • func (tml *TCL) UpdateMeasureRecord(b *pbft.BlockInfoMsg)
• type TxNumCount
  • func NewTxNumCount() *TxNumCount
  • func (ttnc *TxNumCount) GetDesc() metrics.Desc
  • func (ttnc *TxNumCount) OutputMetricName() string
  • func (ttnc *TxNumCount) OutputRecord() (perEpochCTXs []float64, totTxNum float64)
  • func (ttnc *TxNumCount) UpdateMeasureRecord(b *pbft.BlockInfoMsg)

Functions

func MarshalDesc

func MarshalDesc(d metrics.Desc) []byte

func PrintDescJson

func PrintDescJson(d metrics.Desc) string

Types

type AvgTPS

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

func NewAvgTPS

func NewAvgTPS() *AvgTPS

func (*AvgTPS) GetDesc

func (tat *AvgTPS) GetDesc() metrics.Desc

func (*AvgTPS) OutputMetricName

func (tat *AvgTPS) OutputMetricName() string

func (*AvgTPS) OutputRecord

func (tat *AvgTPS) OutputRecord() (perEpochTPS []float64, totalTPS float64)

func (*AvgTPS) UpdateMeasureRecord

func (tat *AvgTPS) UpdateMeasureRecord(b *pbft.BlockInfoMsg)

type BlockNumCount

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

func NewBlockNumCount

func NewBlockNumCount() *BlockNumCount

func (*BlockNumCount) GetDesc

func (ttnc *BlockNumCount) GetDesc() metrics.Desc

func (*BlockNumCount) OutputMetricName

func (ttnc *BlockNumCount) OutputMetricName() string

func (*BlockNumCount) OutputRecord

func (ttnc *BlockNumCount) OutputRecord() ([]float64, float64)

func (*BlockNumCount) UpdateMeasureRecord

func (ttnc *BlockNumCount) UpdateMeasureRecord(b *pbft.BlockInfoMsg)

type CrossTxRate

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

func NewTestCrossTxRate_Pbft

func NewTestCrossTxRate_Pbft() *CrossTxRate

func (*CrossTxRate) GetDesc

func (tctr *CrossTxRate) GetDesc() metrics.Desc

func (*CrossTxRate) OutputMetricName

func (tctr *CrossTxRate) OutputMetricName() string

func (*CrossTxRate) OutputRecord

func (tctr *CrossTxRate) OutputRecord() (perEpochCTXratio []float64, totCTXratio float64)

func (*CrossTxRate) UpdateMeasureRecord

func (tctr *CrossTxRate) UpdateMeasureRecord(b *pbft.BlockInfoMsg)

type MeasureModule

type MeasureModule interface {
	UpdateMeasureRecord(*pbft.BlockInfoMsg)
	OutputMetricName() string
	OutputRecord() ([]float64, float64)
	GetDesc() metrics.Desc
}

func GetByName

func GetByName(name string) MeasureModule

type PCL

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

func NewPCL

func NewPCL() *PCL

func (*PCL) GetDesc

func (tml *PCL) GetDesc() metrics.Desc

func (*PCL) OutputMetricName

func (tml *PCL) OutputMetricName() string

func (*PCL) OutputRecord

func (tml *PCL) OutputRecord() (perEpochLatency []float64, totLatency float64)

func (*PCL) UpdateMeasureRecord

func (tml *PCL) UpdateMeasureRecord(b *pbft.BlockInfoMsg)

type TCL

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

func NewTCL

func NewTCL() *TCL

func (*TCL) GetDesc

func (tml *TCL) GetDesc() metrics.Desc

func (*TCL) OutputMetricName

func (tml *TCL) OutputMetricName() string

func (*TCL) OutputRecord

func (tml *TCL) OutputRecord() (perEpochLatency []float64, totLatency float64)

func (*TCL) UpdateMeasureRecord

func (tml *TCL) UpdateMeasureRecord(b *pbft.BlockInfoMsg)

type TxNumCount

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

to test cross-transaction rate

func NewTxNumCount

func NewTxNumCount() *TxNumCount

func (*TxNumCount) GetDesc

func (ttnc *TxNumCount) GetDesc() metrics.Desc

func (*TxNumCount) OutputMetricName

func (ttnc *TxNumCount) OutputMetricName() string

func (*TxNumCount) OutputRecord

func (ttnc *TxNumCount) OutputRecord() (perEpochCTXs []float64, totTxNum float64)

func (*TxNumCount) UpdateMeasureRecord

func (ttnc *TxNumCount) UpdateMeasureRecord(b *pbft.BlockInfoMsg)