mock

Aug 13, 2024

Changes in this version

type ComplianceMetrics

+ func (_m *ComplianceMetrics) CurrentDKGPhaseViews(phase1FinalView uint64, phase2FinalView uint64, phase3FinalView uint64)

+ func (_m *ComplianceMetrics) EpochFallbackModeExited()

+ func (_m *ComplianceMetrics) EpochFallbackModeTriggered()

Jul 23, 2024

Changes in this version

+ type EVMMetrics struct

+ func NewEVMMetrics(t interface{ ... }) *EVMMetrics

+ func (_m *EVMMetrics) EVMBlockExecuted(txCount int, totalGasUsed uint64, totalSupplyInFlow float64)

+ func (_m *EVMMetrics) EVMTransactionExecuted(gasUsed uint64, isDirectCall bool, failed bool)

+ func (_m *EVMMetrics) SetNumberOfDeployedCOAs(count uint64)

type ExecutionMetrics

+ func (_m *ExecutionMetrics) EVMBlockExecuted(txCount int, totalGasUsed uint64, totalSupplyInFlow float64)

+ func (_m *ExecutionMetrics) EVMTransactionExecuted(gasUsed uint64, isDirectCall bool, failed bool)

+ func (_m *ExecutionMetrics) SetNumberOfDeployedCOAs(count uint64)

Jun 12, 2024

Changes in this version

type CruiseCtlMetrics

+ func (_m *CruiseCtlMetrics) ProposalPublicationDelay(duration time.Duration)

type GossipSubMetrics

+ func (_m *GossipSubMetrics) OnGraftInvalidTopicIdsExceedThreshold()

+ func (_m *GossipSubMetrics) OnIHaveInvalidTopicIdsExceedThreshold()

+ func (_m *GossipSubMetrics) OnPruneInvalidTopicIdsExceedThreshold()

+ func (_m *GossipSubMetrics) OnRpcRejectedFromUnknownSender()

type GossipSubRpcValidationInspectorMetrics

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnGraftInvalidTopicIdsExceedThreshold()

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnIHaveInvalidTopicIdsExceedThreshold()

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnPruneInvalidTopicIdsExceedThreshold()

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnRpcRejectedFromUnknownSender()

+ type GossipSubScoringRegistryMetrics struct

+ func NewGossipSubScoringRegistryMetrics(t interface{ ... }) *GossipSubScoringRegistryMetrics

+ func (_m *GossipSubScoringRegistryMetrics) DuplicateMessagePenalties(penalty float64)

+ func (_m *GossipSubScoringRegistryMetrics) DuplicateMessagesCounts(count float64)

type LibP2PMetrics

+ func (_m *LibP2PMetrics) DuplicateMessagePenalties(penalty float64)

+ func (_m *LibP2PMetrics) DuplicateMessagesCounts(count float64)

+ func (_m *LibP2PMetrics) OnGraftInvalidTopicIdsExceedThreshold()

+ func (_m *LibP2PMetrics) OnIHaveInvalidTopicIdsExceedThreshold()

+ func (_m *LibP2PMetrics) OnPruneInvalidTopicIdsExceedThreshold()

+ func (_m *LibP2PMetrics) OnRpcRejectedFromUnknownSender()

type NetworkMetrics

+ func (_m *NetworkMetrics) DuplicateMessagePenalties(penalty float64)

+ func (_m *NetworkMetrics) DuplicateMessagesCounts(count float64)

+ func (_m *NetworkMetrics) OnGraftInvalidTopicIdsExceedThreshold()

+ func (_m *NetworkMetrics) OnIHaveInvalidTopicIdsExceedThreshold()

+ func (_m *NetworkMetrics) OnPruneInvalidTopicIdsExceedThreshold()

+ func (_m *NetworkMetrics) OnRpcRejectedFromUnknownSender()

May 15, 2024

Changes in this version

+ type MachineAccountMetrics struct

+ func NewMachineAccountMetrics(t mockConstructorTestingTNewMachineAccountMetrics) *MachineAccountMetrics

+ func (_m *MachineAccountMetrics) AccountBalance(bal float64)

+ func (_m *MachineAccountMetrics) IsMisconfigured(misconfigured bool)

+ func (_m *MachineAccountMetrics) RecommendedMinBalance(bal float64)

Apr 12, 2024

Changes in this version

+ type CollectionExecutedMetric struct

+ func NewCollectionExecutedMetric(t mockConstructorTestingTNewCollectionExecutedMetric) *CollectionExecutedMetric

+ func (_m *CollectionExecutedMetric) BlockFinalized(block *flow.Block)

+ func (_m *CollectionExecutedMetric) CollectionExecuted(light flow.LightCollection)

+ func (_m *CollectionExecutedMetric) CollectionFinalized(light flow.LightCollection)

+ func (_m *CollectionExecutedMetric) ExecutionReceiptReceived(r *flow.ExecutionReceipt)

+ func (_m *CollectionExecutedMetric) UpdateLastFullBlockHeight(height uint64)

Feb 22, 2024

Changes in this version

type ExecutionMetrics

+ func (_m *ExecutionMetrics) ExecutionCheckpointSize(bytes uint64)

type WALMetrics

+ func (_m *WALMetrics) ExecutionCheckpointSize(bytes uint64)

Feb 7, 2024

Changes in this version

type GossipSubMetrics

+ func (_m *GossipSubMetrics) OnActiveClusterIDsNotSetErr()

+ func (_m *GossipSubMetrics) OnGraftDuplicateTopicIdsExceedThreshold()

+ func (_m *GossipSubMetrics) OnGraftMessageInspected(duplicateTopicIds int)

+ func (_m *GossipSubMetrics) OnIHaveDuplicateMessageIdsExceedThreshold()

+ func (_m *GossipSubMetrics) OnIHaveDuplicateTopicIdsExceedThreshold()

+ func (_m *GossipSubMetrics) OnIHaveMessagesInspected(duplicateTopicIds int, duplicateMessageIds int)

+ func (_m *GossipSubMetrics) OnIWantCacheMissMessageIdsExceedThreshold()

+ func (_m *GossipSubMetrics) OnIWantDuplicateMessageIdsExceedThreshold()

+ func (_m *GossipSubMetrics) OnIWantMessagesInspected(duplicateCount int, cacheMissCount int)

+ func (_m *GossipSubMetrics) OnInvalidControlMessageNotificationSent()

+ func (_m *GossipSubMetrics) OnInvalidTopicIdDetectedForControlMessage(messageType p2pmsg.ControlMessageType)

+ func (_m *GossipSubMetrics) OnPruneDuplicateTopicIdsExceedThreshold()

+ func (_m *GossipSubMetrics) OnPruneMessageInspected(duplicateTopicIds int)

+ func (_m *GossipSubMetrics) OnPublishMessageInspected(totalErrCount int, invalidTopicIdsCount int, invalidSubscriptionsCount int, ...)

+ func (_m *GossipSubMetrics) OnPublishMessagesInspectionErrorExceedsThreshold()

+ func (_m *GossipSubMetrics) OnUnstakedPeerInspectionFailed()

type GossipSubRpcValidationInspectorMetrics

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnActiveClusterIDsNotSetErr()

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnGraftDuplicateTopicIdsExceedThreshold()

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnGraftMessageInspected(duplicateTopicIds int)

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnIHaveDuplicateMessageIdsExceedThreshold()

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnIHaveDuplicateTopicIdsExceedThreshold()

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnIHaveMessagesInspected(duplicateTopicIds int, duplicateMessageIds int)

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnIWantCacheMissMessageIdsExceedThreshold()

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnIWantDuplicateMessageIdsExceedThreshold()

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnIWantMessagesInspected(duplicateCount int, cacheMissCount int)

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnInvalidControlMessageNotificationSent()

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnInvalidTopicIdDetectedForControlMessage(messageType p2pmsg.ControlMessageType)

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnPruneDuplicateTopicIdsExceedThreshold()

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnPruneMessageInspected(duplicateTopicIds int)

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnPublishMessageInspected(totalErrCount int, invalidTopicIdsCount int, invalidSubscriptionsCount int, ...)

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnPublishMessagesInspectionErrorExceedsThreshold()

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnUnstakedPeerInspectionFailed()

type LibP2PMetrics

+ func (_m *LibP2PMetrics) OnActiveClusterIDsNotSetErr()

+ func (_m *LibP2PMetrics) OnGraftDuplicateTopicIdsExceedThreshold()

+ func (_m *LibP2PMetrics) OnGraftMessageInspected(duplicateTopicIds int)

+ func (_m *LibP2PMetrics) OnIHaveDuplicateMessageIdsExceedThreshold()

+ func (_m *LibP2PMetrics) OnIHaveDuplicateTopicIdsExceedThreshold()

+ func (_m *LibP2PMetrics) OnIHaveMessagesInspected(duplicateTopicIds int, duplicateMessageIds int)

+ func (_m *LibP2PMetrics) OnIWantCacheMissMessageIdsExceedThreshold()

+ func (_m *LibP2PMetrics) OnIWantDuplicateMessageIdsExceedThreshold()

+ func (_m *LibP2PMetrics) OnIWantMessagesInspected(duplicateCount int, cacheMissCount int)

+ func (_m *LibP2PMetrics) OnInvalidControlMessageNotificationSent()

+ func (_m *LibP2PMetrics) OnInvalidTopicIdDetectedForControlMessage(messageType p2pmsg.ControlMessageType)

+ func (_m *LibP2PMetrics) OnPruneDuplicateTopicIdsExceedThreshold()

+ func (_m *LibP2PMetrics) OnPruneMessageInspected(duplicateTopicIds int)

+ func (_m *LibP2PMetrics) OnPublishMessageInspected(totalErrCount int, invalidTopicIdsCount int, invalidSubscriptionsCount int, ...)

+ func (_m *LibP2PMetrics) OnPublishMessagesInspectionErrorExceedsThreshold()

+ func (_m *LibP2PMetrics) OnUnstakedPeerInspectionFailed()

type NetworkMetrics

+ func (_m *NetworkMetrics) OnActiveClusterIDsNotSetErr()

+ func (_m *NetworkMetrics) OnGraftDuplicateTopicIdsExceedThreshold()

+ func (_m *NetworkMetrics) OnGraftMessageInspected(duplicateTopicIds int)

+ func (_m *NetworkMetrics) OnIHaveDuplicateMessageIdsExceedThreshold()

+ func (_m *NetworkMetrics) OnIHaveDuplicateTopicIdsExceedThreshold()

+ func (_m *NetworkMetrics) OnIHaveMessagesInspected(duplicateTopicIds int, duplicateMessageIds int)

+ func (_m *NetworkMetrics) OnIWantCacheMissMessageIdsExceedThreshold()

+ func (_m *NetworkMetrics) OnIWantDuplicateMessageIdsExceedThreshold()

+ func (_m *NetworkMetrics) OnIWantMessagesInspected(duplicateCount int, cacheMissCount int)

+ func (_m *NetworkMetrics) OnInvalidControlMessageNotificationSent()

+ func (_m *NetworkMetrics) OnInvalidTopicIdDetectedForControlMessage(messageType p2pmsg.ControlMessageType)

+ func (_m *NetworkMetrics) OnPruneDuplicateTopicIdsExceedThreshold()

+ func (_m *NetworkMetrics) OnPruneMessageInspected(duplicateTopicIds int)

+ func (_m *NetworkMetrics) OnPublishMessageInspected(totalErrCount int, invalidTopicIdsCount int, invalidSubscriptionsCount int, ...)

+ func (_m *NetworkMetrics) OnPublishMessagesInspectionErrorExceedsThreshold()

+ func (_m *NetworkMetrics) OnUnstakedPeerInspectionFailed()

Jan 18, 2024

Changes in this version

type ExecutionMetrics

+ func (_m *ExecutionMetrics) ExecutionLastFinalizedExecutedBlockHeight(height uint64)

type GossipSubMetrics

+ func (_m *GossipSubMetrics) OnControlMessagesTruncated(messageType p2pmsg.ControlMessageType, diff int)

+ func (_m *GossipSubMetrics) OnIHaveControlMessageIdsTruncated(diff int)

+ func (_m *GossipSubMetrics) OnIHaveMessageIDsReceived(channel string, msgIdCount int)

+ func (_m *GossipSubMetrics) OnIWantControlMessageIdsTruncated(diff int)

+ func (_m *GossipSubMetrics) OnIWantMessageIDsReceived(msgIdCount int)

+ func (_m *GossipSubMetrics) OnIncomingRpcReceived(iHaveCount int, iWantCount int, graftCount int, pruneCount int, msgCount int)

+ func (_m *GossipSubMetrics) OnLocalPeerJoinedTopic()

+ func (_m *GossipSubMetrics) OnLocalPeerLeftTopic()

+ func (_m *GossipSubMetrics) OnMessageDeliveredToAllSubscribers(size int)

+ func (_m *GossipSubMetrics) OnMessageDuplicate(size int)

+ func (_m *GossipSubMetrics) OnMessageEnteredValidation(size int)

+ func (_m *GossipSubMetrics) OnMessageRejected(size int, reason string)

+ func (_m *GossipSubMetrics) OnOutboundRpcDropped()

+ func (_m *GossipSubMetrics) OnPeerAddedToProtocol(protocol string)

+ func (_m *GossipSubMetrics) OnPeerGraftTopic(topic string)

+ func (_m *GossipSubMetrics) OnPeerPruneTopic(topic string)

+ func (_m *GossipSubMetrics) OnPeerRemovedFromProtocol()

+ func (_m *GossipSubMetrics) OnPeerThrottled()

+ func (_m *GossipSubMetrics) OnRpcReceived(msgCount int, iHaveCount int, iWantCount int, graftCount int, pruneCount int)

+ func (_m *GossipSubMetrics) OnRpcSent(msgCount int, iHaveCount int, iWantCount int, graftCount int, pruneCount int)

+ func (_m *GossipSubMetrics) OnUndeliveredMessage()

+ type GossipSubRpcInspectorMetrics struct

+ func NewGossipSubRpcInspectorMetrics(t mockConstructorTestingTNewGossipSubRpcInspectorMetrics) *GossipSubRpcInspectorMetrics

+ func (_m *GossipSubRpcInspectorMetrics) OnIHaveMessageIDsReceived(channel string, msgIdCount int)

+ func (_m *GossipSubRpcInspectorMetrics) OnIWantMessageIDsReceived(msgIdCount int)

+ func (_m *GossipSubRpcInspectorMetrics) OnIncomingRpcReceived(iHaveCount int, iWantCount int, graftCount int, pruneCount int, msgCount int)

type GossipSubRpcValidationInspectorMetrics

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnControlMessagesTruncated(messageType p2pmsg.ControlMessageType, diff int)

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnIHaveControlMessageIdsTruncated(diff int)

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnIHaveMessageIDsReceived(channel string, msgIdCount int)

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnIWantControlMessageIdsTruncated(diff int)

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnIWantMessageIDsReceived(msgIdCount int)

+ func (_m *GossipSubRpcValidationInspectorMetrics) OnIncomingRpcReceived(iHaveCount int, iWantCount int, graftCount int, pruneCount int, msgCount int)

type LibP2PMetrics

+ func (_m *LibP2PMetrics) OnControlMessagesTruncated(messageType p2pmsg.ControlMessageType, diff int)

+ func (_m *LibP2PMetrics) OnIHaveControlMessageIdsTruncated(diff int)

+ func (_m *LibP2PMetrics) OnIHaveMessageIDsReceived(channel string, msgIdCount int)

+ func (_m *LibP2PMetrics) OnIWantControlMessageIdsTruncated(diff int)

+ func (_m *LibP2PMetrics) OnIWantMessageIDsReceived(msgIdCount int)

+ func (_m *LibP2PMetrics) OnIncomingRpcReceived(iHaveCount int, iWantCount int, graftCount int, pruneCount int, msgCount int)

+ func (_m *LibP2PMetrics) OnLocalPeerJoinedTopic()

+ func (_m *LibP2PMetrics) OnLocalPeerLeftTopic()

+ func (_m *LibP2PMetrics) OnMessageDeliveredToAllSubscribers(size int)

+ func (_m *LibP2PMetrics) OnMessageDuplicate(size int)

+ func (_m *LibP2PMetrics) OnMessageEnteredValidation(size int)

+ func (_m *LibP2PMetrics) OnMessageRejected(size int, reason string)

+ func (_m *LibP2PMetrics) OnOutboundRpcDropped()

+ func (_m *LibP2PMetrics) OnPeerAddedToProtocol(_a0 string)

+ func (_m *LibP2PMetrics) OnPeerGraftTopic(topic string)

+ func (_m *LibP2PMetrics) OnPeerPruneTopic(topic string)

+ func (_m *LibP2PMetrics) OnPeerRemovedFromProtocol()

+ func (_m *LibP2PMetrics) OnPeerThrottled()

+ func (_m *LibP2PMetrics) OnRpcReceived(msgCount int, iHaveCount int, iWantCount int, graftCount int, pruneCount int)

+ func (_m *LibP2PMetrics) OnRpcSent(msgCount int, iHaveCount int, iWantCount int, graftCount int, pruneCount int)

+ func (_m *LibP2PMetrics) OnUndeliveredMessage()

+ type LocalGossipSubRouterMetrics struct

+ func NewLocalGossipSubRouterMetrics(t mockConstructorTestingTNewLocalGossipSubRouterMetrics) *LocalGossipSubRouterMetrics

+ func (_m *LocalGossipSubRouterMetrics) OnLocalMeshSizeUpdated(topic string, size int)

+ func (_m *LocalGossipSubRouterMetrics) OnLocalPeerJoinedTopic()

+ func (_m *LocalGossipSubRouterMetrics) OnLocalPeerLeftTopic()

+ func (_m *LocalGossipSubRouterMetrics) OnMessageDeliveredToAllSubscribers(size int)

+ func (_m *LocalGossipSubRouterMetrics) OnMessageDuplicate(size int)

+ func (_m *LocalGossipSubRouterMetrics) OnMessageEnteredValidation(size int)

+ func (_m *LocalGossipSubRouterMetrics) OnMessageRejected(size int, reason string)

+ func (_m *LocalGossipSubRouterMetrics) OnOutboundRpcDropped()

+ func (_m *LocalGossipSubRouterMetrics) OnPeerAddedToProtocol(protocol string)

+ func (_m *LocalGossipSubRouterMetrics) OnPeerGraftTopic(topic string)

+ func (_m *LocalGossipSubRouterMetrics) OnPeerPruneTopic(topic string)

+ func (_m *LocalGossipSubRouterMetrics) OnPeerRemovedFromProtocol()

+ func (_m *LocalGossipSubRouterMetrics) OnPeerThrottled()

+ func (_m *LocalGossipSubRouterMetrics) OnRpcReceived(msgCount int, iHaveCount int, iWantCount int, graftCount int, pruneCount int)

+ func (_m *LocalGossipSubRouterMetrics) OnRpcSent(msgCount int, iHaveCount int, iWantCount int, graftCount int, pruneCount int)

+ func (_m *LocalGossipSubRouterMetrics) OnUndeliveredMessage()

type NetworkMetrics

+ func (_m *NetworkMetrics) OnControlMessagesTruncated(messageType p2pmsg.ControlMessageType, diff int)

+ func (_m *NetworkMetrics) OnIHaveControlMessageIdsTruncated(diff int)

+ func (_m *NetworkMetrics) OnIHaveMessageIDsReceived(channel string, msgIdCount int)

+ func (_m *NetworkMetrics) OnIWantControlMessageIdsTruncated(diff int)

+ func (_m *NetworkMetrics) OnIWantMessageIDsReceived(msgIdCount int)

+ func (_m *NetworkMetrics) OnIncomingRpcReceived(iHaveCount int, iWantCount int, graftCount int, pruneCount int, msgCount int)

+ func (_m *NetworkMetrics) OnLocalPeerJoinedTopic()

+ func (_m *NetworkMetrics) OnLocalPeerLeftTopic()

+ func (_m *NetworkMetrics) OnMessageDeliveredToAllSubscribers(size int)

+ func (_m *NetworkMetrics) OnMessageDuplicate(size int)

+ func (_m *NetworkMetrics) OnMessageEnteredValidation(size int)

+ func (_m *NetworkMetrics) OnMessageRejected(size int, reason string)

+ func (_m *NetworkMetrics) OnOutboundRpcDropped()

+ func (_m *NetworkMetrics) OnPeerAddedToProtocol(_a0 string)

+ func (_m *NetworkMetrics) OnPeerGraftTopic(topic string)

+ func (_m *NetworkMetrics) OnPeerPruneTopic(topic string)

+ func (_m *NetworkMetrics) OnPeerRemovedFromProtocol()

+ func (_m *NetworkMetrics) OnPeerThrottled()

+ func (_m *NetworkMetrics) OnRpcReceived(msgCount int, iHaveCount int, iWantCount int, graftCount int, pruneCount int)

+ func (_m *NetworkMetrics) OnRpcSent(msgCount int, iHaveCount int, iWantCount int, graftCount int, pruneCount int)

+ func (_m *NetworkMetrics) OnUndeliveredMessage()

Nov 8, 2023

Changes in this version

type AccessMetrics

+ func (_m *AccessMetrics) ScriptExecutionNotIndexed()

type BackendScriptsMetrics

+ func (_m *BackendScriptsMetrics) ScriptExecutionNotIndexed()

Oct 19, 2023

Changes in this version

type AccessMetrics

+ func (_m *AccessMetrics) ScriptExecutionErrorLocal()

type BackendScriptsMetrics

+ func (_m *BackendScriptsMetrics) ScriptExecutionErrorLocal()

type ExecutionStateIndexerMetrics

+ func (_m *ExecutionStateIndexerMetrics) InitializeLatestHeight(height uint64)

type LibP2PMetrics

+ func (_m *LibP2PMetrics) OnDialRetryBudgetResetToDefault()

+ func (_m *LibP2PMetrics) OnDialRetryBudgetUpdated(budget uint64)

+ func (_m *LibP2PMetrics) OnStreamCreationRetryBudgetResetToDefault()

+ func (_m *LibP2PMetrics) OnStreamCreationRetryBudgetUpdated(budget uint64)

type NetworkMetrics

+ func (_m *NetworkMetrics) OnDialRetryBudgetResetToDefault()

+ func (_m *NetworkMetrics) OnDialRetryBudgetUpdated(budget uint64)

+ func (_m *NetworkMetrics) OnStreamCreationRetryBudgetResetToDefault()

+ func (_m *NetworkMetrics) OnStreamCreationRetryBudgetUpdated(budget uint64)

type UnicastManagerMetrics

+ func (_m *UnicastManagerMetrics) OnDialRetryBudgetResetToDefault()

+ func (_m *UnicastManagerMetrics) OnDialRetryBudgetUpdated(budget uint64)

+ func (_m *UnicastManagerMetrics) OnStreamCreationRetryBudgetResetToDefault()

+ func (_m *UnicastManagerMetrics) OnStreamCreationRetryBudgetUpdated(budget uint64)

Oct 11, 2023

Changes in this version

+ type ExecutionStateIndexerMetrics struct

+ func NewExecutionStateIndexerMetrics(t mockConstructorTestingTNewExecutionStateIndexerMetrics) *ExecutionStateIndexerMetrics

+ func (_m *ExecutionStateIndexerMetrics) BlockIndexed(height uint64, duration time.Duration, events int, registers int, ...)

+ func (_m *ExecutionStateIndexerMetrics) BlockReindexed()

Oct 3, 2023

Changes in this version

type AccessMetrics

+ func (_m *AccessMetrics) ScriptExecutionErrorMatch()

+ func (_m *AccessMetrics) ScriptExecutionErrorMismatch()

+ func (_m *AccessMetrics) ScriptExecutionResultMatch()

+ func (_m *AccessMetrics) ScriptExecutionResultMismatch()

type BackendScriptsMetrics

+ func (_m *BackendScriptsMetrics) ScriptExecutionErrorMatch()

+ func (_m *BackendScriptsMetrics) ScriptExecutionErrorMismatch()

+ func (_m *BackendScriptsMetrics) ScriptExecutionResultMatch()

+ func (_m *BackendScriptsMetrics) ScriptExecutionResultMismatch()

type HotstuffMetrics

+ func (_m *HotstuffMetrics) TimeoutCollectorsRange(lowestRetainedView uint64, newestViewCreatedCollector uint64, ...)

type NetworkCoreMetrics

+ func (_m *NetworkCoreMetrics) OnRateLimitedPeer(pid peer.ID, role string, msgType string, topic string, reason string)

+ func (_m *NetworkCoreMetrics) OnUnauthorizedMessage(role string, msgType string, topic string, offense string)

+ func (_m *NetworkCoreMetrics) OnViolationReportSkipped()

type NetworkMetrics

+ func (_m *NetworkMetrics) OnViolationReportSkipped()

type NetworkSecurityMetrics

+ func (_m *NetworkSecurityMetrics) OnViolationReportSkipped()

Jul 6, 2023

Changes in this version

type AccessMetrics

+ func (_m *AccessMetrics) ScriptExecutionErrorOnArchiveNode()

+ func (_m *AccessMetrics) ScriptExecutionErrorOnExecutionNode()

type BackendScriptsMetrics

+ func (_m *BackendScriptsMetrics) ScriptExecutionErrorOnArchiveNode()

+ func (_m *BackendScriptsMetrics) ScriptExecutionErrorOnExecutionNode()

Jun 26, 2023

Changes in this version

+ type GRPCConnectionPoolMetrics struct

+ func NewGRPCConnectionPoolMetrics(t mockConstructorTestingTNewGRPCConnectionPoolMetrics) *GRPCConnectionPoolMetrics

+ func (_m *GRPCConnectionPoolMetrics) ConnectionAddedToPool()

+ func (_m *GRPCConnectionPoolMetrics) ConnectionFromPoolEvicted()

+ func (_m *GRPCConnectionPoolMetrics) ConnectionFromPoolInvalidated()

+ func (_m *GRPCConnectionPoolMetrics) ConnectionFromPoolReused()

+ func (_m *GRPCConnectionPoolMetrics) ConnectionFromPoolUpdated()

+ func (_m *GRPCConnectionPoolMetrics) NewConnectionEstablished()

+ func (_m *GRPCConnectionPoolMetrics) TotalConnectionsInPool(connectionCount uint, connectionPoolSize uint)

Jun 5, 2023

Changes in this version

type AccessMetrics

+ func (_m *AccessMetrics) AddInflightRequests(ctx context.Context, props metrics.HTTPProperties, quantity int)

+ func (_m *AccessMetrics) AddTotalRequests(ctx context.Context, service string, id string)

+ func (_m *AccessMetrics) ObserveHTTPRequestDuration(ctx context.Context, props metrics.HTTPReqProperties, duration time.Duration)

+ func (_m *AccessMetrics) ObserveHTTPResponseSize(ctx context.Context, props metrics.HTTPReqProperties, sizeBytes int64)

+ func (_m *AccessMetrics) ScriptExecuted(dur time.Duration, size int)

+ func (_m *AccessMetrics) TransactionExecuted(txID flow.Identifier, when time.Time)

+ func (_m *AccessMetrics) TransactionExpired(txID flow.Identifier)

+ func (_m *AccessMetrics) TransactionFinalized(txID flow.Identifier, when time.Time)

+ func (_m *AccessMetrics) TransactionReceived(txID flow.Identifier, when time.Time)

+ func (_m *AccessMetrics) TransactionResultFetched(dur time.Duration, size int)

+ func (_m *AccessMetrics) TransactionSubmissionFailed()

+ func (_m *AccessMetrics) UpdateExecutionReceiptMaxHeight(height uint64)

+ func (_m *AccessMetrics) UpdateLastFullBlockHeight(height uint64)

+ type AlspMetrics struct

+ func NewAlspMetrics(t mockConstructorTestingTNewAlspMetrics) *AlspMetrics

+ func (_m *AlspMetrics) OnMisbehaviorReported(channel string, misbehaviorType string)

+ type CruiseCtlMetrics struct

+ func NewCruiseCtlMetrics(t mockConstructorTestingTNewCruiseCtlMetrics) *CruiseCtlMetrics

+ func (_m *CruiseCtlMetrics) ControllerOutput(duration time.Duration)

+ func (_m *CruiseCtlMetrics) PIDError(p float64, i float64, d float64)

+ func (_m *CruiseCtlMetrics) TargetProposalDuration(duration time.Duration)

+ type FinalizedHeaderCache struct

+ func NewFinalizedHeaderCache(t mockConstructorTestingTNewFinalizedHeaderCache) *FinalizedHeaderCache

+ func (_m *FinalizedHeaderCache) Get() *flow.Header

type GossipSubMetrics

+ func (_m *GossipSubMetrics) AsyncProcessingFinished(msgType string, duration time.Duration)

+ func (_m *GossipSubMetrics) AsyncProcessingStarted(msgType string)

+ func (_m *GossipSubMetrics) BlockingPreProcessingFinished(msgType string, sampleSize uint, duration time.Duration)

+ func (_m *GossipSubMetrics) BlockingPreProcessingStarted(msgType string, sampleSize uint)

+ type GossipSubRpcValidationInspectorMetrics struct

+ func NewGossipSubRpcValidationInspectorMetrics(t mockConstructorTestingTNewGossipSubRpcValidationInspectorMetrics) *GossipSubRpcValidationInspectorMetrics

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

+ func (_m *GossipSubRpcValidationInspectorMetrics) AsyncProcessingStarted(msgType string)

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

+ func (_m *GossipSubRpcValidationInspectorMetrics) BlockingPreProcessingStarted(msgType string, sampleSize uint)

type HotStuffFollower

+ func (_m *HotStuffFollower) AddCertifiedBlock(certifiedBlock *model.CertifiedBlock)

type LibP2PMetrics

+ func (_m *LibP2PMetrics) AsyncProcessingFinished(msgType string, duration time.Duration)

+ func (_m *LibP2PMetrics) AsyncProcessingStarted(msgType string)

+ func (_m *LibP2PMetrics) BlockingPreProcessingFinished(msgType string, sampleSize uint, duration time.Duration)

+ func (_m *LibP2PMetrics) BlockingPreProcessingStarted(msgType string, sampleSize uint)

type NetworkCoreMetrics

+ func (_m *NetworkCoreMetrics) OnMisbehaviorReported(channel string, misbehaviorType string)

type NetworkMetrics

+ func (_m *NetworkMetrics) AsyncProcessingFinished(msgType string, duration time.Duration)

+ func (_m *NetworkMetrics) AsyncProcessingStarted(msgType string)

+ func (_m *NetworkMetrics) BlockingPreProcessingFinished(msgType string, sampleSize uint, duration time.Duration)

+ func (_m *NetworkMetrics) BlockingPreProcessingStarted(msgType string, sampleSize uint)

+ func (_m *NetworkMetrics) OnMisbehaviorReported(channel string, misbehaviorType string)

+ type RestMetrics struct

+ func NewRestMetrics(t mockConstructorTestingTNewRestMetrics) *RestMetrics

+ func (_m *RestMetrics) AddInflightRequests(ctx context.Context, props metrics.HTTPProperties, quantity int)

+ func (_m *RestMetrics) AddTotalRequests(ctx context.Context, service string, id string)

+ func (_m *RestMetrics) ObserveHTTPRequestDuration(ctx context.Context, props metrics.HTTPReqProperties, duration time.Duration)

+ func (_m *RestMetrics) ObserveHTTPResponseSize(ctx context.Context, props metrics.HTTPReqProperties, sizeBytes int64)

Apr 5, 2023

Changes in this version

type ComplianceMetrics

+ func (_m *ComplianceMetrics) EpochTransitionHeight(height uint64)

+ type GossipSubLocalMeshMetrics struct

+ func NewGossipSubLocalMeshMetrics(t mockConstructorTestingTNewGossipSubLocalMeshMetrics) *GossipSubLocalMeshMetrics

+ func (_m *GossipSubLocalMeshMetrics) OnLocalMeshSizeUpdated(topic string, size int)

+ type GossipSubMetrics struct

+ func NewGossipSubMetrics(t mockConstructorTestingTNewGossipSubMetrics) *GossipSubMetrics

+ func (_m *GossipSubMetrics) OnAppSpecificScoreUpdated(_a0 float64)

+ func (_m *GossipSubMetrics) OnBehaviourPenaltyUpdated(_a0 float64)

+ func (_m *GossipSubMetrics) OnFirstMessageDeliveredUpdated(_a0 channels.Topic, _a1 float64)

+ func (_m *GossipSubMetrics) OnGraftReceived(count int)

+ func (_m *GossipSubMetrics) OnIHaveReceived(count int)

+ func (_m *GossipSubMetrics) OnIPColocationFactorUpdated(_a0 float64)

+ func (_m *GossipSubMetrics) OnIWantReceived(count int)

+ func (_m *GossipSubMetrics) OnIncomingRpcAcceptedFully()

+ func (_m *GossipSubMetrics) OnIncomingRpcAcceptedOnlyForControlMessages()

+ func (_m *GossipSubMetrics) OnIncomingRpcRejected()

+ func (_m *GossipSubMetrics) OnInvalidMessageDeliveredUpdated(_a0 channels.Topic, _a1 float64)

+ func (_m *GossipSubMetrics) OnLocalMeshSizeUpdated(topic string, size int)

+ func (_m *GossipSubMetrics) OnMeshMessageDeliveredUpdated(_a0 channels.Topic, _a1 float64)

+ func (_m *GossipSubMetrics) OnOverallPeerScoreUpdated(_a0 float64)

+ func (_m *GossipSubMetrics) OnPruneReceived(count int)

+ func (_m *GossipSubMetrics) OnPublishedGossipMessagesReceived(count int)

+ func (_m *GossipSubMetrics) OnTimeInMeshUpdated(_a0 channels.Topic, _a1 time.Duration)

+ func (_m *GossipSubMetrics) SetWarningStateCount(_a0 uint)

+ type GossipSubScoringMetrics struct

+ func NewGossipSubScoringMetrics(t mockConstructorTestingTNewGossipSubScoringMetrics) *GossipSubScoringMetrics

+ func (_m *GossipSubScoringMetrics) OnAppSpecificScoreUpdated(_a0 float64)

+ func (_m *GossipSubScoringMetrics) OnBehaviourPenaltyUpdated(_a0 float64)

+ func (_m *GossipSubScoringMetrics) OnFirstMessageDeliveredUpdated(_a0 channels.Topic, _a1 float64)

+ func (_m *GossipSubScoringMetrics) OnIPColocationFactorUpdated(_a0 float64)

+ func (_m *GossipSubScoringMetrics) OnInvalidMessageDeliveredUpdated(_a0 channels.Topic, _a1 float64)

+ func (_m *GossipSubScoringMetrics) OnMeshMessageDeliveredUpdated(_a0 channels.Topic, _a1 float64)

+ func (_m *GossipSubScoringMetrics) OnOverallPeerScoreUpdated(_a0 float64)

+ func (_m *GossipSubScoringMetrics) OnTimeInMeshUpdated(_a0 channels.Topic, _a1 time.Duration)

+ func (_m *GossipSubScoringMetrics) SetWarningStateCount(_a0 uint)

type LibP2PMetrics

+ func (_m *LibP2PMetrics) OnAppSpecificScoreUpdated(_a0 float64)

+ func (_m *LibP2PMetrics) OnBehaviourPenaltyUpdated(_a0 float64)

+ func (_m *LibP2PMetrics) OnEstablishStreamFailure(duration time.Duration, attempts int)

+ func (_m *LibP2PMetrics) OnFirstMessageDeliveredUpdated(_a0 channels.Topic, _a1 float64)

+ func (_m *LibP2PMetrics) OnIPColocationFactorUpdated(_a0 float64)

+ func (_m *LibP2PMetrics) OnInvalidMessageDeliveredUpdated(_a0 channels.Topic, _a1 float64)

+ func (_m *LibP2PMetrics) OnLocalMeshSizeUpdated(topic string, size int)

+ func (_m *LibP2PMetrics) OnMeshMessageDeliveredUpdated(_a0 channels.Topic, _a1 float64)

+ func (_m *LibP2PMetrics) OnOverallPeerScoreUpdated(_a0 float64)

+ func (_m *LibP2PMetrics) OnPeerDialFailure(duration time.Duration, attempts int)

+ func (_m *LibP2PMetrics) OnPeerDialed(duration time.Duration, attempts int)

+ func (_m *LibP2PMetrics) OnStreamCreated(duration time.Duration, attempts int)

+ func (_m *LibP2PMetrics) OnStreamCreationFailure(duration time.Duration, attempts int)

+ func (_m *LibP2PMetrics) OnStreamEstablished(duration time.Duration, attempts int)

+ func (_m *LibP2PMetrics) OnTimeInMeshUpdated(_a0 channels.Topic, _a1 time.Duration)

+ func (_m *LibP2PMetrics) SetWarningStateCount(_a0 uint)

type NetworkMetrics

+ func (_m *NetworkMetrics) OnAppSpecificScoreUpdated(_a0 float64)

+ func (_m *NetworkMetrics) OnBehaviourPenaltyUpdated(_a0 float64)

+ func (_m *NetworkMetrics) OnEstablishStreamFailure(duration time.Duration, attempts int)

+ func (_m *NetworkMetrics) OnFirstMessageDeliveredUpdated(_a0 channels.Topic, _a1 float64)

+ func (_m *NetworkMetrics) OnIPColocationFactorUpdated(_a0 float64)

+ func (_m *NetworkMetrics) OnInvalidMessageDeliveredUpdated(_a0 channels.Topic, _a1 float64)

+ func (_m *NetworkMetrics) OnLocalMeshSizeUpdated(topic string, size int)

+ func (_m *NetworkMetrics) OnMeshMessageDeliveredUpdated(_a0 channels.Topic, _a1 float64)

+ func (_m *NetworkMetrics) OnOverallPeerScoreUpdated(_a0 float64)

+ func (_m *NetworkMetrics) OnPeerDialFailure(duration time.Duration, attempts int)

+ func (_m *NetworkMetrics) OnPeerDialed(duration time.Duration, attempts int)

+ func (_m *NetworkMetrics) OnRateLimitedPeer(pid peer.ID, role string, msgType string, topic string, reason string)

+ func (_m *NetworkMetrics) OnStreamCreated(duration time.Duration, attempts int)

+ func (_m *NetworkMetrics) OnStreamCreationFailure(duration time.Duration, attempts int)

+ func (_m *NetworkMetrics) OnStreamEstablished(duration time.Duration, attempts int)

+ func (_m *NetworkMetrics) OnTimeInMeshUpdated(_a0 channels.Topic, _a1 time.Duration)

+ func (_m *NetworkMetrics) SetWarningStateCount(_a0 uint)

type NetworkSecurityMetrics

+ func (_m *NetworkSecurityMetrics) OnRateLimitedPeer(pid peer.ID, role string, msgType string, topic string, reason string)

type Tracer

+ func (_m *Tracer) BlockRootSpan(blockID flow.Identifier) trace.Span

+ func (_m *Tracer) ShouldSample(entityID flow.Identifier) bool

+ func (_m *Tracer) StartSampledSpanFromParent(parentSpan trace.Span, entityID flow.Identifier, ...) trace.Span

+ type UnicastManagerMetrics struct

+ func NewUnicastManagerMetrics(t mockConstructorTestingTNewUnicastManagerMetrics) *UnicastManagerMetrics

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

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

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

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

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

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

Mar 21, 2023

Changes in this version

type ExecutionMetrics

+ func (_m *ExecutionMetrics) ExecutionBlockCachedPrograms(programs int)

+ func (_m *ExecutionMetrics) RuntimeTransactionProgramsCacheHit()

+ func (_m *ExecutionMetrics) RuntimeTransactionProgramsCacheMiss()

type RuntimeMetrics

+ func (_m *RuntimeMetrics) RuntimeTransactionProgramsCacheHit()

+ func (_m *RuntimeMetrics) RuntimeTransactionProgramsCacheMiss()

Dec 23, 2022

Changes in this version

+ type LibP2PConnectionMetrics struct

+ func NewLibP2PConnectionMetrics(t mockConstructorTestingTNewLibP2PConnectionMetrics) *LibP2PConnectionMetrics

+ func (_m *LibP2PConnectionMetrics) InboundConnections(connectionCount uint)

+ func (_m *LibP2PConnectionMetrics) OutboundConnections(connectionCount uint)

type LibP2PMetrics

+ func (_m *LibP2PMetrics) InboundConnections(connectionCount uint)

+ func (_m *LibP2PMetrics) OutboundConnections(connectionCount uint)

+ type NetworkCoreMetrics struct

+ func NewNetworkCoreMetrics(t mockConstructorTestingTNewNetworkCoreMetrics) *NetworkCoreMetrics

+ func (_m *NetworkCoreMetrics) DuplicateInboundMessagesDropped(topic string, messageType string)

+ func (_m *NetworkCoreMetrics) InboundMessageReceived(sizeBytes int, topic string, messageType string)

+ func (_m *NetworkCoreMetrics) MessageAdded(priority int)

+ func (_m *NetworkCoreMetrics) MessageProcessingFinished(topic string, duration time.Duration)

+ func (_m *NetworkCoreMetrics) MessageProcessingStarted(topic string)

+ func (_m *NetworkCoreMetrics) MessageRemoved(priority int)

+ func (_m *NetworkCoreMetrics) OutboundMessageSent(sizeBytes int, topic string, messageType string)

+ func (_m *NetworkCoreMetrics) QueueDuration(duration time.Duration, priority int)

+ func (_m *NetworkCoreMetrics) UnicastMessageSendingCompleted(topic string)

+ func (_m *NetworkCoreMetrics) UnicastMessageSendingStarted(topic string)

+ type NetworkInboundQueueMetrics struct

+ func NewNetworkInboundQueueMetrics(t mockConstructorTestingTNewNetworkInboundQueueMetrics) *NetworkInboundQueueMetrics

+ func (_m *NetworkInboundQueueMetrics) MessageAdded(priority int)

+ func (_m *NetworkInboundQueueMetrics) MessageRemoved(priority int)

+ func (_m *NetworkInboundQueueMetrics) QueueDuration(duration time.Duration, priority int)

type NetworkMetrics

+ func (_m *NetworkMetrics) DuplicateInboundMessagesDropped(topic string, messageType string)

+ func (_m *NetworkMetrics) InboundMessageReceived(sizeBytes int, topic string, messageType string)

+ func (_m *NetworkMetrics) OutboundMessageSent(sizeBytes int, topic string, messageType string)

+ func (_m *NetworkMetrics) UnicastMessageSendingCompleted(topic string)

+ func (_m *NetworkMetrics) UnicastMessageSendingStarted(topic string)

Dec 16, 2022

Changes in this version

type EngineMetrics

+ func (_m *EngineMetrics) InboundMessageDropped(engine string, messages string)

+ func (_m *EngineMetrics) OutboundMessageDropped(engine string, messages string)

+ type GossipSubRouterMetrics struct

+ func NewGossipSubRouterMetrics(t mockConstructorTestingTNewGossipSubRouterMetrics) *GossipSubRouterMetrics

+ func (_m *GossipSubRouterMetrics) OnGraftReceived(count int)

+ func (_m *GossipSubRouterMetrics) OnIHaveReceived(count int)

+ func (_m *GossipSubRouterMetrics) OnIWantReceived(count int)

+ func (_m *GossipSubRouterMetrics) OnIncomingRpcAcceptedFully()

+ func (_m *GossipSubRouterMetrics) OnIncomingRpcAcceptedOnlyForControlMessages()

+ func (_m *GossipSubRouterMetrics) OnIncomingRpcRejected()

+ func (_m *GossipSubRouterMetrics) OnPruneReceived(count int)

+ func (_m *GossipSubRouterMetrics) OnPublishedGossipMessagesReceived(count int)

type HeroCacheMetrics

+ func (_m *HeroCacheMetrics) OnKeyPutAttempt(size uint32)

+ func (_m *HeroCacheMetrics) OnKeyPutDeduplicated()

+ func (_m *HeroCacheMetrics) OnKeyPutDrop()

+ func (_m *HeroCacheMetrics) OnKeyRemoved(size uint32)

type HotStuffFollower

+ func (_m *HotStuffFollower) Start(_a0 irrecoverable.SignalerContext)

type HotstuffMetrics

+ func (_m *HotstuffMetrics) BlockProcessingDuration(duration time.Duration)

+ func (_m *HotstuffMetrics) SetTCView(view uint64)

+ func (_m *HotstuffMetrics) TimeoutObjectProcessingDuration(duration time.Duration)

+ func (_m *HotstuffMetrics) VoteProcessingDuration(duration time.Duration)

+ type LibP2PMetrics struct

+ func NewLibP2PMetrics(t mockConstructorTestingTNewLibP2PMetrics) *LibP2PMetrics

+ func (_m *LibP2PMetrics) AllowConn(dir network.Direction, usefd bool)

+ func (_m *LibP2PMetrics) AllowMemory(size int)

+ func (_m *LibP2PMetrics) AllowPeer(p peer.ID)

+ func (_m *LibP2PMetrics) AllowProtocol(proto protocol.ID)

+ func (_m *LibP2PMetrics) AllowService(svc string)

+ func (_m *LibP2PMetrics) AllowStream(p peer.ID, dir network.Direction)

+ func (_m *LibP2PMetrics) BlockConn(dir network.Direction, usefd bool)

+ func (_m *LibP2PMetrics) BlockMemory(size int)

+ func (_m *LibP2PMetrics) BlockPeer(p peer.ID)

+ func (_m *LibP2PMetrics) BlockProtocol(proto protocol.ID)

+ func (_m *LibP2PMetrics) BlockProtocolPeer(proto protocol.ID, p peer.ID)

+ func (_m *LibP2PMetrics) BlockService(svc string)

+ func (_m *LibP2PMetrics) BlockServicePeer(svc string, p peer.ID)

+ func (_m *LibP2PMetrics) BlockStream(p peer.ID, dir network.Direction)

+ func (_m *LibP2PMetrics) DNSLookupDuration(duration time.Duration)

+ func (_m *LibP2PMetrics) OnDNSCacheHit()

+ func (_m *LibP2PMetrics) OnDNSCacheInvalidated()

+ func (_m *LibP2PMetrics) OnDNSCacheMiss()

+ func (_m *LibP2PMetrics) OnDNSLookupRequestDropped()

+ func (_m *LibP2PMetrics) OnGraftReceived(count int)

+ func (_m *LibP2PMetrics) OnIHaveReceived(count int)

+ func (_m *LibP2PMetrics) OnIWantReceived(count int)

+ func (_m *LibP2PMetrics) OnIncomingRpcAcceptedFully()

+ func (_m *LibP2PMetrics) OnIncomingRpcAcceptedOnlyForControlMessages()

+ func (_m *LibP2PMetrics) OnIncomingRpcRejected()

+ func (_m *LibP2PMetrics) OnPruneReceived(count int)

+ func (_m *LibP2PMetrics) OnPublishedGossipMessagesReceived(count int)

+ func (_m *LibP2PMetrics) RoutingTablePeerAdded()

+ func (_m *LibP2PMetrics) RoutingTablePeerRemoved()

type NetworkMetrics

+ func (_m *NetworkMetrics) AllowConn(dir network.Direction, usefd bool)

+ func (_m *NetworkMetrics) AllowMemory(size int)

+ func (_m *NetworkMetrics) AllowPeer(p peer.ID)

+ func (_m *NetworkMetrics) AllowProtocol(proto protocol.ID)

+ func (_m *NetworkMetrics) AllowService(svc string)

+ func (_m *NetworkMetrics) AllowStream(p peer.ID, dir network.Direction)

+ func (_m *NetworkMetrics) BlockConn(dir network.Direction, usefd bool)

+ func (_m *NetworkMetrics) BlockMemory(size int)

+ func (_m *NetworkMetrics) BlockPeer(p peer.ID)

+ func (_m *NetworkMetrics) BlockProtocol(proto protocol.ID)

+ func (_m *NetworkMetrics) BlockProtocolPeer(proto protocol.ID, p peer.ID)

+ func (_m *NetworkMetrics) BlockService(svc string)

+ func (_m *NetworkMetrics) BlockServicePeer(svc string, p peer.ID)

+ func (_m *NetworkMetrics) BlockStream(p peer.ID, dir network.Direction)

+ func (_m *NetworkMetrics) OnGraftReceived(count int)

+ func (_m *NetworkMetrics) OnIHaveReceived(count int)

+ func (_m *NetworkMetrics) OnIWantReceived(count int)

+ func (_m *NetworkMetrics) OnIncomingRpcAcceptedFully()

+ func (_m *NetworkMetrics) OnIncomingRpcAcceptedOnlyForControlMessages()

+ func (_m *NetworkMetrics) OnIncomingRpcRejected()

+ func (_m *NetworkMetrics) OnPruneReceived(count int)

+ func (_m *NetworkMetrics) OnPublishedGossipMessagesReceived(count int)

Nov 1, 2022

Changes in this version

type ExecutionMetrics

+ func (_m *ExecutionMetrics) ExecutionChunkDataPackGenerated(proofSize int, numberOfTransactions int)

Oct 18, 2022

Changes in this version

type ExecutionMetrics

+ func (_m *ExecutionMetrics) ExecutionBlockExecutionEffortVectorComponent(_a0 string, _a1 uint)

Oct 13, 2022

Changes in this version

type ExecutionMetrics

+ func (_m *ExecutionMetrics) ChunkDataPackRequestProcessed()

+ func (_m *ExecutionMetrics) ExecutionComputationResultUploadRetried()

+ func (_m *ExecutionMetrics) ExecutionComputationResultUploaded()

+ type IdentifierProvider struct

+ func NewIdentifierProvider(t mockConstructorTestingTNewIdentifierProvider) *IdentifierProvider

+ func (_m *IdentifierProvider) Identifiers() flow.IdentifierList

+ type IdentityProvider struct

+ func NewIdentityProvider(t mockConstructorTestingTNewIdentityProvider) *IdentityProvider

+ func (_m *IdentityProvider) ByNodeID(_a0 flow.Identifier) (*flow.Identity, bool)

+ func (_m *IdentityProvider) ByPeerID(_a0 peer.ID) (*flow.Identity, bool)

+ func (_m *IdentityProvider) Identities(_a0 flow.IdentityFilter) flow.IdentityList

type NetworkMetrics

+ func (_m *NetworkMetrics) OnRateLimitedUnicastMessage(role string, msgType string, topic string)

+ func (_m *NetworkMetrics) OnUnauthorizedMessage(role string, msgType string, topic string, offense string)

+ type NetworkSecurityMetrics struct

+ func NewNetworkSecurityMetrics(t mockConstructorTestingTNewNetworkSecurityMetrics) *NetworkSecurityMetrics

+ func (_m *NetworkSecurityMetrics) OnRateLimitedUnicastMessage(role string, msgType string, topic string)

+ func (_m *NetworkSecurityMetrics) OnUnauthorizedMessage(role string, msgType string, topic string, offense string)

type ProviderMetrics

+ func (_m *ProviderMetrics) ChunkDataPackRequestProcessed()

+ type RateLimitedBlockstoreMetrics struct

+ func NewRateLimitedBlockstoreMetrics(t mockConstructorTestingTNewRateLimitedBlockstoreMetrics) *RateLimitedBlockstoreMetrics

+ func (_m *RateLimitedBlockstoreMetrics) BytesRead(_a0 int)

Aug 21, 2022

Changes in this version

+ type BitswapMetrics struct

+ func NewBitswapMetrics(t mockConstructorTestingTNewBitswapMetrics) *BitswapMetrics

+ func (_m *BitswapMetrics) BlobsReceived(prefix string, n uint64)

+ func (_m *BitswapMetrics) BlobsSent(prefix string, n uint64)

+ func (_m *BitswapMetrics) DataReceived(prefix string, n uint64)

+ func (_m *BitswapMetrics) DataSent(prefix string, n uint64)

+ func (_m *BitswapMetrics) DupBlobsReceived(prefix string, n uint64)

+ func (_m *BitswapMetrics) DupDataReceived(prefix string, n uint64)

+ func (_m *BitswapMetrics) MessagesReceived(prefix string, n uint64)

+ func (_m *BitswapMetrics) Peers(prefix string, n int)

+ func (_m *BitswapMetrics) Wantlist(prefix string, n int)

Aug 10, 2022

Changes in this version

+ type ExecutionDataProviderMetrics struct

+ func NewExecutionDataProviderMetrics(t NewExecutionDataProviderMetricsT) *ExecutionDataProviderMetrics

+ func (_m *ExecutionDataProviderMetrics) AddBlobsFailed()

+ func (_m *ExecutionDataProviderMetrics) AddBlobsSucceeded(duration time.Duration, totalSize uint64)

+ func (_m *ExecutionDataProviderMetrics) RootIDComputed(duration time.Duration, numberOfChunks int)

+ type ExecutionDataPrunerMetrics struct

+ func NewExecutionDataPrunerMetrics(t NewExecutionDataPrunerMetricsT) *ExecutionDataPrunerMetrics

+ func (_m *ExecutionDataPrunerMetrics) Pruned(height uint64, duration time.Duration)

+ type ExecutionDataRequesterV2Metrics struct

+ func NewExecutionDataRequesterV2Metrics(t NewExecutionDataRequesterV2MetricsT) *ExecutionDataRequesterV2Metrics

+ func (_m *ExecutionDataRequesterV2Metrics) FulfilledHeight(blockHeight uint64)

+ func (_m *ExecutionDataRequesterV2Metrics) ReceiptSkipped()

+ func (_m *ExecutionDataRequesterV2Metrics) RequestCanceled()

+ func (_m *ExecutionDataRequesterV2Metrics) RequestFailed(duration time.Duration, retryable bool)

+ func (_m *ExecutionDataRequesterV2Metrics) RequestSucceeded(blockHeight uint64, duration time.Duration, totalSize uint64, ...)

+ func (_m *ExecutionDataRequesterV2Metrics) ResponseDropped()

+ type NewExecutionDataProviderMetricsT interface

+ Cleanup func(func())

+ type NewExecutionDataPrunerMetricsT interface

+ Cleanup func(func())

+ type NewExecutionDataRequesterV2MetricsT interface

+ Cleanup func(func())

Aug 2, 2022

Changes in this version

+ type ChainSyncMetrics struct

+ func NewChainSyncMetrics(t NewChainSyncMetricsT) *ChainSyncMetrics

+ func (_m *ChainSyncMetrics) BatchRequested(batch chainsync.Batch)

+ func (_m *ChainSyncMetrics) PrunedBlockByHeight(status *chainsync.Status)

+ func (_m *ChainSyncMetrics) PrunedBlockById(status *chainsync.Status)

+ func (_m *ChainSyncMetrics) PrunedBlocks(totalByHeight int, totalById int, storedByHeight int, storedById int)

+ func (_m *ChainSyncMetrics) RangeRequested(ran chainsync.Range)

type ExecutionMetrics

+ func (_m *ExecutionMetrics) UpdateCollectionMaxHeight(height uint64)

+ type NewAccessMetricsT interface

+ Cleanup func(func())

+ type NewBackendScriptsMetricsT interface

+ Cleanup func(func())

+ type NewBlockRequesterT interface

+ Cleanup func(func())

+ type NewBuilderT interface

+ Cleanup func(func())

+ type NewCacheMetricsT interface

+ Cleanup func(func())

+ type NewChainSyncMetricsT interface

+ Cleanup func(func())

+ type NewChunkAssignerT interface

+ Cleanup func(func())

+ type NewChunkVerifierT interface

+ Cleanup func(func())

+ type NewCleanerMetricsT interface

+ Cleanup func(func())

+ type NewClusterRootQCVoterT interface

+ Cleanup func(func())

+ type NewCollectionMetricsT interface

+ Cleanup func(func())

+ type NewComplianceMetricsT interface

+ Cleanup func(func())

+ type NewConsensusMetricsT interface

+ Cleanup func(func())

+ type NewDHTMetricsT interface

+ Cleanup func(func())

+ type NewDKGBrokerT interface

+ Cleanup func(func())

+ type NewDKGContractClientT interface

+ Cleanup func(func())

+ type NewDKGControllerFactoryT interface

+ Cleanup func(func())

+ type NewDKGControllerT interface

+ Cleanup func(func())

+ type NewEngineMetricsT interface

+ Cleanup func(func())

+ type NewEntriesFuncT interface

+ Cleanup func(func())

+ type NewEpochLookupT interface

+ Cleanup func(func())

+ type NewExecutionDataRequesterMetricsT interface

+ Cleanup func(func())

+ type NewExecutionDataServiceMetricsT interface

+ Cleanup func(func())

+ type NewExecutionMetricsT interface

+ Cleanup func(func())

+ type NewFinalizerT interface

+ Cleanup func(func())

+ type NewHeroCacheMetricsT interface

+ Cleanup func(func())

+ type NewHotStuffFollowerT interface

+ Cleanup func(func())

+ type NewHotStuffT interface

+ Cleanup func(func())

+ type NewHotstuffMetricsT interface

+ Cleanup func(func())

+ type NewJobConsumerT interface

+ Cleanup func(func())

+ type NewJobQueueT interface

+ Cleanup func(func())

+ type NewJobT interface

+ Cleanup func(func())

+ type NewJobsT interface

+ Cleanup func(func())

+ type NewLedgerMetricsT interface

+ Cleanup func(func())

+ type NewLocalT interface

+ Cleanup func(func())

+ type NewMempoolMetricsT interface

+ Cleanup func(func())

+ type NewNetworkMetricsT interface

+ Cleanup func(func())

+ type NewNewJobListenerT interface

+ Cleanup func(func())

+ type NewPendingBlockBufferT interface

+ Cleanup func(func())

+ type NewPendingClusterBlockBufferT interface

+ Cleanup func(func())

+ type NewPingMetricsT interface

+ Cleanup func(func())

+ type NewProcessingNotifierT interface

+ Cleanup func(func())

+ type NewProviderMetricsT interface

+ Cleanup func(func())

+ type NewPublicKeyT interface

+ Cleanup func(func())

+ type NewQCContractClientT interface

+ Cleanup func(func())

+ type NewRandomBeaconKeyStoreT interface

+ Cleanup func(func())

+ type NewReadyDoneAwareT interface

+ Cleanup func(func())

+ type NewReceiptValidatorT interface

+ Cleanup func(func())

+ type NewRequesterT interface

+ Cleanup func(func())

+ type NewResolverMetricsT interface

+ Cleanup func(func())

+ type NewRuntimeMetricsT interface

+ Cleanup func(func())

+ type NewSDKClientWrapperT interface

+ Cleanup func(func())

+ type NewSealValidatorT interface

+ Cleanup func(func())

+ type NewSealingConfigsGetterT interface

+ Cleanup func(func())

+ type NewSealingConfigsSetterT interface

+ Cleanup func(func())

+ type NewStartableT interface

+ Cleanup func(func())

+ type NewSyncCoreT interface

+ Cleanup func(func())

+ type NewTracerT interface

+ Cleanup func(func())

+ type NewTransactionMetricsT interface

+ Cleanup func(func())

+ type NewVerificationMetricsT interface

+ Cleanup func(func())

+ type NewWALMetricsT interface

+ Cleanup func(func())

type TransactionMetrics

+ func (_m *TransactionMetrics) UpdateExecutionReceiptMaxHeight(height uint64)

Jul 20, 2022

Changes in this version

type AccessMetrics

+ func (_m *AccessMetrics) ConnectionAddedToPool()

+ func (_m *AccessMetrics) ConnectionFromPoolEvicted()

+ func (_m *AccessMetrics) ConnectionFromPoolInvalidated()

+ func (_m *AccessMetrics) ConnectionFromPoolReused()

+ func (_m *AccessMetrics) ConnectionFromPoolUpdated()

+ func (_m *AccessMetrics) NewConnectionEstablished()

+ type DHTMetrics struct

+ func NewDHTMetrics(t testing.TB) *DHTMetrics

+ func (_m *DHTMetrics) RoutingTablePeerAdded()

+ func (_m *DHTMetrics) RoutingTablePeerRemoved()

+ type SealingConfigsGetter struct

+ func NewSealingConfigsGetter(t testing.TB) *SealingConfigsGetter

+ func (_m *SealingConfigsGetter) ApprovalRequestsThresholdConst() uint64

+ func (_m *SealingConfigsGetter) ChunkAlphaConst() uint

+ func (_m *SealingConfigsGetter) EmergencySealingActiveConst() bool

+ func (_m *SealingConfigsGetter) RequireApprovalsForSealConstructionDynamicValue() uint

+ func (_m *SealingConfigsGetter) RequireApprovalsForSealVerificationConst() uint

+ type SealingConfigsSetter struct

+ func NewSealingConfigsSetter(t testing.TB) *SealingConfigsSetter

+ func (_m *SealingConfigsSetter) ApprovalRequestsThresholdConst() uint64

+ func (_m *SealingConfigsSetter) ChunkAlphaConst() uint

+ func (_m *SealingConfigsSetter) EmergencySealingActiveConst() bool

+ func (_m *SealingConfigsSetter) RequireApprovalsForSealConstructionDynamicValue() uint

+ func (_m *SealingConfigsSetter) RequireApprovalsForSealVerificationConst() uint

+ func (_m *SealingConfigsSetter) SetRequiredApprovalsForSealingConstruction(newVal uint) (uint, error)

Jul 11, 2022

Changes in this version

+ type AccessMetrics struct

+ func NewAccessMetrics(t testing.TB) *AccessMetrics

+ func (_m *AccessMetrics) ConnectionFromPoolRetrieved()

+ func (_m *AccessMetrics) TotalConnectionsInPool(connectionCount uint, connectionPoolSize uint)

type NetworkMetrics

+ func (_m *NetworkMetrics) RoutingTablePeerAdded()

+ func (_m *NetworkMetrics) RoutingTablePeerRemoved()

Jun 1, 2022

Changes in this version

type BackendScriptsMetrics

+ func NewBackendScriptsMetrics(t testing.TB) *BackendScriptsMetrics

+ type ExecutionDataRequesterMetrics struct

+ func NewExecutionDataRequesterMetrics(t testing.TB) *ExecutionDataRequesterMetrics

+ func (_m *ExecutionDataRequesterMetrics) ExecutionDataFetchFinished(duration time.Duration, success bool, height uint64)

+ func (_m *ExecutionDataRequesterMetrics) ExecutionDataFetchStarted()

+ func (_m *ExecutionDataRequesterMetrics) FetchRetried()

+ func (_m *ExecutionDataRequesterMetrics) NotificationSent(height uint64)

type JobConsumer

+ func (_m *JobConsumer) LastProcessedIndex() uint64

May 25, 2022

Changes in this version

+ type BackendScriptsMetrics struct

+ func (_m *BackendScriptsMetrics) ScriptExecuted(dur time.Duration, size int)

type BlockRequester

+ func NewBlockRequester(t testing.TB) *BlockRequester

type Builder

+ func NewBuilder(t testing.TB) *Builder

type CacheMetrics

+ func NewCacheMetrics(t testing.TB) *CacheMetrics

type ChunkAssigner

+ func NewChunkAssigner(t testing.TB) *ChunkAssigner

type ChunkVerifier

+ func NewChunkVerifier(t testing.TB) *ChunkVerifier

type CleanerMetrics

+ func NewCleanerMetrics(t testing.TB) *CleanerMetrics

type ClusterRootQCVoter

+ func NewClusterRootQCVoter(t testing.TB) *ClusterRootQCVoter

type CollectionMetrics

+ func NewCollectionMetrics(t testing.TB) *CollectionMetrics

type ComplianceMetrics

+ func NewComplianceMetrics(t testing.TB) *ComplianceMetrics

type ConsensusMetrics

+ func NewConsensusMetrics(t testing.TB) *ConsensusMetrics

type DKGBroker

+ func NewDKGBroker(t testing.TB) *DKGBroker

type DKGContractClient

+ func NewDKGContractClient(t testing.TB) *DKGContractClient

type DKGController

+ func NewDKGController(t testing.TB) *DKGController

type DKGControllerFactory

+ func NewDKGControllerFactory(t testing.TB) *DKGControllerFactory

type EngineMetrics

+ func NewEngineMetrics(t testing.TB) *EngineMetrics

+ type EntriesFunc struct

+ func NewEntriesFunc(t testing.TB) *EntriesFunc

+ func (_m *EntriesFunc) Execute() uint

type EpochLookup

+ func NewEpochLookup(t testing.TB) *EpochLookup

type ExecutionDataServiceMetrics

+ func NewExecutionDataServiceMetrics(t testing.TB) *ExecutionDataServiceMetrics

type ExecutionMetrics

+ func NewExecutionMetrics(t testing.TB) *ExecutionMetrics

type Finalizer

+ func NewFinalizer(t testing.TB) *Finalizer

type HeroCacheMetrics

+ func NewHeroCacheMetrics(t testing.TB) *HeroCacheMetrics

type HotStuff

+ func NewHotStuff(t testing.TB) *HotStuff

type HotStuffFollower

+ func NewHotStuffFollower(t testing.TB) *HotStuffFollower

type HotstuffMetrics

+ func NewHotstuffMetrics(t testing.TB) *HotstuffMetrics

type Job

+ func NewJob(t testing.TB) *Job

type JobConsumer

+ func NewJobConsumer(t testing.TB) *JobConsumer

type JobQueue

+ func NewJobQueue(t testing.TB) *JobQueue

type Jobs

+ func NewJobs(t testing.TB) *Jobs

type LedgerMetrics

+ func NewLedgerMetrics(t testing.TB) *LedgerMetrics

type Local

+ func NewLocal(t testing.TB) *Local

type MempoolMetrics

+ func NewMempoolMetrics(t testing.TB) *MempoolMetrics

type NetworkMetrics

+ func NewNetworkMetrics(t testing.TB) *NetworkMetrics

type NewJobListener

+ func NewNewJobListener(t testing.TB) *NewJobListener

type PendingBlockBuffer

+ func NewPendingBlockBuffer(t testing.TB) *PendingBlockBuffer

type PendingClusterBlockBuffer

+ func NewPendingClusterBlockBuffer(t testing.TB) *PendingClusterBlockBuffer

type PingMetrics

+ func NewPingMetrics(t testing.TB) *PingMetrics

type ProcessingNotifier

+ func NewProcessingNotifier(t testing.TB) *ProcessingNotifier

type ProviderMetrics

+ func NewProviderMetrics(t testing.TB) *ProviderMetrics

type PublicKey

+ func NewPublicKey(t testing.TB) *PublicKey

type QCContractClient

+ func NewQCContractClient(t testing.TB) *QCContractClient

type RandomBeaconKeyStore

+ func NewRandomBeaconKeyStore(t testing.TB) *RandomBeaconKeyStore

type ReadyDoneAware

+ func NewReadyDoneAware(t testing.TB) *ReadyDoneAware

type ReceiptValidator

+ func NewReceiptValidator(t testing.TB) *ReceiptValidator

type Requester

+ func NewRequester(t testing.TB) *Requester

type ResolverMetrics

+ func NewResolverMetrics(t testing.TB) *ResolverMetrics

type RuntimeMetrics

+ func NewRuntimeMetrics(t testing.TB) *RuntimeMetrics

type SDKClientWrapper

+ func NewSDKClientWrapper(t testing.TB) *SDKClientWrapper

type SealValidator

+ func NewSealValidator(t testing.TB) *SealValidator

type Startable

+ func NewStartable(t testing.TB) *Startable

type SyncCore

+ func NewSyncCore(t testing.TB) *SyncCore

type Tracer

+ func NewTracer(t testing.TB) *Tracer

type TransactionMetrics

+ func NewTransactionMetrics(t testing.TB) *TransactionMetrics

+ func (_m *TransactionMetrics) ScriptExecuted(dur time.Duration, size int)

+ func (_m *TransactionMetrics) TransactionResultFetched(dur time.Duration, size int)

type VerificationMetrics

+ func NewVerificationMetrics(t testing.TB) *VerificationMetrics

type WALMetrics

+ func NewWALMetrics(t testing.TB) *WALMetrics

Mar 23, 2022

Changes in this version

type ExecutionMetrics

+ func (_m *ExecutionMetrics) LatestTrieMaxDepthTouched(maxDepth uint16)

+ func (_m *ExecutionMetrics) LatestTrieRegSize(size uint64)

+ func (_m *ExecutionMetrics) LatestTrieRegSizeDiff(size int64)

type LedgerMetrics

+ func (_m *LedgerMetrics) LatestTrieMaxDepthTouched(maxDepth uint16)

+ func (_m *LedgerMetrics) LatestTrieRegSize(size uint64)

+ func (_m *LedgerMetrics) LatestTrieRegSizeDiff(size int64)

Mar 10, 2022

Changes in this version

type PendingBlockBuffer

+ func (_m *PendingBlockBuffer) PruneByView(view uint64)

type PendingClusterBlockBuffer

+ func (_m *PendingClusterBlockBuffer) PruneByView(view uint64)

Apr 27, 2022

Changes in this version

+ type HeroCacheMetrics struct

+ func (_m *HeroCacheMetrics) BucketAvailableSlots(_a0 uint64, _a1 uint64)

+ func (_m *HeroCacheMetrics) OnEntityEjectionDueToEmergency()

+ func (_m *HeroCacheMetrics) OnEntityEjectionDueToFullCapacity()

+ func (_m *HeroCacheMetrics) OnKeyGetFailure()

+ func (_m *HeroCacheMetrics) OnKeyGetSuccess()

+ func (_m *HeroCacheMetrics) OnKeyPutFailure()

+ func (_m *HeroCacheMetrics) OnKeyPutSuccess()

Mar 2, 2022

Changes in this version

type NetworkMetrics

+ func (_m *NetworkMetrics) DirectMessageFinished(topic string)

+ func (_m *NetworkMetrics) DirectMessageStarted(topic string)

+ func (_m *NetworkMetrics) MessageProcessingFinished(topic string, duration time.Duration)

+ func (_m *NetworkMetrics) MessageProcessingStarted(topic string)

Feb 6, 2022

Changes in this version

type HotStuff

+ func (_m *HotStuff) Start(_a0 irrecoverable.SignalerContext)

type NetworkMetrics

+ func (_m *NetworkMetrics) OnDNSLookupRequestDropped()

+ type PublicKey struct

+ func (_m *PublicKey) Algorithm() crypto.SigningAlgorithm

+ func (_m *PublicKey) Encode() []byte

+ func (_m *PublicKey) EncodeCompressed() []byte

+ func (_m *PublicKey) Equals(_a0 crypto.PublicKey) bool

+ func (_m *PublicKey) Size() int

+ func (_m *PublicKey) String() string

+ func (_m *PublicKey) Verify(_a0 crypto.Signature, _a1 []byte, _a2 hash.Hasher) (bool, error)

+ type RandomBeaconKeyStore struct

+ func (_m *RandomBeaconKeyStore) ByView(view uint64) (crypto.PrivateKey, error)

type ResolverMetrics

+ func (_m *ResolverMetrics) OnDNSLookupRequestDropped()

Dec 21, 2021

Changes in this version

+ type ExecutionDataServiceMetrics struct

+ func (_m *ExecutionDataServiceMetrics) ExecutionDataAddFinished(duration time.Duration, success bool, blobTreeNodes int)

+ func (_m *ExecutionDataServiceMetrics) ExecutionDataAddStarted()

+ func (_m *ExecutionDataServiceMetrics) ExecutionDataGetFinished(duration time.Duration, success bool, blobTreeNodes int)

+ func (_m *ExecutionDataServiceMetrics) ExecutionDataGetStarted()

Nov 25, 2021

Changes in this version

type ComplianceMetrics

+ func (_m *ComplianceMetrics) EpochEmergencyFallbackTriggered()

Sep 30, 2021

Changes in this version

+ type Component struct

+ func (_m *Component) Done() <-chan struct{}

+ func (_m *Component) Ready() <-chan struct{}

+ func (_m *Component) Start(_a0 irrecoverable.SignalerContext)

+ type Startable struct

+ func (_m *Startable) Start(_a0 irrecoverable.SignalerContext)

Sep 22, 2021

Changes in this version

type Tracer

+ func (_m *Tracer) StartBlockSpan(ctx context.Context, blockID flow.Identifier, spanName trace.SpanName, ...) (opentracing.Span, context.Context, bool)

+ func (_m *Tracer) StartCollectionSpan(ctx context.Context, collectionID flow.Identifier, spanName trace.SpanName, ...) (opentracing.Span, context.Context, bool)

+ func (_m *Tracer) StartTransactionSpan(ctx context.Context, transactionID flow.Identifier, spanName trace.SpanName, ...) (opentracing.Span, context.Context, bool)

type VerificationMetrics

+ func (_m *VerificationMetrics) SetMaxChunkDataPackAttemptsForNextUnsealedHeightAtRequester(attempts uint64)

Sep 8, 2021

Changes in this version

type EpochLookup

+ func (_m *EpochLookup) EpochForViewWithFallback(view uint64) (uint64, error)

type NetworkMetrics

+ func (_m *NetworkMetrics) OnDNSCacheInvalidated()

+ func (_m *NetworkMetrics) UnstakedInboundConnections(connectionCount uint)

+ func (_m *NetworkMetrics) UnstakedOutboundConnections(connectionCount uint)

+ type ReadyDoneAwareNetwork struct

+ func (_m *ReadyDoneAwareNetwork) Done() <-chan struct{}

+ func (_m *ReadyDoneAwareNetwork) Ready() <-chan struct{}

+ func (_m *ReadyDoneAwareNetwork) Register(channel network.Channel, engine network.Engine) (network.Conduit, error)

type ResolverMetrics

+ func (_m *ResolverMetrics) OnDNSCacheInvalidated()

Sep 1, 2021

Changes in this version

type ComplianceMetrics

+ func (_m *ComplianceMetrics) CurrentDKGPhase1FinalView(view uint64)

+ func (_m *ComplianceMetrics) CurrentDKGPhase2FinalView(view uint64)

+ func (_m *ComplianceMetrics) CurrentDKGPhase3FinalView(view uint64)

+ func (_m *ComplianceMetrics) CurrentEpochFinalView(view uint64)

type NetworkMetrics

+ func (_m *NetworkMetrics) DNSLookupDuration(duration time.Duration)

+ func (_m *NetworkMetrics) OnDNSCacheHit()

+ func (_m *NetworkMetrics) OnDNSCacheMiss()

+ type ResolverMetrics struct

+ func (_m *ResolverMetrics) DNSLookupDuration(duration time.Duration)

+ func (_m *ResolverMetrics) OnDNSCacheHit()

+ func (_m *ResolverMetrics) OnDNSCacheMiss()

Aug 21, 2021

Changes in this version

type ExecutionMetrics

+ func (_m *ExecutionMetrics) ExecutionBlockDataUploadFinished(dur time.Duration)

+ func (_m *ExecutionMetrics) ExecutionBlockDataUploadStarted()

Jul 27, 2021

Changes in this version

type ComplianceMetrics

+ func (_m *ComplianceMetrics) CurrentEpochCounter(counter uint64)

+ func (_m *ComplianceMetrics) CurrentEpochPhase(phase flow.EpochPhase)

+ type DKGBroker struct

+ func (_m *DKGBroker) Broadcast(data []byte)

+ func (_m *DKGBroker) Disqualify(node int, log string)

+ func (_m *DKGBroker) FlagMisbehavior(node int, log string)

+ func (_m *DKGBroker) GetBroadcastMsgCh() <-chan messages.DKGMessage

+ func (_m *DKGBroker) GetIndex() int

+ func (_m *DKGBroker) GetPrivateMsgCh() <-chan messages.DKGMessage

+ func (_m *DKGBroker) Poll(referenceBlock flow.Identifier) error

+ func (_m *DKGBroker) PrivateSend(dest int, data []byte)

+ func (_m *DKGBroker) Shutdown()

+ func (_m *DKGBroker) SubmitResult(_a0 crypto.PublicKey, _a1 []crypto.PublicKey) error

+ type DKGContractClient struct

+ func (_m *DKGContractClient) Broadcast(msg messages.BroadcastDKGMessage) error

+ func (_m *DKGContractClient) ReadBroadcast(fromIndex uint, referenceBlock flow.Identifier) ([]messages.BroadcastDKGMessage, error)

+ func (_m *DKGContractClient) SubmitResult(_a0 crypto.PublicKey, _a1 []crypto.PublicKey) error

+ type DKGController struct

+ func (_m *DKGController) End() error

+ func (_m *DKGController) EndPhase1() error

+ func (_m *DKGController) EndPhase2() error

+ func (_m *DKGController) GetArtifacts() (crypto.PrivateKey, crypto.PublicKey, []crypto.PublicKey)

+ func (_m *DKGController) GetIndex() int

+ func (_m *DKGController) Poll(blockReference flow.Identifier) error

+ func (_m *DKGController) Run() error

+ func (_m *DKGController) Shutdown()

+ func (_m *DKGController) SubmitResult() error

+ type DKGControllerFactory struct

+ func (_m *DKGControllerFactory) Create(dkgInstanceID string, participants flow.IdentityList, seed []byte) (module.DKGController, error)

+ type EpochLookup struct

+ func (_m *EpochLookup) EpochForView(view uint64) (uint64, error)

+ type SDKClientWrapper struct

+ func (_m *SDKClientWrapper) ExecuteScriptAtBlockID(_a0 context.Context, _a1 flow.Identifier, _a2 []byte, _a3 []cadence.Value, ...) (cadence.Value, error)

+ func (_m *SDKClientWrapper) ExecuteScriptAtLatestBlock(_a0 context.Context, _a1 []byte, _a2 []cadence.Value, _a3 ...grpc.CallOption) (cadence.Value, error)

+ func (_m *SDKClientWrapper) GetAccount(_a0 context.Context, _a1 flow.Address, _a2 ...grpc.CallOption) (*flow.Account, error)

+ func (_m *SDKClientWrapper) GetAccountAtLatestBlock(_a0 context.Context, _a1 flow.Address, _a2 ...grpc.CallOption) (*flow.Account, error)

+ func (_m *SDKClientWrapper) GetLatestBlock(_a0 context.Context, _a1 bool, _a2 ...grpc.CallOption) (*flow.Block, error)

+ func (_m *SDKClientWrapper) GetTransactionResult(_a0 context.Context, _a1 flow.Identifier, _a2 ...grpc.CallOption) (*flow.TransactionResult, error)

+ func (_m *SDKClientWrapper) SendTransaction(_a0 context.Context, _a1 flow.Transaction, _a2 ...grpc.CallOption) error

+ type ThresholdSignerStore struct

+ func (_m *ThresholdSignerStore) GetThresholdSigner(view uint64) (module.ThresholdSigner, error)

Jul 14, 2021

Changes in this version

type VerificationMetrics

+ func (_m *VerificationMetrics) OnBlockConsumerJobDone(_a0 uint64)

+ func (_m *VerificationMetrics) OnChunkConsumerJobDone(_a0 uint64)

+ func (_m *VerificationMetrics) OnChunkDataPackRequestDispatchedInNetworkByRequester()

+ func (_m *VerificationMetrics) OnChunkDataPackResponseReceivedFromNetworkByRequester()

+ func (_m *VerificationMetrics) OnExecutionResultReceivedAtAssignerEngine()

+ func (_m *VerificationMetrics) OnResultApprovalDispatchedInNetworkByVerifier()

Jun 22, 2021

Changes in this version

type ComplianceMetrics

+ func (_m *ComplianceMetrics) CommittedEpochFinalView(view uint64)

type ExecutionMetrics

+ func (_m *ExecutionMetrics) ExecutionBlockExecuted(dur time.Duration, compUsed uint64, txCounts int, colCounts int)

+ func (_m *ExecutionMetrics) ExecutionCollectionExecuted(dur time.Duration, compUsed uint64, txCounts int)

+ func (_m *ExecutionMetrics) ExecutionScriptExecuted(dur time.Duration, compUsed uint64)

+ func (_m *ExecutionMetrics) ExecutionTransactionExecuted(dur time.Duration, compUsed uint64, eventCounts int, failed bool)

+ func (_m *ExecutionMetrics) RuntimeSetNumberOfAccounts(count uint64)

+ func (_m *ExecutionMetrics) RuntimeTransactionChecked(dur time.Duration)

+ func (_m *ExecutionMetrics) RuntimeTransactionInterpreted(dur time.Duration)

+ func (_m *ExecutionMetrics) RuntimeTransactionParsed(dur time.Duration)

type RuntimeMetrics

+ func (_m *RuntimeMetrics) RuntimeSetNumberOfAccounts(count uint64)

+ func (_m *RuntimeMetrics) RuntimeTransactionChecked(dur time.Duration)

+ func (_m *RuntimeMetrics) RuntimeTransactionInterpreted(dur time.Duration)

+ func (_m *RuntimeMetrics) RuntimeTransactionParsed(dur time.Duration)

Jun 11, 2021

Changes in this version

type ExecutionMetrics

+ func (_m *ExecutionMetrics) ExecutionComputationUsedPerBlock(computation uint64)

Jun 4, 2021

Changes in this version

type JobConsumer

+ func (_m *JobConsumer) Size() uint

type PingMetrics

+ func (_m *PingMetrics) NodeInfo(node *flow.Identity, nodeInfo string, version string, sealedHeight uint64)

May 18, 2021

Changes in this version

type VerificationMetrics

+ func (_m *VerificationMetrics) OnAssignedChunkProcessedAtAssigner()

+ func (_m *VerificationMetrics) OnAssignedChunkReceivedAtFetcher()

+ func (_m *VerificationMetrics) OnChunkDataPackArrivedAtFetcher()

+ func (_m *VerificationMetrics) OnChunkDataPackRequestDispatchedInNetwork()

+ func (_m *VerificationMetrics) OnChunkDataPackRequestReceivedByRequester()

+ func (_m *VerificationMetrics) OnChunkDataPackRequestSentByFetcher()

+ func (_m *VerificationMetrics) OnChunkDataPackResponseReceivedFromNetwork()

+ func (_m *VerificationMetrics) OnChunkDataPackSentToFetcher()

+ func (_m *VerificationMetrics) OnChunksAssignmentDoneAtAssigner(chunks int)

+ func (_m *VerificationMetrics) OnFinalizedBlockArrivedAtAssigner(height uint64)

+ func (_m *VerificationMetrics) OnResultApprovalDispatchedInNetwork()

+ func (_m *VerificationMetrics) OnVerifiableChunkReceivedAtVerifierEngine()

+ func (_m *VerificationMetrics) OnVerifiableChunkSentToVerifier()

Apr 14, 2021

Changes in this version

type CacheMetrics

+ func (_m *CacheMetrics) CacheNotFound(resource string)

type ReceiptValidator

+ func (_m *ReceiptValidator) ValidatePayload(candidate *flow.Block) error

Apr 5, 2021

Changes in this version

type ThresholdSigner

+ func (_m *ThresholdSigner) Reconstruct(size uint, shares []crypto.Signature, indices []uint) (crypto.Signature, error)

+ type WALMetrics struct

+ func (_m *WALMetrics) DiskSize(_a0 uint64)

Mar 17, 2021

Changes in this version

+ type ApprovalValidator struct

+ func (_m *ApprovalValidator) Validate(approval *flow.ResultApproval) error

type ComplianceMetrics

+ func (_m *ComplianceMetrics) BlockProposalDuration(duration time.Duration)

+ type Job struct

+ func (_m *Job) ID() module.JobID

+ type JobConsumer struct

+ func (_m *JobConsumer) Check()

+ func (_m *JobConsumer) NotifyJobIsDone(_a0 module.JobID)

+ func (_m *JobConsumer) Start(defaultIndex int64) error

+ func (_m *JobConsumer) Stop()

+ type JobQueue struct

+ func (_m *JobQueue) Add(job module.Job) error

+ type Jobs struct

+ func (_m *Jobs) AtIndex(index int64) (module.Job, error)

+ func (_m *Jobs) Head() (int64, error)

+ type NewJobListener struct

+ func (_m *NewJobListener) Check()

+ type ProcessingNotifier struct

+ func (_m *ProcessingNotifier) Notify(entityID flow.Identifier)

type Requester

+ func (_m *Requester) Query(key flow.Identifier, selector flow.IdentityFilter)

type Tracer

+ func (_m *Tracer) WithSpanFromContext(ctx context.Context, operationName trace.SpanName, f func(), ...)

type VerificationMetrics

+ func (_m *VerificationMetrics) OnAssignerProcessFinalizedBlock(height uint64)

+ func (_m *VerificationMetrics) OnChunkProcessed()

+ func (_m *VerificationMetrics) OnChunksAssigned(chunks int)

Feb 26, 2021

Changes in this version

type Tracer

+ func (_m *Tracer) RecordSpanFromParent(span opentracing.Span, operationName trace.SpanName, duration time.Duration, ...)

Feb 17, 2021

Changes in this version

type ConsensusMetrics

+ func (_m *ConsensusMetrics) OnApprovalProcessingDuration(duration time.Duration)

+ func (_m *ConsensusMetrics) OnReceiptProcessingDuration(duration time.Duration)

Feb 3, 2021

Changes in this version

type ConsensusMetrics

+ func (_m *ConsensusMetrics) EmergencySeal()

type NetworkMetrics

+ func (_m *NetworkMetrics) InboundProcessDuration(topic string, duration time.Duration)

+ type ReceiptValidator struct

+ func (_m *ReceiptValidator) Validate(receipts []*flow.ExecutionReceipt) error

+ type SealValidator struct

+ func (_m *SealValidator) Validate(candidate *flow.Block) (*flow.Seal, error)

Nov 24, 2020

Changes in this version

type NetworkMetrics

+ func (_m *NetworkMetrics) InboundConnections(connectionCount uint)

+ func (_m *NetworkMetrics) OutboundConnections(connectionCount uint)

Nov 3, 2020

Changes in this version

type ConsensusMetrics

+ func (_m *ConsensusMetrics) CheckSealingDuration(duration time.Duration)

Oct 6, 2020

Changes in this version

type ExecutionMetrics

+ func (_m *ExecutionMetrics) DiskSize(_a0 uint64)

type LedgerMetrics

+ func (_m *LedgerMetrics) DiskSize(_a0 uint64)

Sep 29, 2020

Changes in this version

+ type AggregatingSigner struct

+ func (_m *AggregatingSigner) Aggregate(sigs []crypto.Signature) (crypto.Signature, error)

+ func (_m *AggregatingSigner) Sign(msg []byte) (crypto.Signature, error)

+ func (_m *AggregatingSigner) Verify(msg []byte, sig crypto.Signature, key crypto.PublicKey) (bool, error)

+ func (_m *AggregatingSigner) VerifyMany(msg []byte, sig crypto.Signature, keys []crypto.PublicKey) (bool, error)

+ type AggregatingVerifier struct

+ func (_m *AggregatingVerifier) Verify(msg []byte, sig crypto.Signature, key crypto.PublicKey) (bool, error)

+ func (_m *AggregatingVerifier) VerifyMany(msg []byte, sig crypto.Signature, keys []crypto.PublicKey) (bool, error)

+ type BadgerMetrics struct

+ func (_m *BadgerMetrics) BadgerLSMSize(sizeBytes int64)

+ func (_m *BadgerMetrics) BadgerNumBlockedPuts(n int64)

+ func (_m *BadgerMetrics) BadgerNumBytesRead(n int64)

+ func (_m *BadgerMetrics) BadgerNumBytesWritten(n int64)

+ func (_m *BadgerMetrics) BadgerNumGets(n int64)

+ func (_m *BadgerMetrics) BadgerNumMemtableGets(n int64)

+ func (_m *BadgerMetrics) BadgerNumPuts(n int64)

+ func (_m *BadgerMetrics) BadgerNumReads(n int64)

+ func (_m *BadgerMetrics) BadgerNumWrites(n int64)

+ func (_m *BadgerMetrics) BadgerVLogSize(sizeBytes int64)

+ type BlockRequester struct

+ func (_m *BlockRequester) Prune(final *flow.Header)

+ func (_m *BlockRequester) RequestBlock(blockID flow.Identifier)

+ func (_m *BlockRequester) RequestHeight(height uint64)

+ type Builder struct

+ func (_m *Builder) BuildOn(parentID flow.Identifier, setter func(*flow.Header) error) (*flow.Header, error)

+ type CacheMetrics struct

+ func (_m *CacheMetrics) CacheEntries(resource string, entries uint)

+ func (_m *CacheMetrics) CacheHit(resource string)

+ func (_m *CacheMetrics) CacheMiss(resource string)

+ type ChunkAssigner struct

+ func (_m *ChunkAssigner) Assign(ids flow.IdentityList, _a1 flow.ChunkList, rng random.Rand) (*chunks.Assignment, error)

+ type ChunkVerifier struct

+ func (_m *ChunkVerifier) SystemChunkVerify(ch *verification.VerifiableChunkData) ([]byte, chunks.ChunkFault, error)

+ func (_m *ChunkVerifier) Verify(ch *verification.VerifiableChunkData) ([]byte, chunks.ChunkFault, error)

+ type CleanerMetrics struct

+ func (_m *CleanerMetrics) RanGC(took time.Duration)

+ type ClusterRootQCVoter struct

+ func (_m *ClusterRootQCVoter) Vote(_a0 context.Context, _a1 protocol.Epoch) error

+ type ColdStuff struct

+ func (_m *ColdStuff) Done() <-chan struct{}

+ func (_m *ColdStuff) Ready() <-chan struct{}

+ func (_m *ColdStuff) SubmitCommit(commit *coldstuff.Commit)

+ func (_m *ColdStuff) SubmitProposal(proposal *flow.Header, parentView uint64)

+ func (_m *ColdStuff) SubmitVote(originID flow.Identifier, blockID flow.Identifier, view uint64, sigData []byte)

+ type CollectionMetrics struct

+ func (_m *CollectionMetrics) ClusterBlockFinalized(block *cluster.Block)

+ func (_m *CollectionMetrics) ClusterBlockProposed(block *cluster.Block)

+ func (_m *CollectionMetrics) TransactionIngested(txID flow.Identifier)

+ type ComplianceMetrics struct

+ func (_m *ComplianceMetrics) BlockFinalized(_a0 *flow.Block)

+ func (_m *ComplianceMetrics) BlockSealed(_a0 *flow.Block)

+ func (_m *ComplianceMetrics) FinalizedHeight(height uint64)

+ func (_m *ComplianceMetrics) SealedHeight(height uint64)

+ type ConsensusMetrics struct

+ func (_m *ConsensusMetrics) FinishBlockToSeal(blockID flow.Identifier)

+ func (_m *ConsensusMetrics) FinishCollectionToFinalized(collectionID flow.Identifier)

+ func (_m *ConsensusMetrics) StartBlockToSeal(blockID flow.Identifier)

+ func (_m *ConsensusMetrics) StartCollectionToFinalized(collectionID flow.Identifier)

+ type Engine struct

+ func (_m *Engine) Done() <-chan struct{}

+ func (_m *Engine) Process(originID flow.Identifier, event interface{}) error

+ func (_m *Engine) ProcessLocal(event interface{}) error

+ func (_m *Engine) Ready() <-chan struct{}

+ func (_m *Engine) Submit(originID flow.Identifier, event interface{})

+ func (_m *Engine) SubmitLocal(event interface{})

+ type EngineMetrics struct

+ func (_m *EngineMetrics) MessageHandled(engine string, messages string)

+ func (_m *EngineMetrics) MessageReceived(engine string, message string)

+ func (_m *EngineMetrics) MessageSent(engine string, message string)

+ type ExecutionMetrics struct

+ func (_m *ExecutionMetrics) ChunkDataPackRequested()

+ func (_m *ExecutionMetrics) ExecutionCollectionRequestRetried()

+ func (_m *ExecutionMetrics) ExecutionCollectionRequestSent()

+ func (_m *ExecutionMetrics) ExecutionGasUsedPerBlock(gas uint64)

+ func (_m *ExecutionMetrics) ExecutionLastExecutedBlockHeight(height uint64)

+ func (_m *ExecutionMetrics) ExecutionStateReadsPerBlock(reads uint64)

+ func (_m *ExecutionMetrics) ExecutionStateStorageDiskTotal(bytes int64)

+ func (_m *ExecutionMetrics) ExecutionStorageStateCommitment(bytes int64)

+ func (_m *ExecutionMetrics) ExecutionSync(syncing bool)

+ func (_m *ExecutionMetrics) ExecutionTotalExecutedTransactions(numExecuted int)

+ func (_m *ExecutionMetrics) FinishBlockReceivedToExecuted(blockID flow.Identifier)

+ func (_m *ExecutionMetrics) ForestApproxMemorySize(bytes uint64)

+ func (_m *ExecutionMetrics) ForestNumberOfTrees(number uint64)

+ func (_m *ExecutionMetrics) LatestTrieMaxDepth(number uint64)

+ func (_m *ExecutionMetrics) LatestTrieMaxDepthDiff(number uint64)

+ func (_m *ExecutionMetrics) LatestTrieRegCount(number uint64)

+ func (_m *ExecutionMetrics) LatestTrieRegCountDiff(number uint64)

+ func (_m *ExecutionMetrics) ProofSize(bytes uint32)

+ func (_m *ExecutionMetrics) ReadDuration(duration time.Duration)

+ func (_m *ExecutionMetrics) ReadDurationPerItem(duration time.Duration)

+ func (_m *ExecutionMetrics) ReadValuesNumber(number uint64)

+ func (_m *ExecutionMetrics) ReadValuesSize(byte uint64)

+ func (_m *ExecutionMetrics) StartBlockReceivedToExecuted(blockID flow.Identifier)

+ func (_m *ExecutionMetrics) TransactionChecked(dur time.Duration)

+ func (_m *ExecutionMetrics) TransactionInterpreted(dur time.Duration)

+ func (_m *ExecutionMetrics) TransactionParsed(dur time.Duration)

+ func (_m *ExecutionMetrics) UpdateCount()

+ func (_m *ExecutionMetrics) UpdateDuration(duration time.Duration)

+ func (_m *ExecutionMetrics) UpdateDurationPerItem(duration time.Duration)

+ func (_m *ExecutionMetrics) UpdateValuesNumber(number uint64)

+ func (_m *ExecutionMetrics) UpdateValuesSize(byte uint64)

+ type Finalizer struct

+ func (_m *Finalizer) MakeFinal(blockID flow.Identifier) error

+ func (_m *Finalizer) MakeValid(blockID flow.Identifier) error

+ type HotStuff struct

+ func (_m *HotStuff) Done() <-chan struct{}

+ func (_m *HotStuff) Ready() <-chan struct{}

+ func (_m *HotStuff) SubmitProposal(proposal *flow.Header, parentView uint64)

+ func (_m *HotStuff) SubmitVote(originID flow.Identifier, blockID flow.Identifier, view uint64, sigData []byte)

+ type HotStuffFollower struct

+ func (_m *HotStuffFollower) Done() <-chan struct{}

+ func (_m *HotStuffFollower) Ready() <-chan struct{}

+ func (_m *HotStuffFollower) SubmitProposal(proposal *flow.Header, parentView uint64)

+ type HotstuffMetrics struct

+ func (_m *HotstuffMetrics) CommitteeProcessingDuration(duration time.Duration)

+ func (_m *HotstuffMetrics) CountSkipped()

+ func (_m *HotstuffMetrics) CountTimeout()

+ func (_m *HotstuffMetrics) HotStuffBusyDuration(duration time.Duration, event string)

+ func (_m *HotstuffMetrics) HotStuffIdleDuration(duration time.Duration)

+ func (_m *HotstuffMetrics) HotStuffWaitDuration(duration time.Duration, event string)

+ func (_m *HotstuffMetrics) PayloadProductionDuration(duration time.Duration)

+ func (_m *HotstuffMetrics) SetCurView(view uint64)

+ func (_m *HotstuffMetrics) SetQCView(view uint64)

+ func (_m *HotstuffMetrics) SetTimeout(duration time.Duration)

+ func (_m *HotstuffMetrics) SignerProcessingDuration(duration time.Duration)

+ func (_m *HotstuffMetrics) ValidatorProcessingDuration(duration time.Duration)

+ type LedgerMetrics struct

+ func (_m *LedgerMetrics) ForestApproxMemorySize(bytes uint64)

+ func (_m *LedgerMetrics) ForestNumberOfTrees(number uint64)

+ func (_m *LedgerMetrics) LatestTrieMaxDepth(number uint64)

+ func (_m *LedgerMetrics) LatestTrieMaxDepthDiff(number uint64)

+ func (_m *LedgerMetrics) LatestTrieRegCount(number uint64)

+ func (_m *LedgerMetrics) LatestTrieRegCountDiff(number uint64)

+ func (_m *LedgerMetrics) ProofSize(bytes uint32)

+ func (_m *LedgerMetrics) ReadDuration(duration time.Duration)

+ func (_m *LedgerMetrics) ReadDurationPerItem(duration time.Duration)

+ func (_m *LedgerMetrics) ReadValuesNumber(number uint64)

+ func (_m *LedgerMetrics) ReadValuesSize(byte uint64)

+ func (_m *LedgerMetrics) UpdateCount()

+ func (_m *LedgerMetrics) UpdateDuration(duration time.Duration)

+ func (_m *LedgerMetrics) UpdateDurationPerItem(duration time.Duration)

+ func (_m *LedgerMetrics) UpdateValuesNumber(number uint64)

+ func (_m *LedgerMetrics) UpdateValuesSize(byte uint64)

+ type Local struct

+ func (_m *Local) Address() string

+ func (_m *Local) NodeID() flow.Identifier

+ func (_m *Local) NotMeFilter() flow.IdentityFilter

+ func (_m *Local) Sign(_a0 []byte, _a1 hash.Hasher) (crypto.Signature, error)

+ func (_m *Local) SignFunc(_a0 []byte, _a1 hash.Hasher, ...) (crypto.Signature, error)

+ type MempoolMetrics struct

+ func (_m *MempoolMetrics) MempoolEntries(resource string, entries uint)

+ func (_m *MempoolMetrics) Register(resource string, entriesFunc metrics.EntriesFunc) error

+ type Merger struct

+ func (_m *Merger) Join(sigs ...crypto.Signature) ([]byte, error)

+ func (_m *Merger) Split(combined []byte) ([]crypto.Signature, error)

+ type Network struct

+ func (_m *Network) Register(channelID string, engine network.Engine) (network.Conduit, error)

+ type NetworkMetrics struct

+ func (_m *NetworkMetrics) MessageAdded(priority int)

+ func (_m *NetworkMetrics) MessageRemoved(priority int)

+ func (_m *NetworkMetrics) NetworkDuplicateMessagesDropped(topic string, messageType string)

+ func (_m *NetworkMetrics) NetworkMessageReceived(sizeBytes int, topic string, messageType string)

+ func (_m *NetworkMetrics) NetworkMessageSent(sizeBytes int, topic string, messageType string)

+ func (_m *NetworkMetrics) QueueDuration(duration time.Duration, priority int)

+ type PendingBlockBuffer struct

+ func (_m *PendingBlockBuffer) Add(originID flow.Identifier, proposal *messages.BlockProposal) bool

+ func (_m *PendingBlockBuffer) ByID(blockID flow.Identifier) (*flow.PendingBlock, bool)

+ func (_m *PendingBlockBuffer) ByParentID(parentID flow.Identifier) ([]*flow.PendingBlock, bool)

+ func (_m *PendingBlockBuffer) DropForParent(parentID flow.Identifier)

+ func (_m *PendingBlockBuffer) PruneByHeight(height uint64)

+ func (_m *PendingBlockBuffer) Size() uint

+ type PendingClusterBlockBuffer struct

+ func (_m *PendingClusterBlockBuffer) Add(originID flow.Identifier, proposal *messages.ClusterBlockProposal) bool

+ func (_m *PendingClusterBlockBuffer) ByID(blockID flow.Identifier) (*cluster.PendingBlock, bool)

+ func (_m *PendingClusterBlockBuffer) ByParentID(parentID flow.Identifier) ([]*cluster.PendingBlock, bool)

+ func (_m *PendingClusterBlockBuffer) DropForParent(parentID flow.Identifier)

+ func (_m *PendingClusterBlockBuffer) PruneByHeight(height uint64)

+ func (_m *PendingClusterBlockBuffer) Size() uint

+ type PingMetrics struct

+ func (_m *PingMetrics) NodeReachable(node *flow.Identity, reachable bool)

+ type ProviderMetrics struct

+ func (_m *ProviderMetrics) ChunkDataPackRequested()

+ type QCContractClient struct

+ func (_m *QCContractClient) SubmitVote(ctx context.Context, vote *model.Vote) error

+ func (_m *QCContractClient) Voted(ctx context.Context) (bool, error)

+ type ReadyDoneAware struct

+ func (_m *ReadyDoneAware) Done() <-chan struct{}

+ func (_m *ReadyDoneAware) Ready() <-chan struct{}

+ type Requester struct

+ func (_m *Requester) EntityByID(entityID flow.Identifier, selector flow.IdentityFilter)

+ func (_m *Requester) Force()

+ type RuntimeMetrics struct

+ func (_m *RuntimeMetrics) TransactionChecked(dur time.Duration)

+ func (_m *RuntimeMetrics) TransactionInterpreted(dur time.Duration)

+ func (_m *RuntimeMetrics) TransactionParsed(dur time.Duration)

+ type Signer struct

+ func (_m *Signer) Sign(msg []byte) (crypto.Signature, error)

+ func (_m *Signer) Verify(msg []byte, sig crypto.Signature, key crypto.PublicKey) (bool, error)

+ type StateMetrics struct

+ func (_m *StateMetrics) BlockFinalized(_a0 *flow.Block)

+ func (_m *StateMetrics) BlockProposed(_a0 *flow.Block)

+ func (_m *StateMetrics) BlockSealed(_a0 *flow.Block)

+ type SyncCore struct

+ func (_m *SyncCore) BatchRequested(batch flow.Batch)

+ func (_m *SyncCore) HandleBlock(header *flow.Header) bool

+ func (_m *SyncCore) HandleHeight(final *flow.Header, height uint64)

+ func (_m *SyncCore) RangeRequested(ran flow.Range)

+ func (_m *SyncCore) ScanPending(final *flow.Header) ([]flow.Range, []flow.Batch)

+ func (_m *SyncCore) WithinTolerance(final *flow.Header, height uint64) bool

+ type Synchronization struct

+ func (_m *Synchronization) Done() <-chan struct{}

+ func (_m *Synchronization) Ready() <-chan struct{}

+ func (_m *Synchronization) RequestBlock(blockID flow.Identifier)

+ type ThresholdSigner struct

+ func (_m *ThresholdSigner) Combine(size uint, shares []crypto.Signature, indices []uint) (crypto.Signature, error)

+ func (_m *ThresholdSigner) Sign(msg []byte) (crypto.Signature, error)

+ func (_m *ThresholdSigner) Verify(msg []byte, sig crypto.Signature, key crypto.PublicKey) (bool, error)

+ func (_m *ThresholdSigner) VerifyThreshold(msg []byte, sig crypto.Signature, key crypto.PublicKey) (bool, error)

+ type ThresholdVerifier struct

+ func (_m *ThresholdVerifier) Verify(msg []byte, sig crypto.Signature, key crypto.PublicKey) (bool, error)

+ func (_m *ThresholdVerifier) VerifyThreshold(msg []byte, sig crypto.Signature, key crypto.PublicKey) (bool, error)

+ type Tracer struct

+ func (_m *Tracer) Done() <-chan struct{}

+ func (_m *Tracer) FinishSpan(entity flow.Identifier, spanName trace.SpanName)

+ func (_m *Tracer) GetSpan(entity flow.Identifier, spanName trace.SpanName) (opentracing.Span, bool)

+ func (_m *Tracer) Ready() <-chan struct{}

+ func (_m *Tracer) StartSpan(entity flow.Identifier, spanName trace.SpanName, ...) opentracing.Span

+ func (_m *Tracer) StartSpanFromContext(ctx context.Context, operationName trace.SpanName, ...) (opentracing.Span, context.Context)

+ func (_m *Tracer) StartSpanFromParent(span opentracing.Span, operationName trace.SpanName, ...) opentracing.Span

+ type TransactionMetrics struct

+ func (_m *TransactionMetrics) TransactionExecuted(txID flow.Identifier, when time.Time)

+ func (_m *TransactionMetrics) TransactionExpired(txID flow.Identifier)

+ func (_m *TransactionMetrics) TransactionFinalized(txID flow.Identifier, when time.Time)

+ func (_m *TransactionMetrics) TransactionReceived(txID flow.Identifier, when time.Time)

+ func (_m *TransactionMetrics) TransactionSubmissionFailed()

+ type TransactionValidator struct

+ func (_m *TransactionValidator) ValidateTransaction(tx *flow.TransactionBody) error

+ type VerificationMetrics struct

+ func (_m *VerificationMetrics) LogVerifiableChunkSize(size float64)

+ func (_m *VerificationMetrics) OnChunkDataPackReceived()

+ func (_m *VerificationMetrics) OnChunkDataPackRequested()

+ func (_m *VerificationMetrics) OnExecutionReceiptReceived()

+ func (_m *VerificationMetrics) OnExecutionResultReceived()

+ func (_m *VerificationMetrics) OnExecutionResultSent()

+ func (_m *VerificationMetrics) OnResultApproval()

+ func (_m *VerificationMetrics) OnVerifiableChunkReceived()

+ func (_m *VerificationMetrics) OnVerifiableChunkSent()

+ type Verifier struct

+ func (_m *Verifier) Verify(msg []byte, sig crypto.Signature, key crypto.PublicKey) (bool, error)