metric

Documentation

Index

• Constants
• Variables
• func DefaultMetricContext() context.Context
• func GetMetricContext(p context.Context, mk *tag.Key, v string) context.Context
• func GetMetricContextByCID(cid int) context.Context
• func Initialize(w module.Wallet)
• func Inspect(c module.Chain, informal bool) map[string]interface{}
• func NewMetricKey(k string) tag.Key
• func ParseMetricData(r *view.Row, prev interface{}, cnt int) interface{}
• func PrometheusExporter() *prometheus.Exporter
• func RegisterConsensus()
• func RegisterMetricView(m stats.Measure, a *view.Aggregation, tks []tag.Key) *view.View
• func RegisterNetwork()
• func RegisterTransaction()
• func RemoveMetricContext(mk *tag.Key, v string)
• func RemoveMetricContextByCID(cid int)
• func ResetMetricViews()
• type ConsensusMetric
  • func NewConsensusMetric(ctx context.Context) *ConsensusMetric
  • func (m *ConsensusMetric) OnHeight(height int64)
  • func (m *ConsensusMetric) OnRound(round int32)
• type NetworkMetric
  • func NewNetworkMetric(ctx context.Context) *NetworkMetric
  • func (m *NetworkMetric) OnRecv(dest byte, ttl byte, hint byte, protocol uint16, pktLen uint32)
  • func (m *NetworkMetric) OnSend(dest byte, ttl byte, hint byte, protocol uint16, pktLen uint32)
• type TxMetric
  • func NewTransactionMetric(ctx context.Context, t string) *TxMetric
  • func (c *TxMetric) OnAddTx(n int, user bool)
  • func (c *TxMetric) OnCommit(hash []byte, ts time.Time, d time.Duration)
  • func (c *TxMetric) OnDropTx(n int, user bool)
  • func (c *TxMetric) OnFinalize(hash []byte, ts time.Time)
  • func (c *TxMetric) OnRemoveTx(n int, user bool)

Constants

const (
	TxTypePatch  = "patch"
	TxTypeNormal = "normal"
)

Variables

var (
	MetricKeyHostname = NewMetricKey("hostname")
	MetricKeyChain    = NewMetricKey("channel")
)

metric common tag key

Functions

func DefaultMetricContext

func DefaultMetricContext() context.Context

func GetMetricContext

func GetMetricContext(p context.Context, mk *tag.Key, v string) context.Context

func GetMetricContextByCID

func GetMetricContextByCID(cid int) context.Context

func Initialize

func Initialize(w module.Wallet)

func Inspect

func Inspect(c module.Chain, informal bool) map[string]interface{}

func NewMetricKey

func NewMetricKey(k string) tag.Key

func ParseMetricData

func ParseMetricData(r *view.Row, prev interface{}, cnt int) interface{}

func PrometheusExporter

func PrometheusExporter() *prometheus.Exporter

func RegisterConsensus

func RegisterConsensus()

func RegisterMetricView

func RegisterMetricView(m stats.Measure, a *view.Aggregation, tks []tag.Key) *view.View

func RegisterNetwork

func RegisterNetwork()

func RegisterTransaction

func RegisterTransaction()

func RemoveMetricContext

func RemoveMetricContext(mk *tag.Key, v string)

func RemoveMetricContextByCID

func RemoveMetricContextByCID(cid int)

func ResetMetricViews

func ResetMetricViews()

Types

type ConsensusMetric

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

func NewConsensusMetric

func NewConsensusMetric(ctx context.Context) *ConsensusMetric

func (*ConsensusMetric) OnHeight

func (m *ConsensusMetric) OnHeight(height int64)

func (*ConsensusMetric) OnRound

func (m *ConsensusMetric) OnRound(round int32)

type NetworkMetric

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

func NewNetworkMetric

func NewNetworkMetric(ctx context.Context) *NetworkMetric

func (*NetworkMetric) OnRecv

func (m *NetworkMetric) OnRecv(dest byte, ttl byte, hint byte, protocol uint16, pktLen uint32)

func (*NetworkMetric) OnSend

func (m *NetworkMetric) OnSend(dest byte, ttl byte, hint byte, protocol uint16, pktLen uint32)

type TxMetric

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

func NewTransactionMetric

func NewTransactionMetric(ctx context.Context, t string) *TxMetric

func (*TxMetric) OnAddTx

func (c *TxMetric) OnAddTx(n int, user bool)

func (*TxMetric) OnCommit

func (c *TxMetric) OnCommit(hash []byte, ts time.Time, d time.Duration)

func (*TxMetric) OnDropTx

func (c *TxMetric) OnDropTx(n int, user bool)

func (*TxMetric) OnFinalize

func (c *TxMetric) OnFinalize(hash []byte, ts time.Time)

func (*TxMetric) OnRemoveTx

func (c *TxMetric) OnRemoveTx(n int, user bool)