Versions in this module Expand all Collapse all v1 v1.0.0 Aug 15, 2021 Changes in this version + var APIInterface = tag.NewKey("api") + var APIRequestDuration = stats.Float64("api/request_duration_ms", "Duration of API requests", stats.UnitMilliseconds) + var APIRequestDurationView = &view.View + var BandwidthRate = stats.Float64("bandwidth/rate", "Counter for bytes per second", stats.UnitBytes) + var BandwidthRateView = &view.View + var BandwidthTotal = stats.Int64("bandwidth/total", "Counter for total traffic bytes", stats.UnitBytes) + var BandwidthTotalView = &view.View + var BlockDelay = stats.Int64("block/delay", "Delay of accepted blocks, where delay is >5s", ...) + var BlockDelayView = &view.View + var BlockPublished = stats.Int64("block/published", "Counter for total locally published blocks", ...) + var BlockReceived = stats.Int64("block/received", "Counter for total received blocks", stats.UnitDimensionless) + var BlockReceivedBytes = stats.Int64("block/received_bytes", "Counter for total bytes of received blocks", ...) + var BlockReceivedBytesView = &view.View + var BlockReceivedView = &view.View + var BlockValidationDurationMilliseconds = stats.Float64("block/validation_ms", "Duration for Block Validation in ms", ...) + var BlockValidationDurationView = &view.View + var BlockValidationFailure = stats.Int64("block/failure", "Counter for block validation failures", ...) + var BlockValidationFailureView = &view.View + var BlockValidationSuccess = stats.Int64("block/success", "Counter for block validation successes", ...) + var BlockValidationSuccessView = &view.View + var ChainNodeHeight = stats.Int64("chain/node_height", "Current Height of the node", stats.UnitDimensionless) + var ChainNodeHeightExpected = stats.Int64("chain/node_height_expected", "Expected Height of the node", ...) + var ChainNodeHeightExpectedView = &view.View + var ChainNodeHeightView = &view.View + var ChainNodeViews = append([]*view.View{ ... }, DefaultViews) + var ChainNodeWorkerHeight = stats.Int64("chain/node_worker_height", "Current Height of workers on the node", ...) + var ChainNodeWorkerHeightView = &view.View + var Coinbase = tag.NewKey("coinbase") + var CoinbaseBalance = stats.Float64("coinbase/balance", "Counter for coinbase balance in EPK", ...) + var CoinbaseBalanceView = &view.View + var Commit = tag.NewKey("commit") + var DefaultViews = func() []*view.View { ... }() + var Endpoint = tag.NewKey("endpoint") + var EpikInfo = stats.Int64("info", "Arbitrary counter to tag epik info to", stats.UnitDimensionless) + var FailureType = tag.NewKey("failure_type") + var InfoView = &view.View + var Local = tag.NewKey("local") + var MessageFrom = tag.NewKey("message_from") + var MessageNonce = tag.NewKey("message_nonce") + var MessagePublished = stats.Int64("message/published", "Counter for total locally published messages", ...) + var MessagePublishedView = &view.View + var MessageReceived = stats.Int64("message/received", "Counter for total received messages", ...) + var MessageReceivedBytes = stats.Int64("message/received_bytes", "Counter for total bytes of received messages", ...) + var MessageReceivedBytesView = &view.View + var MessageReceivedView = &view.View + var MessageTo = tag.NewKey("message_to") + var MessageValidationFailure = stats.Int64("message/failure", "Counter for message validation failures", ...) + var MessageValidationFailureView = &view.View + var MessageValidationSuccess = stats.Int64("message/success", "Counter for message validation successes", ...) + var MessageValidationSuccessView = &view.View + var MinerID = tag.NewKey("miner_id") + var MinerNodeViews = append([]*view.View{ ... }, DefaultViews) + var MinerPower = stats.Int64("miner/power", "miner power", stats.UnitBytes) + var MinerPowerView = &view.View + var MinerSectorCount = stats.Int64("miner/sector", "Counter for miner sector with type", stats.UnitDimensionless) + var MinerSectorView = &view.View + var MpoolPendingCount = stats.Int64("mpool/pending_count", "Counter of pending messages in mpool", ...) + var MpoolPendingCountView = &view.View + var NodeType = tag.NewKey("node_type") + var PeerCount = stats.Int64("peer/count", "Current number of EpiK peers", stats.UnitDimensionless) + var PeerCountView = &view.View + var PeerID = tag.NewKey("peer_id") + var PubsubDeliverMessage = stats.Int64("pubsub/delivered", "Counter for total delivered messages", ...) + var PubsubDeliverMessageView = &view.View + var PubsubDropRPC = stats.Int64("pubsub/drop_rpc", "Counter for total dropped RPCs", stats.UnitDimensionless) + var PubsubDropRPCView = &view.View + var PubsubDuplicateMessage = stats.Int64("pubsub/duplicate", "Counter for total duplicate messages", ...) + var PubsubDuplicateMessageView = &view.View + var PubsubPublishMessage = stats.Int64("pubsub/published", "Counter for total published messages", ...) + var PubsubPublishMessageView = &view.View + var PubsubRecvRPC = stats.Int64("pubsub/recv_rpc", "Counter for total received RPCs", stats.UnitDimensionless) + var PubsubRecvRPCView = &view.View + var PubsubRejectMessage = stats.Int64("pubsub/rejected", "Counter for total rejected messages", ...) + var PubsubRejectMessageView = &view.View + var PubsubSendRPC = stats.Int64("pubsub/send_rpc", "Counter for total sent RPCs", stats.UnitDimensionless) + var PubsubSendRPCView = &view.View + var ReceivedFrom = tag.NewKey("received_from") + var ServeSyncBytes = stats.Int64("serve/sync_bytes", "Counter for total sent bytes", stats.UnitBytes) + var ServeSyncBytesView = &view.View + var ServeSyncFailure = stats.Int64("serve/sync_failure", "Counter for failures", stats.UnitDimensionless) + var ServeSyncFailureView = &view.View + var ServeSyncSuccess = stats.Int64("serve/sync_success", "Counter for successes", stats.UnitDimensionless) + var ServeSyncSuccessView = &view.View + var ServeTransferAccept = stats.Int64("serve/transfer_accept", "Counter for total accepted requests", ...) + var ServeTransferAcceptView = &view.View + var ServeTransferBytes = stats.Int64("serve/transfer_bytes", "Counter for total sent bytes", stats.UnitBytes) + var ServeTransferBytesView = &view.View + var ServeTransferResult = stats.Int64("serve/transfer_result", "Counter for process results", ...) + var ServeTransferResultView = &view.View + var SplitstoreCompactionCold = stats.Int64("splitstore/cold", "Number of cold blocks in last compaction", ...) + var SplitstoreCompactionColdView = &view.View + var SplitstoreCompactionDead = stats.Int64("splitstore/dead", "Number of dead blocks in last compaction", ...) + var SplitstoreCompactionDeadView = &view.View + var SplitstoreCompactionHot = stats.Int64("splitstore/hot", "Number of hot blocks in last compaction", ...) + var SplitstoreCompactionHotView = &view.View + var SplitstoreCompactionTimeSeconds = stats.Float64("splitstore/compaction_time", "Compaction time in seconds", stats.UnitSeconds) + var SplitstoreCompactionTimeSecondsView = &view.View + var SplitstoreMiss = stats.Int64("splitstore/miss", "Number of misses in hotstre access", ...) + var SplitstoreMissView = &view.View + var SysCpuUsed = stats.Int64("sys/cpu_used", "Counter for used percentage of cpu used", ...) + var SysCpuUsedView = &view.View + var SysDiskUsed = stats.Int64("sys/disk_used", "Counter for used percentage of disk", ...) + var SysDiskUsedView = &view.View + var SysMemUsed = stats.Int64("sys/mem_used", "Counter for used percentage of ram used", ...) + var SysMemUsedView = &view.View + var TaskType = tag.NewKey("task_type") + var TipsetGasUsed = stats.Int64("tipset/gasused", "Counter of gas in one tipset", stats.UnitDimensionless) + var TipsetGasUsedView = &view.View + var TipsetMessagesCount = stats.Int64("tipset/messages_count", "Counter of messages in tipsets", ...) + var TipsetMessagesCountView = &view.View + var TipsetMessagesRate = stats.Float64("tipset/messages_rate", "Counter of processed messages per second", ...) + var TipsetMessagesRateView = &view.View + var TipsetPublishDealsCount = stats.Int64("tipset/publishdeals_count", "Counter of publishdeals in tipsets", ...) + var TipsetPublishDealsCountView = &view.View + var TipsetSubmitPoStsCount = stats.Int64("tipset/submitposts_count", "Counter of submitposts in tipsets", ...) + var TipsetSubmitPoStsCountView = &view.View + var Type = tag.NewKey("type") + var VMFlushCopyCount = stats.Int64("vm/flush_copy_count", "Number of copied objects", stats.UnitDimensionless) + var VMFlushCopyCountView = &view.View + var VMFlushCopyDuration = stats.Float64("vm/flush_copy_ms", "Time spent in VM Flush Copy", stats.UnitMilliseconds) + var VMFlushCopyDurationView = &view.View + var Version = tag.NewKey("version") + var WorkerCallsReturnedCount = stats.Int64("sealing/worker_calls_returned_count", "Counter of returned worker tasks", ...) + var WorkerCallsReturnedCountView = &view.View + var WorkerCallsReturnedDuration = stats.Float64("sealing/worker_calls_returned_ms", "Counter of returned worker tasks", ...) + var WorkerCallsReturnedDurationView = &view.View + var WorkerCallsStarted = stats.Int64("sealing/worker_calls_started", "Counter of started worker tasks", ...) + var WorkerCallsStartedView = &view.View + var WorkerHostname = tag.NewKey("worker_hostname") + var WorkerUntrackedCallsReturned = stats.Int64("sealing/worker_untracked_calls_returned", ...) + var WorkerUntrackedCallsReturnedView = &view.View + func Exporter() http.Handler + func MetricedFullAPI(a api.FullNode) api.FullNode + func MetricedGatewayAPI(a api.GatewayAPI) api.GatewayAPI + func MetricedStorMinerAPI(a api.StorageMiner) api.StorageMiner + func MetricedWalletAPI(a api.WalletAPI) api.WalletAPI + func MetricedWorkerAPI(a api.WorkerAPI) api.WorkerAPI + func RunSysInspector(ctx context.Context, reporter p2pmetrics.Reporter, interval time.Duration, ...) + func SinceInMilliseconds(startTime time.Time) float64 + func SinceInSeconds(startTime time.Time) float64 + func Timer(ctx context.Context, m *stats.Float64Measure) func() + type CountReader struct + func NewCountReader(r io.Reader) *CountReader + func (r *CountReader) Count() int64 + func (r *CountReader) Read(buf []byte) (int, error) + type CountWriter struct + func NewCountWriter(w io.Writer) *CountWriter + func (w *CountWriter) Count() int64 + func (w *CountWriter) Write(buf []byte) (int, error)