metricsreporter

Documentation

Index

• type MetricsReporter
  • func New(opts ...Option) MetricsReporter
  • func NewNop() MetricsReporter
• type Option
  • func WithLogger(logger *zap.Logger) Option

Types

type MetricsReporter

type MetricsReporter interface {
	SSVNodeHealthy()
	SSVNodeNotHealthy()
	ExecutionClientReady()
	ExecutionClientSyncing()
	ExecutionClientFailure()
	ExecutionClientLastFetchedBlock(block uint64)
	OperatorPublicKey(operatorID spectypes.OperatorID, publicKey []byte)
	ValidatorInactive(publicKey []byte)
	ValidatorNoIndex(publicKey []byte)
	ValidatorError(publicKey []byte)
	ValidatorReady(publicKey []byte)
	ValidatorNotActivated(publicKey []byte)
	ValidatorExiting(publicKey []byte)
	ValidatorSlashed(publicKey []byte)
	ValidatorNotFound(publicKey []byte)
	ValidatorPending(publicKey []byte)
	ValidatorRemoved(publicKey []byte)
	ValidatorUnknown(publicKey []byte)
	EventProcessed(eventName string)
	EventProcessingFailed(eventName string)
	MessagesReceivedFromPeer(peerId peer.ID)
	MessagesReceivedTotal()
	MessageValidationRSAVerifications()
	LastBlockProcessed(block uint64)
	LogsProcessingError(err error)
	MessageAccepted(role spectypes.BeaconRole, round specqbft.Round)
	MessageIgnored(reason string, role spectypes.BeaconRole, round specqbft.Round)
	MessageRejected(reason string, role spectypes.BeaconRole, round specqbft.Round)
	SSVMessageType(msgType spectypes.MsgType)
	ConsensusMsgType(msgType specqbft.MessageType, signers int)
	MessageValidationDuration(duration time.Duration, labels ...string)
	SignatureValidationDuration(duration time.Duration, labels ...string)
	MessageSize(size int)
	ActiveMsgValidation(topic string)
	ActiveMsgValidationDone(topic string)
	IncomingQueueMessage(messageID spectypes.MessageID)
	OutgoingQueueMessage(messageID spectypes.MessageID)
	DroppedQueueMessage(messageID spectypes.MessageID)
	MessageQueueSize(size int)
	MessageQueueCapacity(size int)
	MessageTimeInQueue(messageID spectypes.MessageID, d time.Duration)
	InCommitteeMessage(msgType spectypes.MsgType, decided bool)
	NonCommitteeMessage(msgType spectypes.MsgType, decided bool)
	PeerScore(peerId peer.ID, score float64)
	PeerP4Score(peerId peer.ID, score float64)
	ResetPeerScores()
	PeerDisconnected(peerId peer.ID)
}

func New

func New(opts ...Option) MetricsReporter

func NewNop

func NewNop() MetricsReporter

type Option

type Option func(reporter *metricsReporter)

Option defines EventSyncer configuration option.

func WithLogger

func WithLogger(logger *zap.Logger) Option

WithLogger enables logging.