monitor_syncer

type Collector struct {
	ArweaveCurrentHeight                  *prometheus.Desc
	ArweaveLastNetworkInfoTimestamp       *prometheus.Desc
	StartTimestamp                        *prometheus.Desc
	UpForSeconds                          *prometheus.Desc
	SyncerBlocksBehind                    *prometheus.Desc
	SyncerCurrentHeight                   *prometheus.Desc
	SyncerFinishedHeight                  *prometheus.Desc
	AverageBlocksProcessedPerMinute       *prometheus.Desc
	AverageTransactionDownloadedPerMinute *prometheus.Desc
	AverageInteractionsSavedPerMinute     *prometheus.Desc
	PeersBlacklisted                      *prometheus.Desc
	NumPeers                              *prometheus.Desc
	TransactionsDownloaded                *prometheus.Desc
	InteractionsSaved                     *prometheus.Desc
	FailedInteractionParsing              *prometheus.Desc
	NumWatchdogRestarts                   *prometheus.Desc

	DbInteractionInsert               *prometheus.Desc `json:""`
	DbLastTransactionBlockHeightError *prometheus.Desc `json:""`
	TxValidationErrors                *prometheus.Desc `json:""`
	TxDownloadErrors                  *prometheus.Desc `json:""`
	BlockValidationErrors             *prometheus.Desc `json:""`
	BlockDownloadErrors               *prometheus.Desc `json:""`
	PeerDownloadErrors                *prometheus.Desc `json:""`
	NetworkInfoDownloadErrors         *prometheus.Desc `json:""`
	// contains filtered or unexported fields
}

type Monitor struct {
	*task.Task

	Report report.Report

	// Block processing speed
	BlockHeights      *deque.Deque[int64]
	TransactionCounts *deque.Deque[uint64]
	InteractionsSaved *deque.Deque[uint64]
	// contains filtered or unexported fields
}