metrics

package
v0.31.13-amlandeep-scr... Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 9, 2023 License: AGPL-3.0 Imports: 29 Imported by: 51

Documentation

Index

Constants

View Source
const (
	HotstuffEventTypeLocalTimeout = "localtimeout"
	HotstuffEventTypeOnProposal   = "onproposal"
	HotstuffEventTypeOnQC         = "onqc"
	HotstuffEventTypeOnTC         = "ontc"
	HotstuffEventTypeOnPartialTc  = "onpartialtc"
)

HotStuff Metrics

View Source
const (
	LabelChannel             = "topic"
	LabelChain               = "chain"
	LabelProposer            = "proposer"
	EngineLabel              = "engine"
	LabelResource            = "resource"
	LabelProtocol            = "protocol"
	LabelMessage             = "message"
	LabelNodeID              = "nodeid"
	LabelNodeAddress         = "nodeaddress"
	LabelNodeRole            = "noderole"
	LabelNodeInfo            = "nodeinfo"
	LabelNodeVersion         = "nodeversion"
	LabelPriority            = "priority"
	LabelComputationKind     = "computationKind"
	LabelConnectionDirection = "direction"
	LabelConnectionUseFD     = "usefd" // whether the connection is using a file descriptor
	LabelSuccess             = "success"
	LabelCtrlMsgType         = "control_message"
	LabelMisbehavior         = "misbehavior"
	LabelHandler             = "handler"
	LabelStatusCode          = "code"
	LabelMethod              = "method"
	LabelService             = "service"
)
View Source
const (
	// collection
	EngineClusterCompliance      = "collection_compliance"
	EngineCollectionMessageHub   = "collection_message_hub"
	EngineCollectionIngest       = "collection_ingest"
	EngineCollectionProvider     = "collection_provider"
	EngineClusterSynchronization = "cluster-sync"
	// consensus
	EnginePropagation         = "propagation"
	EngineCompliance          = "compliance"
	EngineConsensusMessageHub = "consensus_message_hub"
	EngineConsensusIngestion  = "consensus_ingestion"
	EngineSealing             = "sealing"
	EngineSynchronization     = "sync"
	// common
	EngineFollower          = "follower"
	EngineVoteAggregator    = "vote_aggregator"
	EngineTimeoutAggregator = "timeout_aggregator"
)
View Source
const (
	ResourceUndefined                                  = "undefined"
	ResourceProposal                                   = "proposal"
	ResourceHeader                                     = "header"
	ResourceFinalizedHeight                            = "finalized_height"
	ResourceIndex                                      = "index"
	ResourceIdentity                                   = "identity"
	ResourceGuarantee                                  = "guarantee"
	ResourceResult                                     = "result"
	ResourceResultApprovals                            = "result_approvals"
	ResourceReceipt                                    = "receipt"
	ResourceQC                                         = "qc"
	ResourceMyReceipt                                  = "my_receipt"
	ResourceCollection                                 = "collection"
	ResourceApproval                                   = "approval"
	ResourceSeal                                       = "seal"
	ResourcePendingIncorporatedSeal                    = "pending_incorporated_seal"
	ResourceCommit                                     = "commit"
	ResourceTransaction                                = "transaction"
	ResourceClusterPayload                             = "cluster_payload"
	ResourceClusterProposal                            = "cluster_proposal"
	ResourceProcessedResultID                          = "processed_result_id"          // verification node, finder engine // TODO: remove finder engine labels
	ResourceDiscardedResultID                          = "discarded_result_id"          // verification node, finder engine
	ResourcePendingReceipt                             = "pending_receipt"              // verification node, finder engine
	ResourceReceiptIDsByResult                         = "receipt_ids_by_result"        // verification node, finder engine
	ResourcePendingReceiptIDsByBlock                   = "pending_receipt_ids_by_block" // verification node, finder engine
	ResourcePendingResult                              = "pending_result"               // verification node, match engine
	ResourceChunkIDsByResult                           = "chunk_ids_by_result"          // verification node, match engine
	ResourcePendingChunk                               = "pending_chunk"                // verification node, match engine
	ResourcePendingBlock                               = "pending_block"                // verification node, match engine
	ResourceCachedReceipt                              = "cached_receipt"               // verification node, finder engine
	ResourceCachedBlockID                              = "cached_block_id"              // verification node, finder engine
	ResourceChunkStatus                                = "chunk_status"                 // verification node, fetcher engine
	ResourceChunkRequest                               = "chunk_request"                // verification node, requester engine
	ResourceChunkConsumer                              = "chunk_consumer_jobs"          // verification node
	ResourceBlockConsumer                              = "block_consumer_jobs"          // verification node
	ResourceEpochSetup                                 = "epoch_setup"
	ResourceEpochCommit                                = "epoch_commit"
	ResourceEpochStatus                                = "epoch_status"
	ResourceNetworkingReceiveCache                     = "networking_received_message" // networking layer
	ResourceNetworkingDnsIpCache                       = "networking_dns_ip_cache"     // networking layer
	ResourceNetworkingDnsTxtCache                      = "networking_dns_txt_cache"    // networking layer
	ResourceNetworkingDisallowListNotificationQueue    = "networking_disallow_list_notification_queue"
	ResourceNetworkingRpcInspectorNotificationQueue    = "networking_rpc_inspector_notification_queue"
	ResourceNetworkingRpcValidationInspectorQueue      = "networking_rpc_validation_inspector_queue"
	ResourceNetworkingRpcMetricsObserverInspectorQueue = "networking_rpc_metrics_observer_inspector_queue"
	ResourceNetworkingApplicationLayerSpamRecordCache  = "application_layer_spam_record_cache"
	ResourceNetworkingApplicationLayerSpamReportQueue  = "application_layer_spam_report_queue"
	ResourceNetworkingRpcClusterPrefixReceivedCache    = "rpc_cluster_prefixed_received_cache"

	ResourceFollowerPendingBlocksCache = "follower_pending_block_cache"      // follower engine
	ResourceClusterBlockProposalQueue  = "cluster_compliance_proposal_queue" // collection node, compliance engine
	ResourceTransactionIngestQueue     = "ingest_transaction_queue"          // collection node, ingest engine
	ResourceBeaconKey                  = "beacon-key"                        // consensus node, DKG engine
	ResourceDKGMessage                 = "dkg_private_message"               // consensus, DKG messaging engine
	ResourceApprovalQueue              = "sealing_approval_queue"            // consensus node, sealing engine
	ResourceReceiptQueue               = "sealing_receipt_queue"             // consensus node, sealing engine
	ResourceApprovalResponseQueue      = "sealing_approval_response_queue"   // consensus node, sealing engine
	ResourceBlockResponseQueue         = "compliance_block_response_queue"   // consensus node, compliance engine
	ResourceBlockProposalQueue         = "compliance_proposal_queue"         // consensus node, compliance engine
	ResourceBlockVoteQueue             = "vote_aggregator_queue"             // consensus/collection node, vote aggregator
	ResourceTimeoutObjectQueue         = "timeout_aggregator_queue"          // consensus/collection node, timeout aggregator
	ResourceCollectionGuaranteesQueue  = "ingestion_col_guarantee_queue"     // consensus node, ingestion engine
	ResourceChunkDataPack              = "chunk_data_pack"                   // execution node
	ResourceChunkDataPackRequests      = "chunk_data_pack_request"           // execution node
	ResourceEvents                     = "events"                            // execution node
	ResourceServiceEvents              = "service_events"                    // execution node
	ResourceTransactionResults         = "transaction_results"               // execution node
	ResourceTransactionResultIndices   = "transaction_result_indices"        // execution node
	ResourceTransactionResultByBlock   = "transaction_result_by_block"       // execution node
	ResourceExecutionDataCache         = "execution_data_cache"              // access node
)
View Source
const (
	MessageCollectionGuarantee = "guarantee"
	MessageBlockProposal       = "proposal"
	MessageBlockVote           = "vote"
	MessageTimeoutObject       = "timeout_object"
	MessageExecutionReceipt    = "receipt"
	MessageResultApproval      = "approval"
	MessageSyncRequest         = "ping"
	MessageSyncResponse        = "pong"
	MessageRangeRequest        = "range"
	MessageBatchRequest        = "batch"
	MessageBlockResponse       = "block"
	MessageSyncedBlocks        = "synced_blocks"
	MessageSyncedClusterBlock  = "synced_cluster_block"
	MessageTransaction         = "transaction"
	MessageSubmitGuarantee     = "submit_guarantee"
	MessageCollectionRequest   = "collection_request"
	MessageCollectionResponse  = "collection_response"
	MessageEntityRequest       = "entity_request"
	MessageEntityResponse      = "entity_response"
)
View Source
const (
	KiB = 1 << (10 * iota)
	MiB
	GiB
)
View Source
const ExecutionDataRequestRetryable = "retryable"
View Source
const LabelRateLimitReason = "reason"
View Source
const LabelViolationReason = "reason"

Variables

This section is empty.

Functions

func ApplicationLayerSpamRecordCacheMetricFactory added in v0.31.0

func ApplicationLayerSpamRecordCacheMetricFactory(f HeroCacheMetricsFactory, networkType network.NetworkingType) module.HeroCacheMetrics

func ApplicationLayerSpamRecordQueueMetricsFactory added in v0.31.0

func ApplicationLayerSpamRecordQueueMetricsFactory(f HeroCacheMetricsFactory, networkType network.NetworkingType) module.HeroCacheMetrics

func GossipSubRPCInspectorClusterPrefixedCacheMetricFactory added in v0.31.0

func GossipSubRPCInspectorClusterPrefixedCacheMetricFactory(f HeroCacheMetricsFactory, networkType network.NetworkingType) module.HeroCacheMetrics

func GossipSubRPCInspectorQueueMetricFactory added in v0.31.0

func GossipSubRPCInspectorQueueMetricFactory(f HeroCacheMetricsFactory, networkType network.NetworkingType) module.HeroCacheMetrics

func GossipSubRPCMetricsObserverInspectorQueueMetricFactory added in v0.30.0

func GossipSubRPCMetricsObserverInspectorQueueMetricFactory(f HeroCacheMetricsFactory, networkType network.NetworkingType) module.HeroCacheMetrics

func NetworkReceiveCacheMetricsFactory added in v0.25.2

func NetworkReceiveCacheMetricsFactory(f HeroCacheMetricsFactory, networkType network.NetworkingType) module.HeroCacheMetrics

func NewExecutionDataRequesterCollector added in v0.26.2

func NewExecutionDataRequesterCollector() module.ExecutionDataRequesterMetrics

func NewRateLimitedBlockstoreCollector added in v0.28.0

func NewRateLimitedBlockstoreCollector(prefix string) module.RateLimitedBlockstoreMetrics

func PrependPublicPrefix added in v0.31.0

func PrependPublicPrefix(str string) string

PrependPublicPrefix prepends the string "public" to the given string. This is used to distinguish between public and private metrics. Args: - str: the string to prepend, example: "my_metric" Returns: - the prepended string, example: "public_my_metric"

func RegisterBadgerMetrics

func RegisterBadgerMetrics() error

func RpcInspectorNotificationQueueMetricFactory added in v0.30.0

func RpcInspectorNotificationQueueMetricFactory(f HeroCacheMetricsFactory, networkType network.NetworkingType) module.HeroCacheMetrics

Types

type AccessCollector added in v0.26.16

type AccessCollector struct {
	module.RestMetrics
	module.TransactionMetrics
	module.BackendScriptsMetrics
	// contains filtered or unexported fields
}

func NewAccessCollector added in v0.26.16

func NewAccessCollector(opts ...AccessCollectorOpts) *AccessCollector

func (*AccessCollector) ConnectionAddedToPool added in v0.26.17

func (ac *AccessCollector) ConnectionAddedToPool()

func (*AccessCollector) ConnectionFromPoolEvicted added in v0.26.17

func (ac *AccessCollector) ConnectionFromPoolEvicted()

func (*AccessCollector) ConnectionFromPoolInvalidated added in v0.26.17

func (ac *AccessCollector) ConnectionFromPoolInvalidated()

func (*AccessCollector) ConnectionFromPoolReused added in v0.26.17

func (ac *AccessCollector) ConnectionFromPoolReused()

func (*AccessCollector) ConnectionFromPoolUpdated added in v0.26.17

func (ac *AccessCollector) ConnectionFromPoolUpdated()

func (*AccessCollector) NewConnectionEstablished added in v0.26.17

func (ac *AccessCollector) NewConnectionEstablished()

func (*AccessCollector) TotalConnectionsInPool added in v0.26.16

func (ac *AccessCollector) TotalConnectionsInPool(connectionCount uint, connectionPoolSize uint)

func (*AccessCollector) UpdateExecutionReceiptMaxHeight added in v0.31.0

func (ac *AccessCollector) UpdateExecutionReceiptMaxHeight(height uint64)

func (*AccessCollector) UpdateLastFullBlockHeight added in v0.31.0

func (ac *AccessCollector) UpdateLastFullBlockHeight(height uint64)

type AccessCollectorOpts added in v0.31.0

type AccessCollectorOpts func(*AccessCollector)

func WithBackendScriptsMetrics added in v0.31.0

func WithBackendScriptsMetrics(m module.BackendScriptsMetrics) AccessCollectorOpts

func WithRestMetrics added in v0.31.14

func WithRestMetrics(m module.RestMetrics) AccessCollectorOpts

func WithTransactionMetrics added in v0.31.0

func WithTransactionMetrics(m module.TransactionMetrics) AccessCollectorOpts

type AlspMetrics added in v0.31.0

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

AlspMetrics is a struct that contains all the metrics related to the ALSP module. It implements the AlspMetrics interface. AlspMetrics encapsulates the metrics collectors for the Application Layer Spam Prevention (ALSP) module, which is part of the networking layer. ALSP is responsible to prevent spam attacks on the application layer messages that appear to be valid for the networking layer but carry on a malicious intent on the application layer (i.e., Flow protocols).

func NewAlspMetrics added in v0.31.0

func NewAlspMetrics() *AlspMetrics

NewAlspMetrics creates a new AlspMetrics struct. It initializes the metrics collectors for the ALSP module. Returns: - a pointer to the AlspMetrics struct.

func (*AlspMetrics) OnMisbehaviorReported added in v0.31.0

func (a *AlspMetrics) OnMisbehaviorReported(channel string, misbehaviorType string)

OnMisbehaviorReported is called when a misbehavior is reported by the application layer to ALSP. An engine detecting a spamming-related misbehavior reports it to the ALSP module. It increases the counter vector of reported misbehavior. Args: - channel: the channel on which the misbehavior was reported - misbehaviorType: the type of misbehavior reported

type BitswapCollector added in v0.27.3

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

func NewBitswapCollector added in v0.27.3

func NewBitswapCollector() *BitswapCollector

func (*BitswapCollector) BlobsReceived added in v0.27.3

func (bc *BitswapCollector) BlobsReceived(prefix string, n uint64)

func (*BitswapCollector) BlobsSent added in v0.27.3

func (bc *BitswapCollector) BlobsSent(prefix string, n uint64)

func (*BitswapCollector) DataReceived added in v0.27.3

func (bc *BitswapCollector) DataReceived(prefix string, n uint64)

func (*BitswapCollector) DataSent added in v0.27.3

func (bc *BitswapCollector) DataSent(prefix string, n uint64)

func (*BitswapCollector) DupBlobsReceived added in v0.27.3

func (bc *BitswapCollector) DupBlobsReceived(prefix string, n uint64)

func (*BitswapCollector) DupDataReceived added in v0.27.3

func (bc *BitswapCollector) DupDataReceived(prefix string, n uint64)

func (*BitswapCollector) MessagesReceived added in v0.27.3

func (bc *BitswapCollector) MessagesReceived(prefix string, n uint64)

func (*BitswapCollector) Peers added in v0.27.3

func (bc *BitswapCollector) Peers(prefix string, n int)

func (*BitswapCollector) Wantlist added in v0.27.3

func (bc *BitswapCollector) Wantlist(prefix string, n int)

type CacheCollector

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

func NewCacheCollector

func NewCacheCollector(chain flow.ChainID) *CacheCollector

func (*CacheCollector) CacheEntries

func (cc *CacheCollector) CacheEntries(resource string, entries uint)

CacheEntries records the size of the node identities cache.

func (*CacheCollector) CacheHit

func (cc *CacheCollector) CacheHit(resource string)

CacheHit records the number of hits in the node identities cache.

func (*CacheCollector) CacheMiss

func (cc *CacheCollector) CacheMiss(resource string)

CacheMiss report the number of times the queried item is not found in the cache, but found in the database.

func (*CacheCollector) CacheNotFound added in v0.16.0

func (cc *CacheCollector) CacheNotFound(resource string)

CacheNotFound records the number of times the queried item was not found in either cache or database.

type ChainSyncCollector added in v0.27.0

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

func NewChainSyncCollector added in v0.27.0

func NewChainSyncCollector(chainID flow.ChainID) *ChainSyncCollector

func (*ChainSyncCollector) BatchRequested added in v0.27.0

func (c *ChainSyncCollector) BatchRequested(batch chainsync.Batch)

func (*ChainSyncCollector) PrunedBlockByHeight added in v0.27.0

func (c *ChainSyncCollector) PrunedBlockByHeight(status *chainsync.Status)

func (*ChainSyncCollector) PrunedBlockById added in v0.27.0

func (c *ChainSyncCollector) PrunedBlockById(status *chainsync.Status)

func (*ChainSyncCollector) PrunedBlocks added in v0.27.0

func (c *ChainSyncCollector) PrunedBlocks(totalByHeight, totalById, storedByHeight, storedById int)

func (*ChainSyncCollector) RangeRequested added in v0.27.0

func (c *ChainSyncCollector) RangeRequested(ran chainsync.Range)

type CleanerCollector

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

func NewCleanerCollector

func NewCleanerCollector() *CleanerCollector

func (*CleanerCollector) RanGC

func (cc *CleanerCollector) RanGC(duration time.Duration)

RanGC records a successful run of the Badger garbage collector.

type CollectionCollector

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

func NewCollectionCollector

func NewCollectionCollector(tracer module.Tracer) *CollectionCollector

func (*CollectionCollector) ClusterBlockFinalized

func (cc *CollectionCollector) ClusterBlockFinalized(block *cluster.Block)

ClusterBlockFinalized updates the guaranteed collection size gauge and finishes the tx->collection span for each constituent transaction.

func (*CollectionCollector) ClusterBlockProposed

func (cc *CollectionCollector) ClusterBlockProposed(block *cluster.Block)

ClusterBlockProposed tracks the size and number of proposals, as well as starting the collection->guarantee span.

func (*CollectionCollector) TransactionIngested

func (cc *CollectionCollector) TransactionIngested(txID flow.Identifier)

TransactionIngested starts a span to trace the duration of a transaction from being created to being included as part of a collection.

type ComplianceCollector

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

func NewComplianceCollector

func NewComplianceCollector() *ComplianceCollector

func (*ComplianceCollector) BlockFinalized

func (cc *ComplianceCollector) BlockFinalized(block *flow.Block)

BlockFinalized reports metrics about finalized blocks.

func (*ComplianceCollector) BlockSealed

func (cc *ComplianceCollector) BlockSealed(block *flow.Block)

BlockSealed reports metrics about sealed blocks.

func (*ComplianceCollector) CommittedEpochFinalView added in v0.18.3

func (cc *ComplianceCollector) CommittedEpochFinalView(view uint64)

func (*ComplianceCollector) CurrentDKGPhase1FinalView added in v0.21.0

func (cc *ComplianceCollector) CurrentDKGPhase1FinalView(view uint64)

func (*ComplianceCollector) CurrentDKGPhase2FinalView added in v0.21.0

func (cc *ComplianceCollector) CurrentDKGPhase2FinalView(view uint64)

func (*ComplianceCollector) CurrentDKGPhase3FinalView added in v0.21.0

func (cc *ComplianceCollector) CurrentDKGPhase3FinalView(view uint64)

func (*ComplianceCollector) CurrentEpochCounter added in v0.20.0

func (cc *ComplianceCollector) CurrentEpochCounter(counter uint64)

func (*ComplianceCollector) CurrentEpochFinalView added in v0.21.0

func (cc *ComplianceCollector) CurrentEpochFinalView(view uint64)

func (*ComplianceCollector) CurrentEpochPhase added in v0.20.0

func (cc *ComplianceCollector) CurrentEpochPhase(phase flow.EpochPhase)

func (*ComplianceCollector) EpochEmergencyFallbackTriggered added in v0.23.2

func (cc *ComplianceCollector) EpochEmergencyFallbackTriggered()

func (*ComplianceCollector) EpochTransitionHeight added in v0.30.0

func (cc *ComplianceCollector) EpochTransitionHeight(height uint64)

func (*ComplianceCollector) FinalizedHeight

func (cc *ComplianceCollector) FinalizedHeight(height uint64)

FinalizedHeight sets the finalized height.

func (*ComplianceCollector) SealedHeight

func (cc *ComplianceCollector) SealedHeight(height uint64)

SealedHeight sets the finalized height.

type ConsensusCollector

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

ConsensusCollector ...

func NewConsensusCollector

func NewConsensusCollector(tracer module.Tracer, registerer prometheus.Registerer) *ConsensusCollector

NewConsensusCollector created a new consensus collector

func (*ConsensusCollector) CheckSealingDuration added in v0.11.0

func (cc *ConsensusCollector) CheckSealingDuration(duration time.Duration)

CheckSealingDuration increases the number of seconds spent in checkSealing

func (*ConsensusCollector) EmergencySeal added in v0.14.0

func (cc *ConsensusCollector) EmergencySeal()

EmergencySeal increments the counter of emergency seals.

func (*ConsensusCollector) FinishBlockToSeal

func (cc *ConsensusCollector) FinishBlockToSeal(blockID flow.Identifier)

FinishBlockToSeal reports Metrics C4: Block Received by CCL → Block Seal in finalized block

func (*ConsensusCollector) FinishCollectionToFinalized

func (cc *ConsensusCollector) FinishCollectionToFinalized(collectionID flow.Identifier)

FinishCollectionToFinalized reports Metrics C1: Collection Received by CCL→ Collection Included in Finalized Block

func (*ConsensusCollector) OnApprovalProcessingDuration added in v0.14.1

func (cc *ConsensusCollector) OnApprovalProcessingDuration(duration time.Duration)

OnApprovalProcessingDuration increases the number of seconds spent processing approvals

func (*ConsensusCollector) OnReceiptProcessingDuration added in v0.14.1

func (cc *ConsensusCollector) OnReceiptProcessingDuration(duration time.Duration)

OnReceiptProcessingDuration increases the number of seconds spent processing receipts

func (*ConsensusCollector) StartBlockToSeal

func (cc *ConsensusCollector) StartBlockToSeal(blockID flow.Identifier)

StartBlockToSeal reports Metrics C4: Block Received by CCL → Block Seal in finalized block

func (*ConsensusCollector) StartCollectionToFinalized

func (cc *ConsensusCollector) StartCollectionToFinalized(collectionID flow.Identifier)

StartCollectionToFinalized reports Metrics C1: Collection Received by CCL→ Collection Included in Finalized Block

type CruiseCtlMetrics added in v0.31.0

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

CruiseCtlMetrics captures metrics about the Block Rate Controller, which adjusts the proposal duration to attain a target epoch switchover time.

func NewCruiseCtlMetrics added in v0.31.0

func NewCruiseCtlMetrics() *CruiseCtlMetrics

func (*CruiseCtlMetrics) ControllerOutput added in v0.31.0

func (c *CruiseCtlMetrics) ControllerOutput(duration time.Duration)

func (*CruiseCtlMetrics) PIDError added in v0.31.0

func (c *CruiseCtlMetrics) PIDError(p, i, d float64)

func (*CruiseCtlMetrics) TargetProposalDuration added in v0.31.0

func (c *CruiseCtlMetrics) TargetProposalDuration(duration time.Duration)

type EngineCollector

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

func NewEngineCollector

func NewEngineCollector() *EngineCollector

func (*EngineCollector) InboundMessageDropped added in v0.29.0

func (ec *EngineCollector) InboundMessageDropped(engine string, message string)

func (*EngineCollector) MessageHandled

func (ec *EngineCollector) MessageHandled(engine string, message string)

func (*EngineCollector) MessageReceived

func (ec *EngineCollector) MessageReceived(engine string, message string)

func (*EngineCollector) MessageSent

func (ec *EngineCollector) MessageSent(engine string, message string)

func (*EngineCollector) OutboundMessageDropped added in v0.29.0

func (ec *EngineCollector) OutboundMessageDropped(engine string, message string)

type ExecutionCollector

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

func NewExecutionCollector

func NewExecutionCollector(tracer module.Tracer) *ExecutionCollector

func (*ExecutionCollector) ChunkDataPackRequestProcessed added in v0.28.0

func (ec *ExecutionCollector) ChunkDataPackRequestProcessed()

ChunkDataPackRequestProcessed is executed every time a chunk data pack request is picked up for processing at execution node. It increases the request processed counter by one.

func (*ExecutionCollector) ExecutionBlockCachedPrograms added in v0.29.17

func (ec *ExecutionCollector) ExecutionBlockCachedPrograms(programs int)

func (*ExecutionCollector) ExecutionBlockDataUploadFinished added in v0.20.6

func (ec *ExecutionCollector) ExecutionBlockDataUploadFinished(dur time.Duration)

func (*ExecutionCollector) ExecutionBlockDataUploadStarted added in v0.20.6

func (ec *ExecutionCollector) ExecutionBlockDataUploadStarted()

func (*ExecutionCollector) ExecutionBlockExecuted added in v0.18.3

func (ec *ExecutionCollector) ExecutionBlockExecuted(
	dur time.Duration,
	stats module.ExecutionResultStats,
)

ExecutionBlockExecuted reports execution meta data after executing a block

func (*ExecutionCollector) ExecutionBlockExecutionEffortVectorComponent added in v0.28.2

func (ec *ExecutionCollector) ExecutionBlockExecutionEffortVectorComponent(compKind string, value uint)

func (*ExecutionCollector) ExecutionChunkDataPackGenerated added in v0.28.7

func (ec *ExecutionCollector) ExecutionChunkDataPackGenerated(proofSize, numberOfTransactions int)

ExecutionChunkDataPackGenerated reports stats on chunk data pack generation

func (*ExecutionCollector) ExecutionCollectionExecuted added in v0.18.3

func (ec *ExecutionCollector) ExecutionCollectionExecuted(
	dur time.Duration,
	stats module.ExecutionResultStats,
)

ExecutionCollectionExecuted reports stats for executing a collection

func (*ExecutionCollector) ExecutionCollectionRequestRetried

func (ec *ExecutionCollector) ExecutionCollectionRequestRetried()

func (*ExecutionCollector) ExecutionCollectionRequestSent

func (ec *ExecutionCollector) ExecutionCollectionRequestSent()

func (*ExecutionCollector) ExecutionComputationResultUploadRetried added in v0.28.0

func (ec *ExecutionCollector) ExecutionComputationResultUploadRetried()

func (*ExecutionCollector) ExecutionComputationResultUploaded added in v0.28.0

func (ec *ExecutionCollector) ExecutionComputationResultUploaded()

func (*ExecutionCollector) ExecutionLastExecutedBlockHeight

func (ec *ExecutionCollector) ExecutionLastExecutedBlockHeight(height uint64)

ExecutionLastExecutedBlockHeight reports last executed block height

func (*ExecutionCollector) ExecutionScriptExecuted added in v0.18.3

func (ec *ExecutionCollector) ExecutionScriptExecuted(dur time.Duration, compUsed, memoryUsed, memoryEstimated uint64)

ScriptExecuted reports the time spent executing a single script

func (*ExecutionCollector) ExecutionStateStorageDiskTotal

func (ec *ExecutionCollector) ExecutionStateStorageDiskTotal(bytes int64)

ExecutionStateStorageDiskTotal reports the total storage size of the execution state on disk in bytes

func (*ExecutionCollector) ExecutionStorageStateCommitment

func (ec *ExecutionCollector) ExecutionStorageStateCommitment(bytes int64)

ExecutionStorageStateCommitment reports the storage size of a state commitment

func (*ExecutionCollector) ExecutionSync

func (ec *ExecutionCollector) ExecutionSync(syncing bool)

func (*ExecutionCollector) ExecutionTransactionExecuted added in v0.18.3

func (ec *ExecutionCollector) ExecutionTransactionExecuted(
	dur time.Duration,
	compUsed, memoryUsed uint64,
	eventCounts, eventSize int,
	failed bool,
)

TransactionExecuted reports stats for executing a transaction

func (*ExecutionCollector) FinishBlockReceivedToExecuted

func (ec *ExecutionCollector) FinishBlockReceivedToExecuted(blockID flow.Identifier)

FinishBlockReceivedToExecuted finishes a span to trace the duration of a block from being received for execution to execution being finished

func (*ExecutionCollector) ForestApproxMemorySize

func (ec *ExecutionCollector) ForestApproxMemorySize(bytes uint64)

ForestApproxMemorySize records approximate memory usage of forest (all in-memory trees)

func (*ExecutionCollector) ForestNumberOfTrees

func (ec *ExecutionCollector) ForestNumberOfTrees(number uint64)

ForestNumberOfTrees current number of trees in a forest (in memory)

func (*ExecutionCollector) LatestTrieMaxDepthTouched added in v0.25.2

func (ec *ExecutionCollector) LatestTrieMaxDepthTouched(maxDepth uint16)

LatestTrieMaxDepthTouched records the maximum depth touched of the last created trie

func (*ExecutionCollector) LatestTrieRegCount

func (ec *ExecutionCollector) LatestTrieRegCount(number uint64)

LatestTrieRegCount records the number of unique register allocated (the lastest created trie)

func (*ExecutionCollector) LatestTrieRegCountDiff

func (ec *ExecutionCollector) LatestTrieRegCountDiff(number int64)

LatestTrieRegCountDiff records the difference between the number of unique register allocated of the latest created trie and parent trie

func (*ExecutionCollector) LatestTrieRegSize added in v0.25.2

func (ec *ExecutionCollector) LatestTrieRegSize(size uint64)

LatestTrieRegSize records the size of unique register allocated (the lastest created trie)

func (*ExecutionCollector) LatestTrieRegSizeDiff added in v0.25.2

func (ec *ExecutionCollector) LatestTrieRegSizeDiff(size int64)

LatestTrieRegSizeDiff records the difference between the size of unique register allocated of the latest created trie and parent trie

func (*ExecutionCollector) ProofSize

func (ec *ExecutionCollector) ProofSize(bytes uint32)

ProofSize records a proof size

func (*ExecutionCollector) ReadDuration

func (ec *ExecutionCollector) ReadDuration(duration time.Duration)

ReadDuration records absolute time for the read from a trie

func (*ExecutionCollector) ReadDurationPerItem

func (ec *ExecutionCollector) ReadDurationPerItem(duration time.Duration)

ReadDurationPerItem records read time for single value (total duration / number of read values)

func (*ExecutionCollector) ReadValuesNumber

func (ec *ExecutionCollector) ReadValuesNumber(number uint64)

ReadValuesNumber accumulates number of read values

func (*ExecutionCollector) ReadValuesSize

func (ec *ExecutionCollector) ReadValuesSize(bytes uint64)

ReadValuesSize total size (in bytes) of read values

func (*ExecutionCollector) RuntimeSetNumberOfAccounts added in v0.18.3

func (ec *ExecutionCollector) RuntimeSetNumberOfAccounts(count uint64)

func (*ExecutionCollector) RuntimeTransactionChecked added in v0.18.3

func (ec *ExecutionCollector) RuntimeTransactionChecked(dur time.Duration)

TransactionChecked reports the time spent checking a single transaction

func (*ExecutionCollector) RuntimeTransactionInterpreted added in v0.18.3

func (ec *ExecutionCollector) RuntimeTransactionInterpreted(dur time.Duration)

TransactionInterpreted reports the time spent interpreting a single transaction

func (*ExecutionCollector) RuntimeTransactionParsed added in v0.18.3

func (ec *ExecutionCollector) RuntimeTransactionParsed(dur time.Duration)

TransactionParsed reports the time spent parsing a single transaction

func (*ExecutionCollector) RuntimeTransactionProgramsCacheHit added in v0.29.17

func (ec *ExecutionCollector) RuntimeTransactionProgramsCacheHit()

func (*ExecutionCollector) RuntimeTransactionProgramsCacheMiss added in v0.29.17

func (ec *ExecutionCollector) RuntimeTransactionProgramsCacheMiss()

func (*ExecutionCollector) StartBlockReceivedToExecuted

func (ec *ExecutionCollector) StartBlockReceivedToExecuted(blockID flow.Identifier)

StartBlockReceivedToExecuted starts a span to trace the duration of a block from being received for execution to execution being finished

func (*ExecutionCollector) UpdateCollectionMaxHeight added in v0.27.0

func (ec *ExecutionCollector) UpdateCollectionMaxHeight(height uint64)

func (*ExecutionCollector) UpdateCount

func (ec *ExecutionCollector) UpdateCount()

UpdateCount increase a counter of performed updates

func (*ExecutionCollector) UpdateDuration

func (ec *ExecutionCollector) UpdateDuration(duration time.Duration)

UpdateDuration records absolute time for the update of a trie

func (*ExecutionCollector) UpdateDurationPerItem

func (ec *ExecutionCollector) UpdateDurationPerItem(duration time.Duration)

UpdateDurationPerItem records update time for single value (total duration / number of updated values)

func (*ExecutionCollector) UpdateValuesNumber

func (ec *ExecutionCollector) UpdateValuesNumber(number uint64)

UpdateValuesNumber accumulates number of updated values

func (*ExecutionCollector) UpdateValuesSize

func (ec *ExecutionCollector) UpdateValuesSize(bytes uint64)

UpdateValuesSize total size (in bytes) of updates values

type ExecutionDataProviderCollector added in v0.27.2

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

func NewExecutionDataProviderCollector added in v0.27.2

func NewExecutionDataProviderCollector() *ExecutionDataProviderCollector

func (*ExecutionDataProviderCollector) AddBlobsFailed added in v0.27.2

func (c *ExecutionDataProviderCollector) AddBlobsFailed()

func (*ExecutionDataProviderCollector) AddBlobsSucceeded added in v0.27.2

func (c *ExecutionDataProviderCollector) AddBlobsSucceeded(duration time.Duration, totalSize uint64)

func (*ExecutionDataProviderCollector) RootIDComputed added in v0.27.2

func (c *ExecutionDataProviderCollector) RootIDComputed(duration time.Duration, numberOfChunks int)

type ExecutionDataPrunerCollector added in v0.27.2

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

func NewExecutionDataPrunerCollector added in v0.27.2

func NewExecutionDataPrunerCollector() *ExecutionDataPrunerCollector

func (*ExecutionDataPrunerCollector) Pruned added in v0.27.2

func (c *ExecutionDataPrunerCollector) Pruned(height uint64, duration time.Duration)

type ExecutionDataRequesterCollector added in v0.26.2

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

func (*ExecutionDataRequesterCollector) ExecutionDataFetchFinished added in v0.26.2

func (ec *ExecutionDataRequesterCollector) ExecutionDataFetchFinished(duration time.Duration, success bool, height uint64)

func (*ExecutionDataRequesterCollector) ExecutionDataFetchStarted added in v0.26.2

func (ec *ExecutionDataRequesterCollector) ExecutionDataFetchStarted()

func (*ExecutionDataRequesterCollector) FetchRetried added in v0.26.2

func (ec *ExecutionDataRequesterCollector) FetchRetried()

func (*ExecutionDataRequesterCollector) NotificationSent added in v0.26.2

func (ec *ExecutionDataRequesterCollector) NotificationSent(height uint64)

type ExecutionDataRequesterV2Collector added in v0.27.2

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

func NewExecutionDataRequesterV2Collector added in v0.27.2

func NewExecutionDataRequesterV2Collector() *ExecutionDataRequesterV2Collector

func (*ExecutionDataRequesterV2Collector) FulfilledHeight added in v0.27.2

func (c *ExecutionDataRequesterV2Collector) FulfilledHeight(blockHeight uint64)

func (*ExecutionDataRequesterV2Collector) ReceiptSkipped added in v0.27.2

func (c *ExecutionDataRequesterV2Collector) ReceiptSkipped()

func (*ExecutionDataRequesterV2Collector) RequestCanceled added in v0.27.2

func (c *ExecutionDataRequesterV2Collector) RequestCanceled()

func (*ExecutionDataRequesterV2Collector) RequestFailed added in v0.27.2

func (c *ExecutionDataRequesterV2Collector) RequestFailed(duration time.Duration, retryable bool)

func (*ExecutionDataRequesterV2Collector) RequestSucceeded added in v0.27.2

func (c *ExecutionDataRequesterV2Collector) RequestSucceeded(blockHeight uint64, duration time.Duration, totalSize uint64, numberOfAttempts int)

func (*ExecutionDataRequesterV2Collector) ResponseDropped added in v0.27.2

func (c *ExecutionDataRequesterV2Collector) ResponseDropped()

type GossipSubLocalMeshMetrics added in v0.30.0

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

GossipSubLocalMeshMetrics is a metrics collector for the local mesh of GossipSub protocol.

func NewGossipSubLocalMeshMetrics added in v0.30.0

func NewGossipSubLocalMeshMetrics(prefix string) *GossipSubLocalMeshMetrics

func (*GossipSubLocalMeshMetrics) OnLocalMeshSizeUpdated added in v0.30.0

func (g *GossipSubLocalMeshMetrics) OnLocalMeshSizeUpdated(topic string, size int)

OnLocalMeshSizeUpdated updates the local mesh size metric.

type GossipSubMetrics added in v0.29.0

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

func NewGossipSubMetrics added in v0.29.0

func NewGossipSubMetrics(prefix string) *GossipSubMetrics

func (*GossipSubMetrics) OnGraftReceived added in v0.29.0

func (nc *GossipSubMetrics) OnGraftReceived(count int)

OnGraftReceived tracks the number of GRAFT messages received by the node from other nodes. GRAFT is a control message of GossipSub protocol that connects two nodes over a topic directly as gossip partners.

func (*GossipSubMetrics) OnIHaveReceived added in v0.29.0

func (nc *GossipSubMetrics) OnIHaveReceived(count int)

OnIHaveReceived tracks the number of IHAVE messages received by the node from other nodes. iHave is a control message that is sent by a node to another node to indicate that it has a new gossiped message.

func (*GossipSubMetrics) OnIWantReceived added in v0.29.0

func (nc *GossipSubMetrics) OnIWantReceived(count int)

OnIWantReceived tracks the number of IWANT messages received by the node from other nodes. iWant is a control message that is sent by a node to request a message that it has seen advertised in an iHAVE message.

func (*GossipSubMetrics) OnIncomingRpcAcceptedFully added in v0.29.0

func (nc *GossipSubMetrics) OnIncomingRpcAcceptedFully()

OnIncomingRpcAcceptedFully tracks the number of RPC messages received by the node that are fully accepted. An RPC may contain any number of control messages, i.e., IHAVE, IWANT, GRAFT, PRUNE, as well as the actual messages. A fully accepted RPC means that all the control messages are accepted and all the messages are accepted.

func (*GossipSubMetrics) OnIncomingRpcAcceptedOnlyForControlMessages added in v0.29.0

func (nc *GossipSubMetrics) OnIncomingRpcAcceptedOnlyForControlMessages()

OnIncomingRpcAcceptedOnlyForControlMessages tracks the number of RPC messages received by the node that are accepted only for the control messages, i.e., only for the included IHAVE, IWANT, GRAFT, PRUNE. However, the actual messages included in the RPC are not accepted. This happens mostly when the validation pipeline of GossipSub is throttled, and cannot accept more actual messages for validation.

func (*GossipSubMetrics) OnIncomingRpcRejected added in v0.29.0

func (nc *GossipSubMetrics) OnIncomingRpcRejected()

OnIncomingRpcRejected tracks the number of RPC messages received by the node that are rejected. This happens mostly when the RPC is coming from a low-scored peer based on the peer scoring module of GossipSub.

func (*GossipSubMetrics) OnPruneReceived added in v0.29.0

func (nc *GossipSubMetrics) OnPruneReceived(count int)

OnPruneReceived tracks the number of PRUNE messages received by the node from other nodes. PRUNE is a control message of GossipSub protocol that disconnects two nodes over a topic.

func (*GossipSubMetrics) OnPublishedGossipMessagesReceived added in v0.29.0

func (nc *GossipSubMetrics) OnPublishedGossipMessagesReceived(count int)

OnPublishedGossipMessagesReceived tracks the number of gossip messages received by the node from other nodes over an RPC message.

type GossipSubRpcValidationInspectorMetrics added in v0.31.0

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

GossipSubRpcValidationInspectorMetrics metrics collector for the gossipsub RPC validation inspector.

func NewGossipSubRPCValidationInspectorMetrics added in v0.31.0

func NewGossipSubRPCValidationInspectorMetrics(prefix string) *GossipSubRpcValidationInspectorMetrics

NewGossipSubRPCValidationInspectorMetrics returns a new *GossipSubRpcValidationInspectorMetrics.

func (*GossipSubRpcValidationInspectorMetrics) AsyncProcessingFinished added in v0.31.0

func (c *GossipSubRpcValidationInspectorMetrics) AsyncProcessingFinished(msgType string, duration time.Duration)

AsyncProcessingFinished tracks the time spent by the rpc validation inspector to process a message asynchronously and decrements the metric tracking the number of messages being processed asynchronously by the rpc validation inspector.

func (*GossipSubRpcValidationInspectorMetrics) AsyncProcessingStarted added in v0.31.0

func (c *GossipSubRpcValidationInspectorMetrics) AsyncProcessingStarted(msgType string)

AsyncProcessingStarted increments the metric tracking the number of messages being processed asynchronously by the rpc validation inspector.

func (*GossipSubRpcValidationInspectorMetrics) BlockingPreProcessingFinished added in v0.31.0

func (c *GossipSubRpcValidationInspectorMetrics) BlockingPreProcessingFinished(msgType string, sampleSize uint, duration time.Duration)

BlockingPreProcessingFinished tracks the time spent by the rpc validation inspector to pre-process a message and decrements the metric tracking the number of messages being processed by the rpc validation inspector.

func (*GossipSubRpcValidationInspectorMetrics) BlockingPreProcessingStarted added in v0.31.0

func (c *GossipSubRpcValidationInspectorMetrics) BlockingPreProcessingStarted(msgType string, sampleSize uint)

BlockingPreProcessingStarted increments the metric tracking the number of messages being pre-processed by the rpc validation inspector.

type GossipSubScoreMetrics added in v0.30.0

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

func NewGossipSubScoreMetrics added in v0.30.0

func NewGossipSubScoreMetrics(prefix string) *GossipSubScoreMetrics

func (*GossipSubScoreMetrics) OnAppSpecificScoreUpdated added in v0.30.0

func (g *GossipSubScoreMetrics) OnAppSpecificScoreUpdated(score float64)

func (*GossipSubScoreMetrics) OnBehaviourPenaltyUpdated added in v0.30.0

func (g *GossipSubScoreMetrics) OnBehaviourPenaltyUpdated(penalty float64)

func (*GossipSubScoreMetrics) OnFirstMessageDeliveredUpdated added in v0.30.0

func (g *GossipSubScoreMetrics) OnFirstMessageDeliveredUpdated(topic channels.Topic, f float64)

func (*GossipSubScoreMetrics) OnIPColocationFactorUpdated added in v0.30.0

func (g *GossipSubScoreMetrics) OnIPColocationFactorUpdated(factor float64)

func (*GossipSubScoreMetrics) OnInvalidMessageDeliveredUpdated added in v0.30.0

func (g *GossipSubScoreMetrics) OnInvalidMessageDeliveredUpdated(topic channels.Topic, f float64)

func (*GossipSubScoreMetrics) OnMeshMessageDeliveredUpdated added in v0.30.0

func (g *GossipSubScoreMetrics) OnMeshMessageDeliveredUpdated(topic channels.Topic, f float64)

func (*GossipSubScoreMetrics) OnOverallPeerScoreUpdated added in v0.30.0

func (g *GossipSubScoreMetrics) OnOverallPeerScoreUpdated(score float64)

func (*GossipSubScoreMetrics) OnTimeInMeshUpdated added in v0.30.0

func (g *GossipSubScoreMetrics) OnTimeInMeshUpdated(topic channels.Topic, duration time.Duration)

func (*GossipSubScoreMetrics) SetWarningStateCount added in v0.30.0

func (g *GossipSubScoreMetrics) SetWarningStateCount(u uint)

type HeroCacheCollector added in v0.25.2

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

func AccessNodeExecutionDataCacheMetrics added in v0.30.2

func AccessNodeExecutionDataCacheMetrics(registrar prometheus.Registerer) *HeroCacheCollector

func ChunkDataPackRequestQueueMetricsFactory added in v0.28.0

func ChunkDataPackRequestQueueMetricsFactory(registrar prometheus.Registerer) *HeroCacheCollector

func CollectionNodeTransactionsCacheMetrics added in v0.25.2

func CollectionNodeTransactionsCacheMetrics(registrar prometheus.Registerer, epoch uint64) *HeroCacheCollector

func CollectionRequestsQueueMetricFactory added in v0.29.0

func CollectionRequestsQueueMetricFactory(registrar prometheus.Registerer) *HeroCacheCollector

func DisallowListNotificationQueueMetricFactory added in v0.30.0

func DisallowListNotificationQueueMetricFactory(registrar prometheus.Registerer) *HeroCacheCollector

func FollowerCacheMetrics added in v0.30.0

func FollowerCacheMetrics(registrar prometheus.Registerer) *HeroCacheCollector

func NetworkDnsIpCacheMetricsFactory added in v0.25.2

func NetworkDnsIpCacheMetricsFactory(registrar prometheus.Registerer) *HeroCacheCollector

func NetworkDnsTxtCacheMetricsFactory added in v0.25.2

func NetworkDnsTxtCacheMetricsFactory(registrar prometheus.Registerer) *HeroCacheCollector

func NewHeroCacheCollector added in v0.25.2

func NewHeroCacheCollector(nameSpace string, cacheName string, registrar prometheus.Registerer) *HeroCacheCollector

func ReceiptRequestsQueueMetricFactory added in v0.29.0

func ReceiptRequestsQueueMetricFactory(registrar prometheus.Registerer) *HeroCacheCollector

func (*HeroCacheCollector) BucketAvailableSlots added in v0.25.2

func (h *HeroCacheCollector) BucketAvailableSlots(availableSlots uint64, totalSlots uint64)

BucketAvailableSlots keeps track of number of available slots in buckets of cache.

func (*HeroCacheCollector) OnEntityEjectionDueToEmergency added in v0.25.2

func (h *HeroCacheCollector) OnEntityEjectionDueToEmergency()

OnEntityEjectionDueToEmergency is called whenever a bucket is found full and all of its keys are valid, i.e., each key belongs to an existing (key, entity) pair. Hence, adding a new key to that bucket will replace the oldest valid key inside that bucket. Note: in context of HeroCache, the key corresponds to the identifier of its entity.

func (*HeroCacheCollector) OnEntityEjectionDueToFullCapacity added in v0.25.2

func (h *HeroCacheCollector) OnEntityEjectionDueToFullCapacity()

OnEntityEjectionDueToFullCapacity is called whenever adding a new (key, entity) to the cache results in ejection of another (key', entity') pair. This normally happens -- and is expected -- when the cache is full. Note: in context of HeroCache, the key corresponds to the identifier of its entity.

func (*HeroCacheCollector) OnKeyGetFailure added in v0.25.2

func (h *HeroCacheCollector) OnKeyGetFailure()

OnKeyGetFailure tracks total number of unsuccessful read queries. A read query is unsuccessful if the entity corresponding to its key is not available in the cache. Note: in context of HeroCache, the key corresponds to the identifier of its entity.

func (*HeroCacheCollector) OnKeyGetSuccess added in v0.25.2

func (h *HeroCacheCollector) OnKeyGetSuccess()

OnKeyGetSuccess tracks total number of successful read queries. A read query is successful if the entity corresponding to its key is available in the cache. Note: in context of HeroCache, the key corresponds to the identifier of its entity.

func (*HeroCacheCollector) OnKeyPutAttempt added in v0.29.0

func (h *HeroCacheCollector) OnKeyPutAttempt(size uint32)

OnKeyPutAttempt is called whenever a new (key, value) pair is attempted to be put in cache. It does not reflect whether the put was successful or not. A (key, value) pair put attempt may fail if the cache is full, or the key already exists. size parameter is the current size of the cache prior to the put attempt.

func (*HeroCacheCollector) OnKeyPutDeduplicated added in v0.29.0

func (h *HeroCacheCollector) OnKeyPutDeduplicated()

OnKeyPutDeduplicated is tracking the total number of unsuccessful writes caused by adding a duplicate key to the cache. A duplicate key is dropped by the cache when it is written to the cache. Note: in context of HeroCache, the key corresponds to the identifier of its entity. Hence, a duplicate key corresponds to a duplicate entity.

func (*HeroCacheCollector) OnKeyPutDrop added in v0.29.0

func (h *HeroCacheCollector) OnKeyPutDrop()

OnKeyPutDrop is called whenever a new (key, entity) pair is dropped from the cache due to full cache.

func (*HeroCacheCollector) OnKeyPutSuccess added in v0.25.2

func (h *HeroCacheCollector) OnKeyPutSuccess(size uint32)

OnKeyPutSuccess is called whenever a new (key, entity) pair is successfully added to the cache. size parameter is the current size of the cache post insertion.

func (*HeroCacheCollector) OnKeyRemoved added in v0.29.0

func (h *HeroCacheCollector) OnKeyRemoved(size uint32)

OnKeyRemoved is called whenever a (key, entity) pair is removed from the cache. size parameter is the current size of the cache.

type HeroCacheMetricsFactory added in v0.31.0

type HeroCacheMetricsFactory func(namespace string, cacheName string) module.HeroCacheMetrics

HeroCacheMetricsFactory is a factory method to create a new HeroCacheCollector for a specific cache with a specific namespace and a specific name. Args: - namespace: the namespace of the cache - cacheName: the name of the cache

func NewHeroCacheMetricsFactory added in v0.31.0

func NewHeroCacheMetricsFactory(registrar prometheus.Registerer) HeroCacheMetricsFactory

NewHeroCacheMetricsFactory creates a new HeroCacheMetricsFactory for the given registrar. It allows to defer the registration of the metrics to the point where the cache is created without exposing the registrar to the cache. Args: - registrar: the prometheus registrar to register the metrics with Returns: - a HeroCacheMetricsFactory that can be used to create a new HeroCacheCollector for a specific cache

func NewNoopHeroCacheMetricsFactory added in v0.31.0

func NewNoopHeroCacheMetricsFactory() HeroCacheMetricsFactory

NewNoopHeroCacheMetricsFactory creates a new HeroCacheMetricsFactory that returns a noop collector. This is useful for tests that don't want to register metrics. Args: - none Returns: - a HeroCacheMetricsFactory that returns a noop collector

type HeroCacheMetricsRegistrationFunc added in v0.25.2

type HeroCacheMetricsRegistrationFunc func(uint64) module.HeroCacheMetrics

type HotstuffCollector

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

HotstuffCollector implements only the metrics emitted by the HotStuff core logic. We have multiple instances of HotStuff running within Flow: Consensus Nodes form the main consensus committee. In addition each Collector node cluster runs their own HotStuff instance. Depending on the node role, the name space is different. Furthermore, even within the `collection` name space, we need to separate metrics between the different clusters. We do this by adding the label `committeeID` to the HotStuff metrics and allowing for configurable name space.

func NewHotstuffCollector

func NewHotstuffCollector(chain flow.ChainID) *HotstuffCollector

func (*HotstuffCollector) BlockProcessingDuration added in v0.29.0

func (hc *HotstuffCollector) BlockProcessingDuration(duration time.Duration)

BlockProcessingDuration measures the time which the compliance engine spends to process one block proposal.

func (*HotstuffCollector) CommitteeProcessingDuration

func (hc *HotstuffCollector) CommitteeProcessingDuration(duration time.Duration)

CommitteeProcessingDuration measures the time which the HotStuff's core logic spends in the hotstuff.Committee component, i.e. the time determining consensus committee relations.

func (*HotstuffCollector) CountSkipped

func (hc *HotstuffCollector) CountSkipped()

CountSkipped counts the number of skips we did.

func (*HotstuffCollector) CountTimeout

func (hc *HotstuffCollector) CountTimeout()

CountTimeout tracks the number of views that this replica left due to observing a TC.

func (*HotstuffCollector) HotStuffBusyDuration

func (hc *HotstuffCollector) HotStuffBusyDuration(duration time.Duration, event string)

HotStuffBusyDuration reports Metrics C6 HotStuff Busy Duration

func (*HotstuffCollector) HotStuffIdleDuration

func (hc *HotstuffCollector) HotStuffIdleDuration(duration time.Duration)

HotStuffIdleDuration reports Metrics C6 HotStuff Idle Duration

func (*HotstuffCollector) HotStuffWaitDuration

func (hc *HotstuffCollector) HotStuffWaitDuration(duration time.Duration, event string)

HotStuffWaitDuration reports Metrics C6 HotStuff Idle Duration - the time between receiving and enqueueing a message to beginning to process that message.

func (*HotstuffCollector) PayloadProductionDuration

func (hc *HotstuffCollector) PayloadProductionDuration(duration time.Duration)

PayloadProductionDuration reports the time which the HotStuff's core logic spends in the module.Builder component, i.e. the with generating block payloads

func (*HotstuffCollector) SetCurView

func (hc *HotstuffCollector) SetCurView(view uint64)

SetCurView reports Metrics C8: Current View

func (*HotstuffCollector) SetQCView

func (hc *HotstuffCollector) SetQCView(view uint64)

SetQCView reports Metrics C9: View of Newest Known QC

func (*HotstuffCollector) SetTCView added in v0.29.0

func (hc *HotstuffCollector) SetTCView(view uint64)

SetTCView reports the view of the newest known TC

func (*HotstuffCollector) SetTimeout

func (hc *HotstuffCollector) SetTimeout(duration time.Duration)

SetTimeout sets the current timeout duration.

func (*HotstuffCollector) SignerProcessingDuration

func (hc *HotstuffCollector) SignerProcessingDuration(duration time.Duration)

SignerProcessingDuration reports the time which the HotStuff's core logic spends in the hotstuff.Signer component, i.e. the with crypto-related operations.

func (*HotstuffCollector) TimeoutObjectProcessingDuration added in v0.29.0

func (hc *HotstuffCollector) TimeoutObjectProcessingDuration(duration time.Duration)

TimeoutObjectProcessingDuration reports the processing time for a TimeoutObject

func (*HotstuffCollector) ValidatorProcessingDuration

func (hc *HotstuffCollector) ValidatorProcessingDuration(duration time.Duration)

ValidatorProcessingDuration reports the time which the HotStuff's core logic spends in the hotstuff.Validator component, i.e. the with verifying higher-level consensus messages.

func (*HotstuffCollector) VoteProcessingDuration added in v0.29.0

func (hc *HotstuffCollector) VoteProcessingDuration(duration time.Duration)

VoteProcessingDuration reports the processing time for a single vote

type LibP2PResourceManagerMetrics added in v0.29.0

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

func NewLibP2PResourceManagerMetrics added in v0.29.0

func NewLibP2PResourceManagerMetrics(logger zerolog.Logger, prefix string) *LibP2PResourceManagerMetrics

func (*LibP2PResourceManagerMetrics) AllowConn added in v0.29.0

func (l *LibP2PResourceManagerMetrics) AllowConn(dir network.Direction, usefd bool)

func (*LibP2PResourceManagerMetrics) AllowMemory added in v0.29.0

func (l *LibP2PResourceManagerMetrics) AllowMemory(size int)

func (*LibP2PResourceManagerMetrics) AllowPeer added in v0.29.0

func (l *LibP2PResourceManagerMetrics) AllowPeer(p peer.ID)

func (*LibP2PResourceManagerMetrics) AllowProtocol added in v0.29.0

func (l *LibP2PResourceManagerMetrics) AllowProtocol(proto protocol.ID)

func (*LibP2PResourceManagerMetrics) AllowService added in v0.29.0

func (l *LibP2PResourceManagerMetrics) AllowService(svc string)

func (*LibP2PResourceManagerMetrics) AllowStream added in v0.29.0

func (l *LibP2PResourceManagerMetrics) AllowStream(p peer.ID, dir network.Direction)

func (*LibP2PResourceManagerMetrics) BlockConn added in v0.29.0

func (l *LibP2PResourceManagerMetrics) BlockConn(dir network.Direction, usefd bool)

func (*LibP2PResourceManagerMetrics) BlockMemory added in v0.29.0

func (l *LibP2PResourceManagerMetrics) BlockMemory(size int)

func (*LibP2PResourceManagerMetrics) BlockPeer added in v0.29.0

func (l *LibP2PResourceManagerMetrics) BlockPeer(p peer.ID)

func (*LibP2PResourceManagerMetrics) BlockProtocol added in v0.29.0

func (l *LibP2PResourceManagerMetrics) BlockProtocol(proto protocol.ID)

func (*LibP2PResourceManagerMetrics) BlockProtocolPeer added in v0.29.0

func (l *LibP2PResourceManagerMetrics) BlockProtocolPeer(proto protocol.ID, p peer.ID)

func (*LibP2PResourceManagerMetrics) BlockService added in v0.29.0

func (l *LibP2PResourceManagerMetrics) BlockService(svc string)

func (*LibP2PResourceManagerMetrics) BlockServicePeer added in v0.29.0

func (l *LibP2PResourceManagerMetrics) BlockServicePeer(svc string, p peer.ID)

func (*LibP2PResourceManagerMetrics) BlockStream added in v0.29.0

func (l *LibP2PResourceManagerMetrics) BlockStream(p peer.ID, dir network.Direction)

type LoaderCollector

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

func NewLoaderCollector

func NewLoaderCollector() *LoaderCollector

func (*LoaderCollector) SetTPSConfigured

func (cc *LoaderCollector) SetTPSConfigured(tps uint)

func (*LoaderCollector) TransactionExecuted added in v0.27.0

func (cc *LoaderCollector) TransactionExecuted(duration time.Duration)

func (*LoaderCollector) TransactionLost added in v0.29.0

func (cc *LoaderCollector) TransactionLost()

func (*LoaderCollector) TransactionSent

func (cc *LoaderCollector) TransactionSent()

type MempoolCollector

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

func NewMempoolCollector

func NewMempoolCollector(interval time.Duration) *MempoolCollector

func (*MempoolCollector) Done

func (mc *MempoolCollector) Done() <-chan struct{}

func (*MempoolCollector) MempoolEntries

func (mc *MempoolCollector) MempoolEntries(resource string, entries uint)

func (*MempoolCollector) Ready

func (mc *MempoolCollector) Ready() <-chan struct{}

func (*MempoolCollector) Register

func (mc *MempoolCollector) Register(resource string, entriesFunc module.EntriesFunc) error

Register registers entriesFunc for a resource

type NetworkCollector

func NewNetworkCollector

func NewNetworkCollector(logger zerolog.Logger, opts ...NetworkCollectorOpt) *NetworkCollector

func (*NetworkCollector) DNSLookupDuration added in v0.21.0

func (nc *NetworkCollector) DNSLookupDuration(duration time.Duration)

DNSLookupDuration tracks the time spent to resolve a DNS address.

func (*NetworkCollector) DuplicateInboundMessagesDropped added in v0.29.1

func (nc *NetworkCollector) DuplicateInboundMessagesDropped(topic, protocol, messageType string)

DuplicateInboundMessagesDropped increments the metric tracking the number of duplicate messages dropped by the node.

func (*NetworkCollector) InboundConnections added in v0.12.0

func (nc *NetworkCollector) InboundConnections(connectionCount uint)

InboundConnections updates the metric tracking the number of inbound connections of this node

func (*NetworkCollector) InboundMessageReceived added in v0.29.1

func (nc *NetworkCollector) InboundMessageReceived(sizeBytes int, topic, protocol, messageType string)

InboundMessageReceived collects metrics related to a message received by the node.

func (*NetworkCollector) MessageAdded

func (nc *NetworkCollector) MessageAdded(priority int)

func (*NetworkCollector) MessageProcessingFinished added in v0.24.7

func (nc *NetworkCollector) MessageProcessingFinished(topic string, duration time.Duration)

MessageProcessingFinished tracks the time spent by the node to process a message and decrements the metric tracking the number of messages being processed by the node.

func (*NetworkCollector) MessageProcessingStarted added in v0.24.7

func (nc *NetworkCollector) MessageProcessingStarted(topic string)

MessageProcessingStarted increments the metric tracking the number of messages being processed by the node.

func (*NetworkCollector) MessageRemoved

func (nc *NetworkCollector) MessageRemoved(priority int)

func (*NetworkCollector) OnDNSCacheHit added in v0.21.0

func (nc *NetworkCollector) OnDNSCacheHit()

OnDNSCacheHit tracks the total number of dns requests resolved through the cache without looking up the network.

func (*NetworkCollector) OnDNSCacheInvalidated added in v0.21.0

func (nc *NetworkCollector) OnDNSCacheInvalidated()

OnDNSCacheInvalidated is called whenever dns cache is invalidated for an entry

func (*NetworkCollector) OnDNSCacheMiss added in v0.21.0

func (nc *NetworkCollector) OnDNSCacheMiss()

OnDNSCacheMiss tracks the total number of dns requests resolved through looking up the network.

func (*NetworkCollector) OnDNSLookupRequestDropped added in v0.23.9

func (nc *NetworkCollector) OnDNSLookupRequestDropped()

OnDNSLookupRequestDropped tracks the number of dns lookup requests that are dropped due to a full queue

func (*NetworkCollector) OnRateLimitedPeer added in v0.30.0

func (nc *NetworkCollector) OnRateLimitedPeer(peerID peer.ID, role, msgType, topic, reason string)

OnRateLimitedPeer tracks the number of rate limited messages seen on the network.

func (*NetworkCollector) OnUnauthorizedMessage added in v0.28.0

func (nc *NetworkCollector) OnUnauthorizedMessage(role, msgType, topic, offense string)

OnUnauthorizedMessage tracks the number of unauthorized messages seen on the network.

func (*NetworkCollector) OutboundConnections added in v0.12.0

func (nc *NetworkCollector) OutboundConnections(connectionCount uint)

OutboundConnections updates the metric tracking the number of outbound connections of this node

func (*NetworkCollector) OutboundMessageSent added in v0.29.1

func (nc *NetworkCollector) OutboundMessageSent(sizeBytes int, topic, protocol, messageType string)

OutboundMessageSent collects metrics related to a message sent by the node.

func (*NetworkCollector) QueueDuration

func (nc *NetworkCollector) QueueDuration(duration time.Duration, priority int)

func (*NetworkCollector) RoutingTablePeerAdded added in v0.26.11

func (nc *NetworkCollector) RoutingTablePeerAdded()

func (*NetworkCollector) RoutingTablePeerRemoved added in v0.26.11

func (nc *NetworkCollector) RoutingTablePeerRemoved()

func (*NetworkCollector) UnicastMessageSendingCompleted added in v0.29.1

func (nc *NetworkCollector) UnicastMessageSendingCompleted(topic string)

UnicastMessageSendingCompleted decrements the metric tracking the number of unicast messages sent by the node.

func (*NetworkCollector) UnicastMessageSendingStarted added in v0.29.1

func (nc *NetworkCollector) UnicastMessageSendingStarted(topic string)

UnicastMessageSendingStarted increments the metric tracking the number of unicast messages sent by the node.

type NetworkCollectorOpt added in v0.23.9

type NetworkCollectorOpt func(*NetworkCollector)

func WithNetworkPrefix added in v0.23.9

func WithNetworkPrefix(prefix string) NetworkCollectorOpt

type NodeInfoCollector added in v0.29.6

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

NodeInfoCollector implements metrics to report static information about node. Such information can include: version, commit, sporkID.

func NewNodeInfoCollector added in v0.29.6

func NewNodeInfoCollector() *NodeInfoCollector

func (*NodeInfoCollector) NodeInfo added in v0.29.6

func (sc *NodeInfoCollector) NodeInfo(version, commit, sporkID string, protocolVersion uint)

type NoopCollector

type NoopCollector struct{}

func NewNoopCollector

func NewNoopCollector() *NoopCollector

func (*NoopCollector) AddBlobsFailed added in v0.27.2

func (nc *NoopCollector) AddBlobsFailed()

func (*NoopCollector) AddBlobsSucceeded added in v0.27.2

func (nc *NoopCollector) AddBlobsSucceeded(duration time.Duration, totalSize uint64)

func (*NoopCollector) AddInflightRequests added in v0.29.12

func (nc *NoopCollector) AddInflightRequests(context.Context, httpmetrics.HTTPProperties, int)

func (*NoopCollector) AddTotalRequests added in v0.29.12

func (nc *NoopCollector) AddTotalRequests(context.Context, string, string)

func (*NoopCollector) AllowConn added in v0.29.0

func (nc *NoopCollector) AllowConn(network.Direction, bool)

func (*NoopCollector) AllowMemory added in v0.29.0

func (nc *NoopCollector) AllowMemory(int)

func (*NoopCollector) AllowPeer added in v0.29.0

func (nc *NoopCollector) AllowPeer(peer.ID)

func (*NoopCollector) AllowProtocol added in v0.29.0

func (nc *NoopCollector) AllowProtocol(protocol.ID)

func (*NoopCollector) AllowService added in v0.29.0

func (nc *NoopCollector) AllowService(string)

func (*NoopCollector) AllowStream added in v0.29.0

func (nc *NoopCollector) AllowStream(peer.ID, network.Direction)

func (*NoopCollector) AsyncProcessingFinished added in v0.31.0

func (nc *NoopCollector) AsyncProcessingFinished(string, time.Duration)

func (*NoopCollector) AsyncProcessingStarted added in v0.31.0

func (nc *NoopCollector) AsyncProcessingStarted(string)

func (*NoopCollector) BadgerLSMSize

func (nc *NoopCollector) BadgerLSMSize(sizeBytes int64)

func (*NoopCollector) BadgerNumBlockedPuts

func (nc *NoopCollector) BadgerNumBlockedPuts(n int64)

func (*NoopCollector) BadgerNumBytesRead

func (nc *NoopCollector) BadgerNumBytesRead(n int64)

func (*NoopCollector) BadgerNumBytesWritten

func (nc *NoopCollector) BadgerNumBytesWritten(n int64)

func (*NoopCollector) BadgerNumGets

func (nc *NoopCollector) BadgerNumGets(n int64)

func (*NoopCollector) BadgerNumMemtableGets

func (nc *NoopCollector) BadgerNumMemtableGets(n int64)

func (*NoopCollector) BadgerNumPuts

func (nc *NoopCollector) BadgerNumPuts(n int64)

func (*NoopCollector) BadgerNumReads

func (nc *NoopCollector) BadgerNumReads(n int64)

func (*NoopCollector) BadgerNumWrites

func (nc *NoopCollector) BadgerNumWrites(n int64)

func (*NoopCollector) BadgerVLogSize

func (nc *NoopCollector) BadgerVLogSize(sizeBytes int64)

func (*NoopCollector) BatchRequested added in v0.27.0

func (nc *NoopCollector) BatchRequested(batch chainsync.Batch)

func (*NoopCollector) BlobsReceived added in v0.27.3

func (nc *NoopCollector) BlobsReceived(prefix string, n uint64)

func (*NoopCollector) BlobsSent added in v0.27.3

func (nc *NoopCollector) BlobsSent(prefix string, n uint64)

func (*NoopCollector) BlockConn added in v0.29.0

func (nc *NoopCollector) BlockConn(network.Direction, bool)

func (*NoopCollector) BlockFinalized

func (nc *NoopCollector) BlockFinalized(*flow.Block)

func (*NoopCollector) BlockMemory added in v0.29.0

func (nc *NoopCollector) BlockMemory(int)

func (*NoopCollector) BlockPeer added in v0.29.0

func (nc *NoopCollector) BlockPeer(peer.ID)

func (*NoopCollector) BlockProcessingDuration added in v0.29.0

func (nc *NoopCollector) BlockProcessingDuration(time.Duration)

func (*NoopCollector) BlockProposalDuration added in v0.15.0

func (nc *NoopCollector) BlockProposalDuration(duration time.Duration)

func (*NoopCollector) BlockProposed

func (nc *NoopCollector) BlockProposed(*flow.Block)

func (*NoopCollector) BlockProtocol added in v0.29.0

func (nc *NoopCollector) BlockProtocol(protocol.ID)

func (*NoopCollector) BlockProtocolPeer added in v0.29.0

func (nc *NoopCollector) BlockProtocolPeer(protocol.ID, peer.ID)

func (*NoopCollector) BlockSealed

func (nc *NoopCollector) BlockSealed(*flow.Block)

func (*NoopCollector) BlockService added in v0.29.0

func (nc *NoopCollector) BlockService(string)

func (*NoopCollector) BlockServicePeer added in v0.29.0

func (nc *NoopCollector) BlockServicePeer(string, peer.ID)

func (*NoopCollector) BlockStream added in v0.29.0

func (nc *NoopCollector) BlockStream(peer.ID, network.Direction)

func (*NoopCollector) BlockingPreProcessingFinished added in v0.31.0

func (nc *NoopCollector) BlockingPreProcessingFinished(string, uint, time.Duration)

func (*NoopCollector) BlockingPreProcessingStarted added in v0.31.0

func (nc *NoopCollector) BlockingPreProcessingStarted(string, uint)

func (*NoopCollector) BucketAvailableSlots added in v0.25.2

func (nc *NoopCollector) BucketAvailableSlots(uint64, uint64)

func (*NoopCollector) CacheEntries

func (nc *NoopCollector) CacheEntries(resource string, entries uint)

func (*NoopCollector) CacheHit

func (nc *NoopCollector) CacheHit(resource string)

func (*NoopCollector) CacheMiss

func (nc *NoopCollector) CacheMiss(resource string)

func (*NoopCollector) CacheNotFound added in v0.16.0

func (nc *NoopCollector) CacheNotFound(resource string)

func (*NoopCollector) CheckSealingDuration added in v0.11.0

func (nc *NoopCollector) CheckSealingDuration(duration time.Duration)

func (*NoopCollector) ChunkDataPackRequestProcessed added in v0.28.0

func (nc *NoopCollector) ChunkDataPackRequestProcessed()

func (*NoopCollector) ClusterBlockFinalized

func (nc *NoopCollector) ClusterBlockFinalized(*cluster.Block)

func (*NoopCollector) ClusterBlockProposed

func (nc *NoopCollector) ClusterBlockProposed(*cluster.Block)

func (*NoopCollector) CommittedEpochFinalView added in v0.18.3

func (nc *NoopCollector) CommittedEpochFinalView(view uint64)

func (*NoopCollector) CommitteeProcessingDuration

func (nc *NoopCollector) CommitteeProcessingDuration(duration time.Duration)

func (*NoopCollector) ConnectionAddedToPool added in v0.26.17

func (nc *NoopCollector) ConnectionAddedToPool()

func (*NoopCollector) ConnectionFromPoolEvicted added in v0.26.17

func (nc *NoopCollector) ConnectionFromPoolEvicted()

func (*NoopCollector) ConnectionFromPoolInvalidated added in v0.26.17

func (nc *NoopCollector) ConnectionFromPoolInvalidated()

func (*NoopCollector) ConnectionFromPoolReused added in v0.26.17

func (nc *NoopCollector) ConnectionFromPoolReused()

func (*NoopCollector) ConnectionFromPoolUpdated added in v0.26.17

func (nc *NoopCollector) ConnectionFromPoolUpdated()

func (*NoopCollector) CountSkipped

func (nc *NoopCollector) CountSkipped()

func (*NoopCollector) CountTimeout

func (nc *NoopCollector) CountTimeout()

func (*NoopCollector) CurrentDKGPhase1FinalView added in v0.21.0

func (nc *NoopCollector) CurrentDKGPhase1FinalView(view uint64)

func (*NoopCollector) CurrentDKGPhase2FinalView added in v0.21.0

func (nc *NoopCollector) CurrentDKGPhase2FinalView(view uint64)

func (*NoopCollector) CurrentDKGPhase3FinalView added in v0.21.0

func (nc *NoopCollector) CurrentDKGPhase3FinalView(view uint64)

func (*NoopCollector) CurrentEpochCounter added in v0.20.0

func (nc *NoopCollector) CurrentEpochCounter(counter uint64)

func (*NoopCollector) CurrentEpochFinalView added in v0.21.0

func (nc *NoopCollector) CurrentEpochFinalView(view uint64)

func (*NoopCollector) CurrentEpochPhase added in v0.20.0

func (nc *NoopCollector) CurrentEpochPhase(phase flow.EpochPhase)

func (*NoopCollector) DNSLookupDuration added in v0.21.0

func (nc *NoopCollector) DNSLookupDuration(duration time.Duration)

func (*NoopCollector) DataReceived added in v0.27.3

func (nc *NoopCollector) DataReceived(prefix string, n uint64)

func (*NoopCollector) DataSent added in v0.27.3

func (nc *NoopCollector) DataSent(prefix string, n uint64)

func (*NoopCollector) DirectMessageFinished added in v0.24.7

func (nc *NoopCollector) DirectMessageFinished(topic string)

func (*NoopCollector) DirectMessageStarted added in v0.24.7

func (nc *NoopCollector) DirectMessageStarted(topic string)

func (*NoopCollector) DupBlobsReceived added in v0.27.3

func (nc *NoopCollector) DupBlobsReceived(prefix string, n uint64)

func (*NoopCollector) DupDataReceived added in v0.27.3

func (nc *NoopCollector) DupDataReceived(prefix string, n uint64)

func (*NoopCollector) DuplicateInboundMessagesDropped added in v0.29.1

func (nc *NoopCollector) DuplicateInboundMessagesDropped(string, string, string)

func (*NoopCollector) EmergencySeal added in v0.14.0

func (nc *NoopCollector) EmergencySeal()

func (*NoopCollector) EpochEmergencyFallbackTriggered added in v0.23.2

func (nc *NoopCollector) EpochEmergencyFallbackTriggered()

func (*NoopCollector) EpochTransitionHeight added in v0.30.0

func (nc *NoopCollector) EpochTransitionHeight(height uint64)

func (*NoopCollector) ExecutionBlockCachedPrograms added in v0.29.17

func (nc *NoopCollector) ExecutionBlockCachedPrograms(programs int)

func (*NoopCollector) ExecutionBlockDataUploadFinished added in v0.20.6

func (nc *NoopCollector) ExecutionBlockDataUploadFinished(dur time.Duration)

func (*NoopCollector) ExecutionBlockDataUploadStarted added in v0.20.6

func (nc *NoopCollector) ExecutionBlockDataUploadStarted()

func (*NoopCollector) ExecutionBlockExecuted added in v0.18.3

func (nc *NoopCollector) ExecutionBlockExecuted(_ time.Duration, _ module.ExecutionResultStats)

func (*NoopCollector) ExecutionBlockExecutionEffortVectorComponent added in v0.28.2

func (nc *NoopCollector) ExecutionBlockExecutionEffortVectorComponent(_ string, _ uint)

func (*NoopCollector) ExecutionChunkDataPackGenerated added in v0.28.7

func (nc *NoopCollector) ExecutionChunkDataPackGenerated(_, _ int)

func (*NoopCollector) ExecutionCollectionExecuted added in v0.18.3

func (nc *NoopCollector) ExecutionCollectionExecuted(_ time.Duration, _ module.ExecutionResultStats)

func (*NoopCollector) ExecutionCollectionRequestRetried

func (nc *NoopCollector) ExecutionCollectionRequestRetried()

func (*NoopCollector) ExecutionCollectionRequestSent

func (nc *NoopCollector) ExecutionCollectionRequestSent()

func (*NoopCollector) ExecutionComputationResultUploadRetried added in v0.28.0

func (nc *NoopCollector) ExecutionComputationResultUploadRetried()

func (*NoopCollector) ExecutionComputationResultUploaded added in v0.28.0

func (nc *NoopCollector) ExecutionComputationResultUploaded()

func (*NoopCollector) ExecutionComputationUsedPerBlock added in v0.18.3

func (nc *NoopCollector) ExecutionComputationUsedPerBlock(computation uint64)

func (*NoopCollector) ExecutionDataFetchFinished added in v0.26.2

func (nc *NoopCollector) ExecutionDataFetchFinished(_ time.Duration, _ bool, _ uint64)

func (*NoopCollector) ExecutionDataFetchStarted added in v0.26.2

func (nc *NoopCollector) ExecutionDataFetchStarted()

func (*NoopCollector) ExecutionLastExecutedBlockHeight

func (nc *NoopCollector) ExecutionLastExecutedBlockHeight(height uint64)

func (*NoopCollector) ExecutionScriptExecuted added in v0.18.3

func (nc *NoopCollector) ExecutionScriptExecuted(dur time.Duration, compUsed, _, _ uint64)

func (*NoopCollector) ExecutionStorageStateCommitment

func (nc *NoopCollector) ExecutionStorageStateCommitment(bytes int64)

func (*NoopCollector) ExecutionSync

func (nc *NoopCollector) ExecutionSync(syncing bool)

func (*NoopCollector) ExecutionTransactionExecuted added in v0.18.3

func (nc *NoopCollector) ExecutionTransactionExecuted(_ time.Duration, _, _ uint64, _, _ int, _ bool)

func (*NoopCollector) FetchRetried added in v0.26.2

func (nc *NoopCollector) FetchRetried()

func (*NoopCollector) FinalizedHeight

func (nc *NoopCollector) FinalizedHeight(height uint64)

func (*NoopCollector) FinishBlockReceivedToExecuted

func (nc *NoopCollector) FinishBlockReceivedToExecuted(blockID flow.Identifier)

func (*NoopCollector) FinishBlockToSeal

func (nc *NoopCollector) FinishBlockToSeal(blockID flow.Identifier)

func (*NoopCollector) FinishCollectionToFinalized

func (nc *NoopCollector) FinishCollectionToFinalized(collectionID flow.Identifier)

func (*NoopCollector) ForestApproxMemorySize

func (nc *NoopCollector) ForestApproxMemorySize(bytes uint64)

func (*NoopCollector) ForestNumberOfTrees

func (nc *NoopCollector) ForestNumberOfTrees(number uint64)

func (*NoopCollector) FulfilledHeight added in v0.27.2

func (nc *NoopCollector) FulfilledHeight(blockHeight uint64)

func (*NoopCollector) HotStuffBusyDuration

func (nc *NoopCollector) HotStuffBusyDuration(duration time.Duration, event string)

func (*NoopCollector) HotStuffIdleDuration

func (nc *NoopCollector) HotStuffIdleDuration(duration time.Duration)

func (*NoopCollector) HotStuffWaitDuration

func (nc *NoopCollector) HotStuffWaitDuration(duration time.Duration, event string)

func (*NoopCollector) InboundConnections added in v0.12.0

func (nc *NoopCollector) InboundConnections(_ uint)

func (*NoopCollector) InboundMessageDropped added in v0.29.0

func (nc *NoopCollector) InboundMessageDropped(engine string, message string)

func (*NoopCollector) InboundMessageReceived added in v0.29.1

func (nc *NoopCollector) InboundMessageReceived(int, string, string, string)

func (*NoopCollector) LatestTrieMaxDepthTouched added in v0.25.2

func (nc *NoopCollector) LatestTrieMaxDepthTouched(maxDepth uint16)

func (*NoopCollector) LatestTrieRegCount

func (nc *NoopCollector) LatestTrieRegCount(number uint64)

func (*NoopCollector) LatestTrieRegCountDiff

func (nc *NoopCollector) LatestTrieRegCountDiff(number int64)

func (*NoopCollector) LatestTrieRegSize added in v0.25.2

func (nc *NoopCollector) LatestTrieRegSize(size uint64)

func (*NoopCollector) LatestTrieRegSizeDiff added in v0.25.2

func (nc *NoopCollector) LatestTrieRegSizeDiff(size int64)

func (*NoopCollector) MempoolEntries

func (nc *NoopCollector) MempoolEntries(resource string, entries uint)

func (*NoopCollector) MessageAdded

func (nc *NoopCollector) MessageAdded(priority int)

func (*NoopCollector) MessageHandled

func (nc *NoopCollector) MessageHandled(engine string, message string)

func (*NoopCollector) MessageProcessingFinished added in v0.24.7

func (nc *NoopCollector) MessageProcessingFinished(topic string, duration time.Duration)

func (*NoopCollector) MessageProcessingStarted added in v0.24.7

func (nc *NoopCollector) MessageProcessingStarted(topic string)

func (*NoopCollector) MessageReceived

func (nc *NoopCollector) MessageReceived(engine string, message string)

func (*NoopCollector) MessageRemoved

func (nc *NoopCollector) MessageRemoved(priority int)

func (*NoopCollector) MessageSent

func (nc *NoopCollector) MessageSent(engine string, message string)

func (*NoopCollector) MessagesReceived added in v0.27.3

func (nc *NoopCollector) MessagesReceived(prefix string, n uint64)

func (*NoopCollector) NetworkDuplicateMessagesDropped

func (nc *NoopCollector) NetworkDuplicateMessagesDropped(topic string, messageType string)

func (*NoopCollector) NetworkMessageReceived

func (nc *NoopCollector) NetworkMessageReceived(sizeBytes int, topic string, messageType string)

func (*NoopCollector) NetworkMessageSent

func (nc *NoopCollector) NetworkMessageSent(sizeBytes int, topic string, messageType string)

func (*NoopCollector) NewConnectionEstablished added in v0.26.17

func (nc *NoopCollector) NewConnectionEstablished()

func (*NoopCollector) NotificationSent added in v0.26.2

func (nc *NoopCollector) NotificationSent(height uint64)

func (*NoopCollector) ObserveHTTPRequestDuration added in v0.29.12

func (nc *NoopCollector) ObserveHTTPRequestDuration(context.Context, httpmetrics.HTTPReqProperties, time.Duration)

func (*NoopCollector) ObserveHTTPResponseSize added in v0.29.12

func (nc *NoopCollector) ObserveHTTPResponseSize(context.Context, httpmetrics.HTTPReqProperties, int64)

func (*NoopCollector) OnAppSpecificScoreUpdated added in v0.30.0

func (nc *NoopCollector) OnAppSpecificScoreUpdated(f float64)

func (*NoopCollector) OnApprovalProcessingDuration added in v0.14.1

func (nc *NoopCollector) OnApprovalProcessingDuration(duration time.Duration)

func (*NoopCollector) OnAssignedChunkProcessedAtAssigner added in v0.17.1

func (nc *NoopCollector) OnAssignedChunkProcessedAtAssigner()

func (*NoopCollector) OnAssignedChunkReceivedAtFetcher added in v0.17.1

func (nc *NoopCollector) OnAssignedChunkReceivedAtFetcher()

func (*NoopCollector) OnBehaviourPenaltyUpdated added in v0.30.0

func (nc *NoopCollector) OnBehaviourPenaltyUpdated(f float64)

func (*NoopCollector) OnBlockConsumerJobDone added in v0.19.0

func (nc *NoopCollector) OnBlockConsumerJobDone(uint64)

func (*NoopCollector) OnChunkConsumerJobDone added in v0.19.0

func (nc *NoopCollector) OnChunkConsumerJobDone(uint64)

func (*NoopCollector) OnChunkDataPackArrivedAtFetcher added in v0.17.1

func (nc *NoopCollector) OnChunkDataPackArrivedAtFetcher()

func (*NoopCollector) OnChunkDataPackRequestDispatchedInNetworkByRequester added in v0.19.0

func (nc *NoopCollector) OnChunkDataPackRequestDispatchedInNetworkByRequester()

func (*NoopCollector) OnChunkDataPackRequestReceivedByRequester added in v0.17.1

func (nc *NoopCollector) OnChunkDataPackRequestReceivedByRequester()

func (*NoopCollector) OnChunkDataPackRequestSentByFetcher added in v0.17.1

func (nc *NoopCollector) OnChunkDataPackRequestSentByFetcher()

func (*NoopCollector) OnChunkDataPackResponseReceivedFromNetworkByRequester added in v0.19.0

func (nc *NoopCollector) OnChunkDataPackResponseReceivedFromNetworkByRequester()

func (*NoopCollector) OnChunkDataPackSentToFetcher added in v0.17.1

func (nc *NoopCollector) OnChunkDataPackSentToFetcher()

func (*NoopCollector) OnChunksAssignmentDoneAtAssigner added in v0.17.1

func (nc *NoopCollector) OnChunksAssignmentDoneAtAssigner(chunks int)

func (*NoopCollector) OnDNSCacheHit added in v0.21.0

func (nc *NoopCollector) OnDNSCacheHit()

func (*NoopCollector) OnDNSCacheInvalidated added in v0.21.0

func (nc *NoopCollector) OnDNSCacheInvalidated()

func (*NoopCollector) OnDNSCacheMiss added in v0.21.0

func (nc *NoopCollector) OnDNSCacheMiss()

func (*NoopCollector) OnDNSLookupRequestDropped added in v0.23.9

func (nc *NoopCollector) OnDNSLookupRequestDropped()

func (*NoopCollector) OnEntityEjectionDueToEmergency added in v0.25.2

func (nc *NoopCollector) OnEntityEjectionDueToEmergency()

func (*NoopCollector) OnEntityEjectionDueToFullCapacity added in v0.25.2

func (nc *NoopCollector) OnEntityEjectionDueToFullCapacity()

func (*NoopCollector) OnEstablishStreamFailure added in v0.30.0

func (nc *NoopCollector) OnEstablishStreamFailure(duration time.Duration, attempts int)

func (*NoopCollector) OnExecutionResultReceivedAtAssignerEngine added in v0.19.0

func (nc *NoopCollector) OnExecutionResultReceivedAtAssignerEngine()

func (*NoopCollector) OnFinalizedBlockArrivedAtAssigner added in v0.17.1

func (nc *NoopCollector) OnFinalizedBlockArrivedAtAssigner(height uint64)

func (*NoopCollector) OnFirstMessageDeliveredUpdated added in v0.30.0

func (nc *NoopCollector) OnFirstMessageDeliveredUpdated(topic channels.Topic, f float64)

func (*NoopCollector) OnGraftReceived added in v0.29.0

func (nc *NoopCollector) OnGraftReceived(int)

func (*NoopCollector) OnIHaveReceived added in v0.29.0

func (nc *NoopCollector) OnIHaveReceived(int)

func (*NoopCollector) OnIPColocationFactorUpdated added in v0.30.0

func (nc *NoopCollector) OnIPColocationFactorUpdated(f float64)

func (*NoopCollector) OnIWantReceived added in v0.29.0

func (nc *NoopCollector) OnIWantReceived(int)

func (*NoopCollector) OnIncomingRpcAcceptedFully added in v0.29.0

func (nc *NoopCollector) OnIncomingRpcAcceptedFully()

func (*NoopCollector) OnIncomingRpcAcceptedOnlyForControlMessages added in v0.29.0

func (nc *NoopCollector) OnIncomingRpcAcceptedOnlyForControlMessages()

func (*NoopCollector) OnIncomingRpcRejected added in v0.29.0

func (nc *NoopCollector) OnIncomingRpcRejected()

func (*NoopCollector) OnInvalidMessageDeliveredUpdated added in v0.30.0

func (nc *NoopCollector) OnInvalidMessageDeliveredUpdated(topic channels.Topic, f float64)

func (*NoopCollector) OnKeyGetFailure added in v0.25.2

func (nc *NoopCollector) OnKeyGetFailure()

func (*NoopCollector) OnKeyGetSuccess added in v0.25.2

func (nc *NoopCollector) OnKeyGetSuccess()

func (*NoopCollector) OnKeyPutAttempt added in v0.29.0

func (nc *NoopCollector) OnKeyPutAttempt(uint32)

func (*NoopCollector) OnKeyPutDeduplicated added in v0.29.0

func (nc *NoopCollector) OnKeyPutDeduplicated()

func (*NoopCollector) OnKeyPutDrop added in v0.29.0

func (nc *NoopCollector) OnKeyPutDrop()

func (*NoopCollector) OnKeyPutSuccess added in v0.25.2

func (nc *NoopCollector) OnKeyPutSuccess(uint32)

func (*NoopCollector) OnKeyRemoved added in v0.29.0

func (nc *NoopCollector) OnKeyRemoved(uint32)

func (*NoopCollector) OnLocalMeshSizeUpdated added in v0.30.0

func (nc *NoopCollector) OnLocalMeshSizeUpdated(string, int)

func (*NoopCollector) OnMeshMessageDeliveredUpdated added in v0.30.0

func (nc *NoopCollector) OnMeshMessageDeliveredUpdated(topic channels.Topic, f float64)

func (*NoopCollector) OnMisbehaviorReported added in v0.31.0

func (nc *NoopCollector) OnMisbehaviorReported(string, string)

func (*NoopCollector) OnOverallPeerScoreUpdated added in v0.30.0

func (nc *NoopCollector) OnOverallPeerScoreUpdated(f float64)

func (*NoopCollector) OnPeerDialFailure added in v0.30.0

func (nc *NoopCollector) OnPeerDialFailure(duration time.Duration, attempts int)

func (*NoopCollector) OnPeerDialed added in v0.30.0

func (nc *NoopCollector) OnPeerDialed(duration time.Duration, attempts int)

func (*NoopCollector) OnPruneReceived added in v0.29.0

func (nc *NoopCollector) OnPruneReceived(int)

func (*NoopCollector) OnPublishedGossipMessagesReceived added in v0.29.0

func (nc *NoopCollector) OnPublishedGossipMessagesReceived(int)

func (*NoopCollector) OnRateLimitedPeer added in v0.30.0

func (nc *NoopCollector) OnRateLimitedPeer(pid peer.ID, role, msgType, topic, reason string)

func (*NoopCollector) OnRateLimitedUnicastMessage added in v0.28.0

func (nc *NoopCollector) OnRateLimitedUnicastMessage(role, msgType, topic, reason string)

func (*NoopCollector) OnReceiptProcessingDuration added in v0.14.1

func (nc *NoopCollector) OnReceiptProcessingDuration(duration time.Duration)

func (*NoopCollector) OnResultApprovalDispatchedInNetworkByVerifier added in v0.19.0

func (nc *NoopCollector) OnResultApprovalDispatchedInNetworkByVerifier()

func (*NoopCollector) OnStreamCreated added in v0.30.0

func (nc *NoopCollector) OnStreamCreated(duration time.Duration, attempts int)

func (*NoopCollector) OnStreamCreationFailure added in v0.30.0

func (nc *NoopCollector) OnStreamCreationFailure(duration time.Duration, attempts int)

func (*NoopCollector) OnStreamEstablished added in v0.30.0

func (nc *NoopCollector) OnStreamEstablished(duration time.Duration, attempts int)

func (*NoopCollector) OnTimeInMeshUpdated added in v0.30.0

func (nc *NoopCollector) OnTimeInMeshUpdated(topic channels.Topic, duration time.Duration)

func (*NoopCollector) OnUnauthorizedMessage added in v0.28.0

func (nc *NoopCollector) OnUnauthorizedMessage(role, msgType, topic, offense string)

func (*NoopCollector) OnVerifiableChunkReceivedAtVerifierEngine added in v0.17.1

func (nc *NoopCollector) OnVerifiableChunkReceivedAtVerifierEngine()

func (*NoopCollector) OnVerifiableChunkSentToVerifier added in v0.17.1

func (nc *NoopCollector) OnVerifiableChunkSentToVerifier()

func (*NoopCollector) OutboundConnections added in v0.12.0

func (nc *NoopCollector) OutboundConnections(_ uint)

func (*NoopCollector) OutboundMessageDropped added in v0.29.0

func (nc *NoopCollector) OutboundMessageDropped(engine string, messages string)

func (*NoopCollector) OutboundMessageSent added in v0.29.1

func (nc *NoopCollector) OutboundMessageSent(int, string, string, string)

func (*NoopCollector) PayloadProductionDuration

func (nc *NoopCollector) PayloadProductionDuration(duration time.Duration)

func (*NoopCollector) Peers added in v0.27.3

func (nc *NoopCollector) Peers(prefix string, n int)

func (*NoopCollector) ProofSize

func (nc *NoopCollector) ProofSize(bytes uint32)

func (*NoopCollector) Pruned added in v0.27.2

func (nc *NoopCollector) Pruned(height uint64, duration time.Duration)

func (*NoopCollector) PrunedBlockByHeight added in v0.27.0

func (nc *NoopCollector) PrunedBlockByHeight(status *chainsync.Status)

func (*NoopCollector) PrunedBlockById added in v0.27.0

func (nc *NoopCollector) PrunedBlockById(status *chainsync.Status)

func (*NoopCollector) PrunedBlocks added in v0.27.0

func (nc *NoopCollector) PrunedBlocks(totalByHeight, totalById, storedByHeight, storedById int)

func (*NoopCollector) QueueDuration

func (nc *NoopCollector) QueueDuration(duration time.Duration, priority int)

func (*NoopCollector) RanGC

func (nc *NoopCollector) RanGC(duration time.Duration)

func (*NoopCollector) RangeRequested added in v0.27.0

func (nc *NoopCollector) RangeRequested(ran chainsync.Range)

func (*NoopCollector) ReadDuration

func (nc *NoopCollector) ReadDuration(duration time.Duration)

func (*NoopCollector) ReadDurationPerItem

func (nc *NoopCollector) ReadDurationPerItem(duration time.Duration)

func (*NoopCollector) ReadValuesNumber

func (nc *NoopCollector) ReadValuesNumber(number uint64)

func (*NoopCollector) ReadValuesSize

func (nc *NoopCollector) ReadValuesSize(byte uint64)

func (*NoopCollector) ReceiptSkipped added in v0.27.2

func (nc *NoopCollector) ReceiptSkipped()

func (*NoopCollector) Register

func (nc *NoopCollector) Register(resource string, entriesFunc module.EntriesFunc) error

func (*NoopCollector) RequestCanceled added in v0.27.2

func (nc *NoopCollector) RequestCanceled()

func (*NoopCollector) RequestFailed added in v0.27.2

func (nc *NoopCollector) RequestFailed(duration time.Duration, retryable bool)

func (*NoopCollector) RequestSucceeded added in v0.27.2

func (nc *NoopCollector) RequestSucceeded(blockHeight uint64, duration time.Duration, totalSize uint64, numberOfAttempts int)

func (*NoopCollector) ResponseDropped added in v0.27.2

func (nc *NoopCollector) ResponseDropped()

func (*NoopCollector) RootIDComputed added in v0.27.2

func (nc *NoopCollector) RootIDComputed(duration time.Duration, numberOfChunks int)

func (*NoopCollector) RoutingTablePeerAdded added in v0.26.11

func (nc *NoopCollector) RoutingTablePeerAdded()

func (*NoopCollector) RoutingTablePeerRemoved added in v0.26.11

func (nc *NoopCollector) RoutingTablePeerRemoved()

func (*NoopCollector) RuntimeSetNumberOfAccounts added in v0.18.3

func (nc *NoopCollector) RuntimeSetNumberOfAccounts(count uint64)

func (*NoopCollector) RuntimeTransactionChecked added in v0.18.3

func (nc *NoopCollector) RuntimeTransactionChecked(dur time.Duration)

func (*NoopCollector) RuntimeTransactionInterpreted added in v0.18.3

func (nc *NoopCollector) RuntimeTransactionInterpreted(dur time.Duration)

func (*NoopCollector) RuntimeTransactionParsed added in v0.18.3

func (nc *NoopCollector) RuntimeTransactionParsed(dur time.Duration)

func (*NoopCollector) RuntimeTransactionProgramsCacheHit added in v0.29.17

func (nc *NoopCollector) RuntimeTransactionProgramsCacheHit()

func (*NoopCollector) RuntimeTransactionProgramsCacheMiss added in v0.29.17

func (nc *NoopCollector) RuntimeTransactionProgramsCacheMiss()

func (*NoopCollector) ScriptExecuted added in v0.26.1

func (nc *NoopCollector) ScriptExecuted(dur time.Duration, size int)

func (*NoopCollector) ScriptExecutionErrorMatch added in v0.32.0

func (nc *NoopCollector) ScriptExecutionErrorMatch()

func (*NoopCollector) ScriptExecutionErrorMismatch added in v0.32.0

func (nc *NoopCollector) ScriptExecutionErrorMismatch()

func (*NoopCollector) ScriptExecutionErrorOnArchiveNode added in v0.31.11

func (nc *NoopCollector) ScriptExecutionErrorOnArchiveNode()

func (*NoopCollector) ScriptExecutionErrorOnExecutionNode added in v0.31.11

func (nc *NoopCollector) ScriptExecutionErrorOnExecutionNode()

func (*NoopCollector) ScriptExecutionResultMatch added in v0.32.0

func (nc *NoopCollector) ScriptExecutionResultMatch()

func (*NoopCollector) ScriptExecutionResultMismatch added in v0.32.0

func (nc *NoopCollector) ScriptExecutionResultMismatch()

func (*NoopCollector) SealedHeight

func (nc *NoopCollector) SealedHeight(height uint64)

func (*NoopCollector) SetCurView

func (nc *NoopCollector) SetCurView(view uint64)

func (*NoopCollector) SetMaxChunkDataPackAttemptsForNextUnsealedHeightAtRequester added in v0.22.0

func (nc *NoopCollector) SetMaxChunkDataPackAttemptsForNextUnsealedHeightAtRequester(attempts uint64)

func (*NoopCollector) SetQCView

func (nc *NoopCollector) SetQCView(view uint64)

func (*NoopCollector) SetTCView added in v0.29.0

func (nc *NoopCollector) SetTCView(uint64)

func (*NoopCollector) SetTimeout

func (nc *NoopCollector) SetTimeout(duration time.Duration)

func (*NoopCollector) SetWarningStateCount added in v0.30.0

func (nc *NoopCollector) SetWarningStateCount(u uint)

func (*NoopCollector) SignerProcessingDuration

func (nc *NoopCollector) SignerProcessingDuration(duration time.Duration)

func (*NoopCollector) StartBlockReceivedToExecuted

func (nc *NoopCollector) StartBlockReceivedToExecuted(blockID flow.Identifier)

func (*NoopCollector) StartBlockToSeal

func (nc *NoopCollector) StartBlockToSeal(blockID flow.Identifier)

func (*NoopCollector) StartCollectionToFinalized

func (nc *NoopCollector) StartCollectionToFinalized(collectionID flow.Identifier)

func (*NoopCollector) TimeoutObjectProcessingDuration added in v0.29.0

func (nc *NoopCollector) TimeoutObjectProcessingDuration(time.Duration)

func (*NoopCollector) TotalConnectionsInPool added in v0.26.16

func (nc *NoopCollector) TotalConnectionsInPool(connectionCount uint, connectionPoolSize uint)

func (*NoopCollector) TransactionExecuted

func (nc *NoopCollector) TransactionExecuted(txID flow.Identifier, when time.Time)

func (*NoopCollector) TransactionExpired

func (nc *NoopCollector) TransactionExpired(txID flow.Identifier)

func (*NoopCollector) TransactionFinalized

func (nc *NoopCollector) TransactionFinalized(txID flow.Identifier, when time.Time)

func (*NoopCollector) TransactionIngested

func (nc *NoopCollector) TransactionIngested(txID flow.Identifier)

func (*NoopCollector) TransactionReceived

func (nc *NoopCollector) TransactionReceived(txID flow.Identifier, when time.Time)

func (*NoopCollector) TransactionResultFetched added in v0.26.1

func (nc *NoopCollector) TransactionResultFetched(dur time.Duration, size int)

func (*NoopCollector) TransactionSubmissionFailed

func (nc *NoopCollector) TransactionSubmissionFailed()

func (*NoopCollector) UnicastMessageSendingCompleted added in v0.29.1

func (nc *NoopCollector) UnicastMessageSendingCompleted(topic string)

func (*NoopCollector) UnicastMessageSendingStarted added in v0.29.1

func (nc *NoopCollector) UnicastMessageSendingStarted(topic string)

func (*NoopCollector) UnstakedInboundConnections added in v0.21.1

func (nc *NoopCollector) UnstakedInboundConnections(_ uint)

func (*NoopCollector) UnstakedOutboundConnections added in v0.21.1

func (nc *NoopCollector) UnstakedOutboundConnections(_ uint)

func (*NoopCollector) UpdateCollectionMaxHeight added in v0.27.0

func (nc *NoopCollector) UpdateCollectionMaxHeight(height uint64)

func (*NoopCollector) UpdateCount

func (nc *NoopCollector) UpdateCount()

func (*NoopCollector) UpdateDuration

func (nc *NoopCollector) UpdateDuration(duration time.Duration)

func (*NoopCollector) UpdateDurationPerItem

func (nc *NoopCollector) UpdateDurationPerItem(duration time.Duration)

func (*NoopCollector) UpdateExecutionReceiptMaxHeight added in v0.27.0

func (nc *NoopCollector) UpdateExecutionReceiptMaxHeight(height uint64)

func (*NoopCollector) UpdateLastFullBlockHeight added in v0.31.0

func (nc *NoopCollector) UpdateLastFullBlockHeight(height uint64)

func (*NoopCollector) UpdateValuesNumber

func (nc *NoopCollector) UpdateValuesNumber(number uint64)

func (*NoopCollector) UpdateValuesSize

func (nc *NoopCollector) UpdateValuesSize(byte uint64)

func (*NoopCollector) ValidatorProcessingDuration

func (nc *NoopCollector) ValidatorProcessingDuration(duration time.Duration)

func (*NoopCollector) VoteProcessingDuration added in v0.29.0

func (nc *NoopCollector) VoteProcessingDuration(time.Duration)

func (*NoopCollector) Wantlist added in v0.27.3

func (nc *NoopCollector) Wantlist(prefix string, n int)

type ObserverCollector added in v0.28.0

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

func NewObserverCollector added in v0.28.0

func NewObserverCollector() *ObserverCollector

func (*ObserverCollector) RecordRPC added in v0.28.0

func (oc *ObserverCollector) RecordRPC(handler, rpc string, code codes.Code)

type PingCollector

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

func NewPingCollector

func NewPingCollector() *PingCollector

func (*PingCollector) NodeInfo added in v0.17.6

func (pc *PingCollector) NodeInfo(node *flow.Identity, nodeInfo string, version string, sealedHeight uint64, hotstuffCurView uint64)

func (*PingCollector) NodeReachable

func (pc *PingCollector) NodeReachable(node *flow.Identity, nodeInfo string, rtt time.Duration)

type RateLimitedBlockstoreCollector added in v0.28.0

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

func (*RateLimitedBlockstoreCollector) BytesRead added in v0.28.0

func (r *RateLimitedBlockstoreCollector) BytesRead(n int)

type RestCollector added in v0.29.12

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

func NewRestCollector added in v0.29.12

func NewRestCollector(urlToRouteMapper func(string) (string, error), registerer prometheus.Registerer) (*RestCollector, error)

NewRestCollector returns a new metrics RestCollector that implements the RestCollector using Prometheus as the backend.

func (*RestCollector) AddInflightRequests added in v0.31.0

func (r *RestCollector) AddInflightRequests(_ context.Context, p httpmetrics.HTTPProperties, quantity int)

AddInflightRequests increments and decrements the number of inflight request being processed. This method is called automatically by go-http-metrics/middleware

func (*RestCollector) AddTotalRequests added in v0.29.12

func (r *RestCollector) AddTotalRequests(_ context.Context, method, path string)

AddTotalRequests records all REST requests This is a custom method called by the REST handler

func (*RestCollector) ObserveHTTPRequestDuration added in v0.31.0

func (r *RestCollector) ObserveHTTPRequestDuration(_ context.Context, p httpmetrics.HTTPReqProperties, duration time.Duration)

ObserveHTTPRequestDuration records the duration of the REST request. This method is called automatically by go-http-metrics/middleware

func (*RestCollector) ObserveHTTPResponseSize added in v0.31.0

func (r *RestCollector) ObserveHTTPResponseSize(_ context.Context, p httpmetrics.HTTPReqProperties, sizeBytes int64)

ObserveHTTPResponseSize records the response size of the REST request. This method is called automatically by go-http-metrics/middleware

type Server

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

Server is the http server that will be serving the /metrics request for prometheus

func NewServer

func NewServer(log zerolog.Logger, port uint) *Server

NewServer creates a new server that will start on the specified port, and responds to only the `/metrics` endpoint

func (*Server) Done

func (m *Server) Done() <-chan struct{}

Done returns a channel that will close when shutdown is complete.

func (*Server) Ready

func (m *Server) Ready() <-chan struct{}

Ready returns a channel that will close when the network stack is ready.

type StorageCollector

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

func GetStorageCollector

func GetStorageCollector() *StorageCollector

func (*StorageCollector) RetryOnConflict

func (sc *StorageCollector) RetryOnConflict()

func (*StorageCollector) SkipDuplicate

func (sc *StorageCollector) SkipDuplicate()

type TransactionCollector

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

func NewTransactionCollector

func NewTransactionCollector(
	log zerolog.Logger,
	transactionTimings mempool.TransactionTimings,
	logTimeToFinalized bool,
	logTimeToExecuted bool,
	logTimeToFinalizedExecuted bool,
) *TransactionCollector

func (*TransactionCollector) ScriptExecuted added in v0.26.1

func (tc *TransactionCollector) ScriptExecuted(dur time.Duration, size int)

func (*TransactionCollector) ScriptExecutionErrorMatch added in v0.32.0

func (tc *TransactionCollector) ScriptExecutionErrorMatch()

func (*TransactionCollector) ScriptExecutionErrorMismatch added in v0.32.0

func (tc *TransactionCollector) ScriptExecutionErrorMismatch()

func (*TransactionCollector) ScriptExecutionErrorOnArchiveNode added in v0.31.11

func (tc *TransactionCollector) ScriptExecutionErrorOnArchiveNode()

func (*TransactionCollector) ScriptExecutionErrorOnExecutionNode added in v0.31.11

func (tc *TransactionCollector) ScriptExecutionErrorOnExecutionNode()

func (*TransactionCollector) ScriptExecutionResultMatch added in v0.32.0

func (tc *TransactionCollector) ScriptExecutionResultMatch()

func (*TransactionCollector) ScriptExecutionResultMismatch added in v0.32.0

func (tc *TransactionCollector) ScriptExecutionResultMismatch()

func (*TransactionCollector) TransactionExecuted

func (tc *TransactionCollector) TransactionExecuted(txID flow.Identifier, when time.Time)

func (*TransactionCollector) TransactionExpired

func (tc *TransactionCollector) TransactionExpired(txID flow.Identifier)

func (*TransactionCollector) TransactionFinalized

func (tc *TransactionCollector) TransactionFinalized(txID flow.Identifier, when time.Time)

func (*TransactionCollector) TransactionReceived

func (tc *TransactionCollector) TransactionReceived(txID flow.Identifier, when time.Time)

func (*TransactionCollector) TransactionResultFetched added in v0.26.1

func (tc *TransactionCollector) TransactionResultFetched(dur time.Duration, size int)

func (*TransactionCollector) TransactionSubmissionFailed

func (tc *TransactionCollector) TransactionSubmissionFailed()

type UnicastManagerMetrics added in v0.30.0

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

UnicastManagerMetrics metrics collector for the unicast manager.

func NewUnicastManagerMetrics added in v0.30.0

func NewUnicastManagerMetrics(prefix string) *UnicastManagerMetrics

func (*UnicastManagerMetrics) OnEstablishStreamFailure added in v0.30.0

func (u *UnicastManagerMetrics) OnEstablishStreamFailure(duration time.Duration, attempts int)

OnEstablishStreamFailure tracks the amount of time taken and number of retry attempts used when the unicast manager cannot establish a stream on the open connection between two peers.

func (*UnicastManagerMetrics) OnPeerDialFailure added in v0.30.0

func (u *UnicastManagerMetrics) OnPeerDialFailure(duration time.Duration, attempts int)

OnPeerDialFailure tracks the amount of time taken and number of retry attempts used when the unicast manager cannot dial a peer to establish the initial connection between the two.

func (*UnicastManagerMetrics) OnPeerDialed added in v0.30.0

func (u *UnicastManagerMetrics) OnPeerDialed(duration time.Duration, attempts int)

OnPeerDialed tracks the time it takes to dial a peer during stream creation and the number of retry attempts before a peer is dialed successfully.

func (*UnicastManagerMetrics) OnStreamCreated added in v0.30.0

func (u *UnicastManagerMetrics) OnStreamCreated(duration time.Duration, attempts int)

OnStreamCreated tracks the overall time taken to create a stream successfully and the number of retry attempts.

func (*UnicastManagerMetrics) OnStreamCreationFailure added in v0.30.0

func (u *UnicastManagerMetrics) OnStreamCreationFailure(duration time.Duration, attempts int)

OnStreamCreationFailure tracks the overall time taken and number of retry attempts used when the unicast manager fails to create a stream.

func (*UnicastManagerMetrics) OnStreamEstablished added in v0.30.0

func (u *UnicastManagerMetrics) OnStreamEstablished(duration time.Duration, attempts int)

OnStreamEstablished tracks the time it takes to create a stream successfully on the available open connection during stream creation and the number of retry attempts.

type VerificationCollector

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

func NewVerificationCollector

func NewVerificationCollector(tracer module.Tracer, registerer prometheus.Registerer) *VerificationCollector

func (*VerificationCollector) OnAssignedChunkProcessedAtAssigner added in v0.17.1

func (vc *VerificationCollector) OnAssignedChunkProcessedAtAssigner()

OnAssignedChunkProcessedAtAssigner increments a counter that keeps track of the total number of assigned chunks pushed by assigner engine to the fetcher engine.

func (*VerificationCollector) OnAssignedChunkReceivedAtFetcher added in v0.17.1

func (vc *VerificationCollector) OnAssignedChunkReceivedAtFetcher()

OnAssignedChunkReceivedAtFetcher increments a counter that keeps track of number of assigned chunks arrive at fetcher engine.

func (*VerificationCollector) OnBlockConsumerJobDone added in v0.19.0

func (vc *VerificationCollector) OnBlockConsumerJobDone(processedIndex uint64)

OnBlockConsumerJobDone is invoked by block consumer whenever it is notified a job is done by a worker. It sets the last processed block job index.

func (*VerificationCollector) OnChunkConsumerJobDone added in v0.19.0

func (vc *VerificationCollector) OnChunkConsumerJobDone(processedIndex uint64)

OnChunkConsumerJobDone is invoked by chunk consumer whenever it is notified a job is done by a worker. It sets the last processed chunk job index.

func (*VerificationCollector) OnChunkDataPackArrivedAtFetcher added in v0.17.1

func (vc *VerificationCollector) OnChunkDataPackArrivedAtFetcher()

OnChunkDataPackArrivedAtFetcher increments a counter that keeps track of number of chunk data packs arrived at fetcher engine from requester engine.

func (*VerificationCollector) OnChunkDataPackRequestDispatchedInNetworkByRequester added in v0.19.0

func (vc *VerificationCollector) OnChunkDataPackRequestDispatchedInNetworkByRequester()

OnChunkDataPackRequestDispatchedInNetworkByRequester increments a counter that keeps track of number of chunk data pack requests that the requester engine dispatches in the network (to the execution nodes).

func (*VerificationCollector) OnChunkDataPackRequestReceivedByRequester added in v0.17.1

func (vc *VerificationCollector) OnChunkDataPackRequestReceivedByRequester()

OnChunkDataPackRequestReceivedByRequester increments a counter that keeps track of number of chunk data pack requests arrive at the requester engine from the fetcher engine.

func (*VerificationCollector) OnChunkDataPackRequestSentByFetcher added in v0.17.1

func (vc *VerificationCollector) OnChunkDataPackRequestSentByFetcher()

OnChunkDataPackRequestSentByFetcher increments a counter that keeps track of number of chunk data pack requests that fetcher engine sends to requester engine.

func (*VerificationCollector) OnChunkDataPackResponseReceivedFromNetworkByRequester added in v0.19.0

func (vc *VerificationCollector) OnChunkDataPackResponseReceivedFromNetworkByRequester()

OnChunkDataPackResponseReceivedFromNetworkByRequester increments a counter that keeps track of number of chunk data pack responses that the requester engine receives from execution nodes (through network).

func (*VerificationCollector) OnChunkDataPackSentToFetcher added in v0.17.1

func (vc *VerificationCollector) OnChunkDataPackSentToFetcher()

OnChunkDataPackSentToFetcher increases a counter that keeps track of number of chunk data packs sent to the fetcher engine from requester engine.

func (*VerificationCollector) OnChunksAssignmentDoneAtAssigner added in v0.17.1

func (vc *VerificationCollector) OnChunksAssignmentDoneAtAssigner(chunks int)

OnChunksAssignmentDoneAtAssigner increments a counter that keeps track of the total number of assigned chunks to the verification node.

func (*VerificationCollector) OnExecutionResultReceivedAtAssignerEngine added in v0.19.0

func (vc *VerificationCollector) OnExecutionResultReceivedAtAssignerEngine()

OnExecutionResultReceivedAtAssignerEngine is called whenever a new execution result arrives at Assigner engine. It increments total number of received results.

func (*VerificationCollector) OnFinalizedBlockArrivedAtAssigner added in v0.17.1

func (vc *VerificationCollector) OnFinalizedBlockArrivedAtAssigner(height uint64)

OnFinalizedBlockArrivedAtAssigner sets a gauge that keeps track of number of the latest block height arrives at assigner engine. Note that it assumes blocks are coming to assigner engine in strictly increasing order of their height.

func (*VerificationCollector) OnResultApprovalDispatchedInNetworkByVerifier added in v0.19.0

func (vc *VerificationCollector) OnResultApprovalDispatchedInNetworkByVerifier()

OnResultApprovalDispatchedInNetwork is called whenever a result approval for is emitted to consensus nodes. It increases the total number of result approvals.

func (*VerificationCollector) OnVerifiableChunkReceivedAtVerifierEngine added in v0.17.1

func (vc *VerificationCollector) OnVerifiableChunkReceivedAtVerifierEngine()

OnVerifiableChunkReceivedAtVerifierEngine is called whenever a verifiable chunk is received by Verifier engine from Assigner engine.It increments the total number of sent verifiable chunks.

func (*VerificationCollector) OnVerifiableChunkSentToVerifier added in v0.17.1

func (vc *VerificationCollector) OnVerifiableChunkSentToVerifier()

OnVerifiableChunkSentToVerifier increments a counter that keeps track of number of verifiable chunks fetcher engine sent to verifier engine.

func (*VerificationCollector) SetMaxChunkDataPackAttemptsForNextUnsealedHeightAtRequester added in v0.22.0

func (vc *VerificationCollector) SetMaxChunkDataPackAttemptsForNextUnsealedHeightAtRequester(attempts uint64)

SetMaxChunkDataPackAttemptsForNextUnsealedHeightAtRequester is invoked when a cycle of requesting chunk data packs is done by requester engine. It updates the maximum number of attempts made by requester engine for requesting the chunk data packs of the next unsealed height. The maximum is taken over the history of all chunk data packs requested during that cycle that belong to the next unsealed height.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL