report

Documentation

Index

• type AppSyncPublisherErrors
• type AppSyncPublisherReport
• type AppSyncPublisherState
• type BlockDownloaderErrors
• type BlockDownloaderReport
• type BlockDownloaderState
• type BlockMonitorErrors
• type BlockMonitorReport
• type BlockMonitorState
• type BundlerErrors
• type BundlerReport
• type BundlerState
• type CheckerErrors
• type CheckerReport
• type CheckerState
• type ContractorErrors
• type ContractorReport
• type ContractorState
• type ForwarderErrors
• type ForwarderReport
• type ForwarderState
• type NetworkInfoErrors
• type NetworkInfoReport
• type NetworkInfoState
• type PeerErrors
• type PeerReport
• type PeerState
• type RedisPublisherErrors
• type RedisPublisherReport
• type RedisPublisherState
• type Report
• type RunErrors
• type RunReport
• type RunState
• type SyncerErrors
• type SyncerReport
• type SyncerState
• type TransactionDownloaderErrors
• type TransactionDownloaderReport
• type TransactionDownloaderState

Types

type AppSyncPublisherErrors

type AppSyncPublisherErrors struct {
	Publish           atomic.Uint64 `json:"publish"`
	PersistentFailure atomic.Uint64 `json:"persistent"`
}

type AppSyncPublisherReport

type AppSyncPublisherReport struct {
	State  AppSyncPublisherState  `json:"state"`
	Errors AppSyncPublisherErrors `json:"errors"`
}

type AppSyncPublisherState

type AppSyncPublisherState struct {
	MessagesPublished atomic.Uint64 `json:"messages_published"`
}

type BlockDownloaderErrors

type BlockDownloaderErrors struct {
	BlockDownloadErrors   atomic.Int64 `json:"block_download"`
	BlockValidationErrors atomic.Int64 `json:"block_validation"`
}

type BlockDownloaderReport

type BlockDownloaderReport struct {
	State  BlockDownloaderState  `json:"state"`
	Errors BlockDownloaderErrors `json:"errors"`
}

type BlockDownloaderState

type BlockDownloaderState struct {
	CurrentHeight                   atomic.Int64   `json:"syncer_current_height"`
	BlocksBehind                    atomic.Int64   `json:"syncer_blocks_behind"`
	AverageBlocksProcessedPerMinute atomic.Float64 `json:"average_blocks_processed_per_minute"`
}

type BlockMonitorErrors

type BlockMonitorErrors struct {
	BlockDownloadErrors   atomic.Int64 `json:"block_download"`
	BlockValidationErrors atomic.Int64 `json:"block_validation"`
	TxDownloadErrors      atomic.Int64 `json:"tx_download"`
}

FIMXE: Remove this file

type BlockMonitorReport

type BlockMonitorReport struct {
	State  BlockMonitorState  `json:"state"`
	Errors BlockMonitorErrors `json:"errors"`
}

type BlockMonitorState

type BlockMonitorState struct {
	SyncerCurrentHeight    atomic.Int64  `json:"syncer_current_height"`
	TransactionsDownloaded atomic.Uint64 `json:"transactions_downloaded"`
	SyncerBlocksBehind     atomic.Int64  `json:"syncer_blocks_behind"`

	AverageBlocksProcessedPerMinute       atomic.Float64 `json:"average_blocks_processed_per_minute"`
	AverageTransactionDownloadedPerMinute atomic.Float64 `json:"average_transactions_downloaded_per_minute"`
}

type BundlerErrors

type BundlerErrors struct {
	BundrlError                 atomic.Uint64 `json:"bundrl_error"`
	BundrlMarshalError          atomic.Uint64 `json:"bundrl_marshal_error"`
	ConfirmationsSavedToDbError atomic.Uint64 `json:"confirmations_saved_to_db_error"`
	AdditionalFetchError        atomic.Uint64 `json:"additional_fetch_error"`
	PollerFetchError            atomic.Uint64 `json:"poller_fetch_error"`
}

type BundlerReport

type BundlerReport struct {
	State  BundlerState  `json:"state"`
	Errors BundlerErrors `json:"errors"`
}

type BundlerState

type BundlerState struct {
	// Transactions that are pending, waiting to be bundled in the database
	PendingBundleItems atomic.Int64 `json:"pending_bundle_items"`

	// Counting bundles that come from the database
	BundlesFromNotifications  atomic.Uint64 `json:"bundles_from_notifications"`
	AdditionalFetches         atomic.Uint64 `json:"additional_fetches"`
	BundlesFromSelects        atomic.Uint64 `json:"bundles_from_selects"`
	RetriedBundlesFromSelects atomic.Uint64 `json:"retried_bundles_from_selects"`
	AllBundlesFromDb          atomic.Uint64 `json:"all_bundles_from_db"`

	// Counting bundles sent to bundlr.network
	BundlrSuccess atomic.Uint64 `json:"bundlr_success"`

	// Counting properly saved confirmations that bundle is sent
	ConfirmationsSavedToDb atomic.Uint64 `json:"confirmations_saved_to_db"`
}

type CheckerErrors

type CheckerErrors struct {
	BundrlGetStatusError atomic.Uint64 `json:"bundle_check_state_error"`
	DbStateUpdateError   atomic.Uint64 `json:"db_state_update_error"`
}

type CheckerReport

type CheckerReport struct {
	State  CheckerState  `json:"state"`
	Errors CheckerErrors `json:"errors"`
}

type CheckerState

type CheckerState struct {
	BundlesTakenFromDb atomic.Uint64 `json:"bundles_taken_from_db"`
	AllCheckedBundles  atomic.Uint64 `json:"all_checked_bundles"`
	FinishedBundles    atomic.Uint64 `json:"finished_bundles"`
	UnfinishedBundles  atomic.Uint64 `json:"unfinished_bundles"`
	DbStateUpdated     atomic.Uint64 `json:"db_state_updated"`
}

type ContractorErrors

type ContractorErrors struct {
	DbContractInsert             atomic.Uint64 `json:"db_contract_interaction"`
	DbSourceInsert               atomic.Uint64 `json:"db_source_interaction"`
	DbLastTransactionBlockHeight atomic.Uint64 `json:"db_last_tx_block_height"`
	LoadPersistentContract       atomic.Uint64 `json:"load_persistent_contract"`
	LoadContract                 atomic.Uint64 `json:"load_contract"`
	LoadSource                   atomic.Uint64 `json:"load_source"`
	LoadInitState                atomic.Uint64 `json:"load_init_state"`
}

type ContractorReport

type ContractorReport struct {
	State  ContractorState  `json:"state"`
	Errors ContractorErrors `json:"errors"`
}

type ContractorState

type ContractorState struct {
	FinishedHeight atomic.Uint64 `json:"finished_height"`

	AverageContractsSavedPerMinute atomic.Float64 `json:"average_contracts_saved_per_minute"`
	ContractsSaved                 atomic.Uint64  `json:"contracts_saved"`
}

type ForwarderErrors

type ForwarderErrors struct {
}

type ForwarderReport

type ForwarderReport struct {
	State  ForwarderState  `json:"state"`
	Errors ForwarderErrors `json:"errors"`
}

type ForwarderState

type ForwarderState struct {
	CurrentHeight           atomic.Uint64 `json:"current_height"`
	FinishedHeight          atomic.Uint64 `json:"finished_height"`
	L1InteractionsPublished atomic.Uint64 `json:"l1_interactions_published"`
	L2InteractionsPublished atomic.Uint64 `json:"l2_interactions_published"`
	L1BroadcastSeconds      atomic.Uint64 `json:"l1_broadcast_seconds"`
	L2BroadcastSeconds      atomic.Uint64 `json:"l2_broadcast_seconds"`
}

type NetworkInfoErrors

type NetworkInfoErrors struct {
	NetworkInfoDownloadErrors atomic.Uint64 `json:"network_info_download"`
}

type NetworkInfoReport

type NetworkInfoReport struct {
	State  NetworkInfoState  `json:"state"`
	Errors NetworkInfoErrors `json:"errors"`
}

type NetworkInfoState

type NetworkInfoState struct {
	ArweaveCurrentHeight            atomic.Uint64 `json:"arweave_current_height"`
	ArweaveLastNetworkInfoTimestamp atomic.Uint64 `json:"arweave_last_network_info_timestamp"`
}

type PeerErrors

type PeerErrors struct {
	PeerDownloadErrors atomic.Uint64 `json:"peer_download"`
}

type PeerReport

type PeerReport struct {
	State  PeerState  `json:"state"`
	Errors PeerErrors `json:"errors"`
}

type PeerState

type PeerState struct {
	PeersBlacklisted atomic.Uint64 `json:"peers_blacklisted"`
	NumPeers         atomic.Uint64 `json:"num_peers"`
}

type RedisPublisherErrors

type RedisPublisherErrors struct {
	Publish           atomic.Uint64 `json:"publish"`
	PersistentFailure atomic.Uint64 `json:"persistent"`
}

type RedisPublisherReport

type RedisPublisherReport struct {
	State  RedisPublisherState  `json:"state"`
	Errors RedisPublisherErrors `json:"errors"`
}

type RedisPublisherState

type RedisPublisherState struct {
	MessagesPublished atomic.Uint64 `json:"messages_published"`
}

type Report

type Report struct {
	Run                   *RunReport                   `json:"run,omitempty"`
	Peer                  *PeerReport                  `json:"peer,omitempty"`
	Syncer                *SyncerReport                `json:"syncer,omitempty"`
	Contractor            *ContractorReport            `json:"contractor,omitempty"`
	Bundler               *BundlerReport               `json:"bundler,omitempty"`
	Checker               *CheckerReport               `json:"checker,omitempty"`
	Forwarder             *ForwarderReport             `json:"forwarder,omitempty"`
	NetworkInfo           *NetworkInfoReport           `json:"network_info,omitempty"`
	BlockMonitor          *BlockMonitorReport          `json:"block_monitor,omitempty"`
	BlockDownloader       *BlockDownloaderReport       `json:"block_downloader,omitempty"`
	TransactionDownloader *TransactionDownloaderReport `json:"transaction_downloader,omitempty"`
	RedisPublisher        *RedisPublisherReport        `json:"redis_publisher,omitempty"`
	AppSyncPublisher      *AppSyncPublisherReport      `json:"appsync_publisher,omitempty"`
}

type RunErrors

type RunErrors struct {
	NumWatchdogRestarts atomic.Uint64 `json:"num_watchdog_restarts"`
}

type RunReport

type RunReport struct {
	State  RunState  `json:"state"`
	Errors RunErrors `json:"errors"`
}

type RunState

type RunState struct {
	StartTimestamp atomic.Int64  `json:"start_timestamp"`
	UpForSeconds   atomic.Uint64 `json:"up_for_seconds"`
}

type SyncerErrors

type SyncerErrors struct {
	DbInteractionInsert               atomic.Int64 `json:"db_interaction"`
	DbLastTransactionBlockHeightError atomic.Int64 `json:"db_last_tx_block_height"`
	TxValidationErrors                atomic.Int64 `json:"tx_validation"`
}

type SyncerReport

type SyncerReport struct {
	State  SyncerState  `json:"state"`
	Errors SyncerErrors `json:"errors"`
}

type SyncerState

type SyncerState struct {
	SyncerFinishedHeight atomic.Int64 `json:"syncer_finished_height"`

	AverageInteractionsSavedPerMinute atomic.Float64 `json:"average_interactions_saved_per_minute"`

	InteractionsSaved        atomic.Uint64 `json:"interactions_saved"`
	FailedInteractionParsing atomic.Uint64 `json:"failed_interaction_parsing"`
}

type TransactionDownloaderErrors

type TransactionDownloaderErrors struct {
	Download                 atomic.Uint64 `json:"download"`
	PermanentDownloadFailure atomic.Uint64 `json:"permanent_download_failure"`
	Validation               atomic.Uint64 `json:"validation"`
}

type TransactionDownloaderReport

type TransactionDownloaderReport struct {
	State  TransactionDownloaderState  `json:"state"`
	Errors TransactionDownloaderErrors `json:"errors"`
}

type TransactionDownloaderState

type TransactionDownloaderState struct {
	TransactionsDownloaded                atomic.Uint64  `json:"transactions_downloaded"`
	AverageTransactionDownloadedPerMinute atomic.Float64 `json:"average_transactions_downloaded_per_minute"`
}