monitor_relayer

type Collector struct {

	// Run
	UpForSeconds        *prometheus.Desc
	NumWatchdogRestarts *prometheus.Desc

	// Network
	NetworkInfoDownloadErrors *prometheus.Desc

	// BlockDownloader
	BlockDownloadErrors             *prometheus.Desc
	BlockValidationErrors           *prometheus.Desc
	BlockCurrentHeight              *prometheus.Desc
	BlocksBehind                    *prometheus.Desc
	AverageBlocksProcessedPerMinute *prometheus.Desc

	// TransactionDownloader
	TransactionsDownloaded                *prometheus.Desc
	AverageTransactionDownloadedPerMinute *prometheus.Desc
	TxPermanentDownloadErrors             *prometheus.Desc
	TxValidationErrors                    *prometheus.Desc
	TxDownloadErrors                      *prometheus.Desc

	// PeerMonitor
	PeersBlacklisted   *prometheus.Desc
	NumPeers           *prometheus.Desc
	PeerDownloadErrors *prometheus.Desc

	// Relayer
	SequencerPermanentParsingError           *prometheus.Desc
	SequencerBlockDownloadError              *prometheus.Desc
	SequencerPermanentBlockDownloadError     *prometheus.Desc
	PersistentSequencerFailedParsing         *prometheus.Desc
	PersistentArweaveFailedParsing           *prometheus.Desc
	DbError                                  *prometheus.Desc
	SequencerBlocksDownloaded                *prometheus.Desc
	SequencerBlocksStreamed                  *prometheus.Desc
	SequencerBlocksCatchedUp                 *prometheus.Desc
	AverageSequencerBlocksProcessedPerMinute *prometheus.Desc
	SequencerTransactionsParsed              *prometheus.Desc
	ArwaeveFinishedHeight                    *prometheus.Desc
	SequencerFinishedHeight                  *prometheus.Desc
	BundleItemsSaved                         *prometheus.Desc
	AverageInteractionsSavedPerMinute        *prometheus.Desc
	L1InteractionsSaved                      *prometheus.Desc
	L2InteractionsSaved                      *prometheus.Desc
	InteractionsSaved                        *prometheus.Desc
	// contains filtered or unexported fields
}

type Monitor struct {
	*task.Task

	Report report.Report

	// Arweave block processing speed
	BlockHeights      *deque.Deque[int64]
	TransactionCounts *deque.Deque[uint64]
	InteractionsSaved *deque.Deque[uint64]

	// Sequencer block processing speed
	SequencerBlockHeights *deque.Deque[uint64]

	// Params
	IsFatalError atomic.Bool
	// contains filtered or unexported fields
}