metricsreporter

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Nov 7, 2023 License: GPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MetricsReporter 

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

func New 

func New(opts ...Option) *MetricsReporter

func (*MetricsReporter) ActiveMsgValidation 

func (m *MetricsReporter) ActiveMsgValidation(topic string)

func (*MetricsReporter) ActiveMsgValidationDone 

func (m *MetricsReporter) ActiveMsgValidationDone(topic string)

func (*MetricsReporter) ConsensusMsgType 

func (m *MetricsReporter) ConsensusMsgType(msgType specqbft.MessageType, signers int)

func (*MetricsReporter) DroppedQueueMessage 

func (m *MetricsReporter) DroppedQueueMessage(messageID spectypes.MessageID)

func (*MetricsReporter) EventProcessed 

func (m *MetricsReporter) EventProcessed(eventName string)

func (*MetricsReporter) EventProcessingFailed 

func (m *MetricsReporter) EventProcessingFailed(eventName string)

func (*MetricsReporter) ExecutionClientFailure 

func (m *MetricsReporter) ExecutionClientFailure()

func (*MetricsReporter) ExecutionClientLastFetchedBlock 

func (m *MetricsReporter) ExecutionClientLastFetchedBlock(block uint64)

func (*MetricsReporter) ExecutionClientReady 

func (m *MetricsReporter) ExecutionClientReady()

func (*MetricsReporter) ExecutionClientSyncing 

func (m *MetricsReporter) ExecutionClientSyncing()

func (*MetricsReporter) InCommitteeMessage 

func (m *MetricsReporter) InCommitteeMessage(msgType spectypes.MsgType, decided bool)

func (*MetricsReporter) IncomingQueueMessage 

func (m *MetricsReporter) IncomingQueueMessage(messageID spectypes.MessageID)

func (*MetricsReporter) LastBlockProcessed 

func (m *MetricsReporter) LastBlockProcessed(uint64)

TODO implement

func (*MetricsReporter) LogsProcessingError 

func (m *MetricsReporter) LogsProcessingError(error)

func (*MetricsReporter) MessageAccepted 

func (m *MetricsReporter) MessageAccepted(
	role spectypes.BeaconRole,
	round specqbft.Round,
)

func (*MetricsReporter) MessageIgnored 

func (m *MetricsReporter) MessageIgnored(
	reason string,
	role spectypes.BeaconRole,
	round specqbft.Round,
)

func (*MetricsReporter) MessageQueueCapacity 

func (m *MetricsReporter) MessageQueueCapacity(size int)

func (*MetricsReporter) MessageQueueSize 

func (m *MetricsReporter) MessageQueueSize(size int)

func (*MetricsReporter) MessageRejected 

func (m *MetricsReporter) MessageRejected(
	reason string,
	role spectypes.BeaconRole,
	round specqbft.Round,
)

func (*MetricsReporter) MessageSize 

func (m *MetricsReporter) MessageSize(size int)

func (*MetricsReporter) MessageTimeInQueue 

func (m *MetricsReporter) MessageTimeInQueue(messageID spectypes.MessageID, d time.Duration)

func (*MetricsReporter) MessageValidationDuration 

func (m *MetricsReporter) MessageValidationDuration(duration time.Duration, labels ...string)

func (*MetricsReporter) NonCommitteeMessage 

func (m *MetricsReporter) NonCommitteeMessage(msgType spectypes.MsgType, decided bool)

func (*MetricsReporter) OperatorPublicKey 

func (m *MetricsReporter) OperatorPublicKey(operatorID spectypes.OperatorID, publicKey []byte)

func (*MetricsReporter) OutgoingQueueMessage 

func (m *MetricsReporter) OutgoingQueueMessage(messageID spectypes.MessageID)

func (*MetricsReporter) SSVMessageType 

func (m *MetricsReporter) SSVMessageType(msgType spectypes.MsgType)

func (*MetricsReporter) SSVNodeHealthy 

func (m *MetricsReporter) SSVNodeHealthy()

func (*MetricsReporter) SSVNodeNotHealthy 

func (m *MetricsReporter) SSVNodeNotHealthy()

func (*MetricsReporter) SignatureValidationDuration 

func (m *MetricsReporter) SignatureValidationDuration(duration time.Duration, labels ...string)

func (*MetricsReporter) ValidatorError 

func (m *MetricsReporter) ValidatorError(publicKey []byte)

func (*MetricsReporter) ValidatorExiting 

func (m *MetricsReporter) ValidatorExiting(publicKey []byte)

func (*MetricsReporter) ValidatorInactive 

func (m *MetricsReporter) ValidatorInactive(publicKey []byte)

func (*MetricsReporter) ValidatorNoIndex 

func (m *MetricsReporter) ValidatorNoIndex(publicKey []byte)

func (*MetricsReporter) ValidatorNotActivated 

func (m *MetricsReporter) ValidatorNotActivated(publicKey []byte)

func (*MetricsReporter) ValidatorNotFound 

func (m *MetricsReporter) ValidatorNotFound(publicKey []byte)

func (*MetricsReporter) ValidatorPending 

func (m *MetricsReporter) ValidatorPending(publicKey []byte)

func (*MetricsReporter) ValidatorReady 

func (m *MetricsReporter) ValidatorReady(publicKey []byte)

func (*MetricsReporter) ValidatorRemoved 

func (m *MetricsReporter) ValidatorRemoved(publicKey []byte)

func (*MetricsReporter) ValidatorSlashed 

func (m *MetricsReporter) ValidatorSlashed(publicKey []byte)

func (*MetricsReporter) ValidatorUnknown 

func (m *MetricsReporter) ValidatorUnknown(publicKey []byte)

type Option 

type Option func(reporter *MetricsReporter)

Option defines EventSyncer configuration option.

func WithLogger 

func WithLogger(logger *zap.Logger) Option

WithLogger enables logging.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.