monitor_contract

type Collector struct {

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

	// Network
	NetworkInfoDownloadErrors       *prometheus.Desc
	ArweaveCurrentHeight            *prometheus.Desc
	ArweaveLastNetworkInfoTimestamp *prometheus.Desc

	// Blocks
	BlocksBehind                    *prometheus.Desc
	BlockCurrentHeight              *prometheus.Desc
	AverageBlocksProcessedPerMinute *prometheus.Desc

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

	// BlockDownloader
	BlockValidationErrors *prometheus.Desc
	BlockDownloadErrors   *prometheus.Desc
	PeerDownloadErrors    *prometheus.Desc

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

	// Contractor
	DbContractInsertError             *prometheus.Desc
	DbSourceError                     *prometheus.Desc
	DbLastTransactionBlockHeightError *prometheus.Desc
	LoadPersistentContractError       *prometheus.Desc
	LoadContractError                 *prometheus.Desc
	LoadSourceError                   *prometheus.Desc
	LoadInitStateError                *prometheus.Desc
	FinishedHeight                    *prometheus.Desc
	AverageContractsSavedPerMinute    *prometheus.Desc
	ContractsSaved                    *prometheus.Desc

	// Redis publisher
	RedisPublishErrors     []*prometheus.Desc
	RedisPersistentErrors  []*prometheus.Desc
	RedisMessagesPublished []*prometheus.Desc
	RedisPoolHits          []*prometheus.Desc
	RedisPoolIdleConns     []*prometheus.Desc
	RedisPoolMisses        []*prometheus.Desc
	RedisPoolStaleConns    []*prometheus.Desc
	RedisPoolTimeouts      []*prometheus.Desc
	RedisPoolTotalConns    []*prometheus.Desc

	// App sync publisher
	AppSyncPublishErrors     *prometheus.Desc
	AppSyncPersistentErrors  *prometheus.Desc
	AppSyncMessagesPublished *prometheus.Desc
	// contains filtered or unexported fields
}

type Monitor struct {
	*task.Task

	Report report.Report

	// Block processing speed
	BlockHeights      *deque.Deque[int64]
	TransactionCounts *deque.Deque[uint64]
	ContractsSaved    *deque.Deque[uint64]

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