metric

Documentation

Index

• Constants
• Variables
• func BeforeExport()
• func DefaultMetricContext() context.Context
• func GetCIDFromMetricContext(ctx context.Context) (int, bool)
• 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 RegisterBeforeExportFunc(f func())
• func RegisterConsensus()
• func RegisterJsonrpc()
• 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 Duration
• type Durations
  • func NewDurations(size int) *Durations
  • func (ds *Durations) Add(ts time.Time) *Duration
  • func (ds *Durations) Avg() time.Duration
  • func (ds *Durations) Count() int
  • func (ds *Durations) Remove(expire time.Duration)
  • func (ds *Durations) Size() int
  • func (ds *Durations) Sum() int64
• type JsonrpcMeasure
  • func (m *JsonrpcMeasure) Remove(expire time.Duration)
  • func (m *JsonrpcMeasure) RemoveAndRecord(ctx context.Context, ts time.Time, expire time.Duration)
• type JsonrpcMetric
  • func NewJsonrpcMetric(expire time.Duration, durationsSize int, useDefault bool) *JsonrpcMetric
  • func (m *JsonrpcMetric) EnsureMeasure(ctx context.Context, ms *measure) *JsonrpcMeasure
  • func (m *JsonrpcMetric) OnHandle(ctx context.Context, method string, ts time.Time, err error)
  • func (m *JsonrpcMetric) Remove()
• 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 (
	DefaultJsonrpcDurationsSize   = 20000
	DefaultJsonrpcDurationsExpire = 10 * time.Second
)

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

Variables

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

metric common tag key

Functions

func BeforeExport

func BeforeExport()

func DefaultMetricContext

func DefaultMetricContext() context.Context

func GetCIDFromMetricContext

func GetCIDFromMetricContext(ctx context.Context) (int, bool)

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 RegisterBeforeExportFunc

func RegisterBeforeExportFunc(f func())

func RegisterConsensus

func RegisterConsensus()

func RegisterJsonrpc

func RegisterJsonrpc()

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 Duration

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

type Durations

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

func NewDurations

func NewDurations(size int) *Durations

func (*Durations) Add

func (ds *Durations) Add(ts time.Time) *Duration

func (*Durations) Avg

func (ds *Durations) Avg() time.Duration

func (*Durations) Count

func (ds *Durations) Count() int

func (*Durations) Remove

func (ds *Durations) Remove(expire time.Duration)

func (*Durations) Size

func (ds *Durations) Size() int

func (*Durations) Sum

func (ds *Durations) Sum() int64

type JsonrpcMeasure

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

func (*JsonrpcMeasure) Remove

func (m *JsonrpcMeasure) Remove(expire time.Duration)

func (*JsonrpcMeasure) RemoveAndRecord

func (m *JsonrpcMeasure) RemoveAndRecord(ctx context.Context, ts time.Time, expire time.Duration)

type JsonrpcMetric

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

func NewJsonrpcMetric

func NewJsonrpcMetric(expire time.Duration, durationsSize int, useDefault bool) *JsonrpcMetric

func (*JsonrpcMetric) EnsureMeasure

func (m *JsonrpcMetric) EnsureMeasure(ctx context.Context, ms *measure) *JsonrpcMeasure

func (*JsonrpcMetric) OnHandle

func (m *JsonrpcMetric) OnHandle(ctx context.Context, method string, ts time.Time, err error)

func (*JsonrpcMetric) Remove

func (m *JsonrpcMetric) Remove()

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)