observer

type AccountBalances map[common.Address]*TokenBalances

type AccountBalancesObserver struct {
	// contains filtered or unexported fields
}

type BaseFeePerGasObserver struct {
	// contains filtered or unexported fields
}

type BlockEventsObserver struct {
	// contains filtered or unexported fields
}

type BlockIntervalObserver struct {
	// contains filtered or unexported fields
}

type BlockObserver struct {
	// contains filtered or unexported fields
}

type BogonBlockObserver struct {
	// contains filtered or unexported fields
}

type BridgeEventNetworks struct {
	OriginNetwork      uint32
	DestinationNetwork uint32
}

type BridgeEventObserver struct {
	// contains filtered or unexported fields
}

type BridgeEventTimes map[BridgeEventNetworks]time.Time

type CheckpointObserver struct {
	// contains filtered or unexported fields
}

type CheckpointSignatures struct {
	Event     *contracts.RootChainNewHeaderBlock
	Block     *types.Block
	Signers   []common.Address
	Seen      bool
	Finalized bool
}

type ClaimEventObserver struct {
	// contains filtered or unexported fields
}

type ClaimEventTimes map[uint32]time.Time

type CoreMessage struct {
	// contains filtered or unexported fields
}

type DatastoreReorg struct {
	Depth      int
	Start      int
	End        int
	StartBlock *datastore.Key
	EndBlock   *datastore.Key
	Time       *time.Time
}

type DepositCountObserver struct {
	// contains filtered or unexported fields
}

type DepositCounts struct {
	DepositCount            *big.Int
	LastUpdatedDepositCount *uint32
}

type DoubleSignObserver struct {
	// contains filtered or unexported fields
}

type EmptyBlockObserver struct {
	// contains filtered or unexported fields
}

type EventBus struct {
	// contains filtered or unexported fields
}

type ExchangeRate struct {
	Base  string
	Quote string
	Rate  float64
}

type ExchangeRatesObserver struct {
	// contains filtered or unexported fields
}

type ExitRoot struct {
	Hash common.Hash
	Time time.Time
	Seen bool
}

type ExitRoots struct {
	GlobalExitRoot  *ExitRoot
	MainnetExitRoot *ExitRoot
	RollupExitRoot  *ExitRoot
}

type ExitRootsObserver struct {
	// contains filtered or unexported fields
}

type FailedProposerInfo struct {
	FailedProposers []string
}

type GasLimitObserver struct {
	// contains filtered or unexported fields
}

type GasUsedObserver struct {
	// contains filtered or unexported fields
}

type HashDivergence struct {
	Blocks      []*types.Block
	BlockNumber uint64
}

type HashDivergenceObserver struct {
	// contains filtered or unexported fields
}

type HeimdallBlock struct {
	Result struct {
		Block struct {
			Header struct {
				Time            string `json:"time"`
				Height          string `json:"height"`
				NumTxs          string `json:"num_txs"`
				TotalTxs        string `json:"total_txs"`
				ProposerAddress string `json:"proposer_address"`
			} `json:"header"`
			LastCommit struct {
				PreCommits []*PreCommit `json:"precommits"`
			} `json:"last_commit"`
		} `json:"block"`
	} `json:"result"`
}

type HeimdallBlockIntervalObserver struct {
	// contains filtered or unexported fields
}

type HeimdallCheckpoint struct {
	Height string `json:"height"`
	Result struct {
		HeimdallCheckpointBuffer
		ID uint64 `json:"id"`
	} `json:"result"`
}

type HeimdallCheckpointBuffer struct {
	Proposer   string `json:"proposer"`
	StartBlock uint64 `json:"start_block"`
	EndBlock   uint64 `json:"end_block"`
	RootHash   string `json:"root_hash"`
	BorChainID string `json:"bor_chain_id"`
	Timestamp  uint64 `json:"timestamp"`
}

type HeimdallCheckpointObserver struct {
	// contains filtered or unexported fields
}

type HeimdallCurrentProposer struct {
	Height string `json:"height"`
	Result struct {
		api.Validator
	} `json:"result"`
}

type HeimdallHeightObserver struct {
	// contains filtered or unexported fields
}

type HeimdallMilestone struct {
	Height string `json:"height"`
	Result struct {
		Proposer    string `json:"proposer"`
		StartBlock  uint64 `json:"start_block"`
		EndBlock    uint64 `json:"end_block"`
		Hash        string `json:"hash"`
		BorChainID  string `json:"bor_chain_id"`
		MilestoneID string `json:"milestone_id"`
		Timestamp   uint64 `json:"timestamp"`
	} `json:"result"`
	Count uint64 `json:"count"`
}

type HeimdallMilestoneCount struct {
	Height string `json:"height"`
	Result struct {
		Count uint64 `json:"count"`
	} `json:"result"`
}

type HeimdallMilestoneProposers struct {
	Height string           `json:"height"`
	Result []*api.Validator `json:"result"`
}

type HeimdallMissedBlockProposal map[uint64]FailedProposerInfo

type HeimdallMissedBlockProposalObserver struct {
	// contains filtered or unexported fields
}

type HeimdallMissedCheckpointProposalObserver struct {
	// contains filtered or unexported fields
}

type HeimdallMissedMilestoneProposal struct {
	// contains filtered or unexported fields
}

type HeimdallSignatureCountObserver struct {
	// contains filtered or unexported fields
}

type HeimdallSpan struct {
	Height string `json:"height"`
	Result struct {
		SpanID     int64 `json:"span_id"`
		StartBlock int64 `json:"start_block"`
		EndBlock   int64 `json:"end_block"`
	} `json:"result"`
}

type HeimdallSpanObserver struct {
	// contains filtered or unexported fields
}

type HeimdallTotalTransactionCountObserver struct {
	// contains filtered or unexported fields
}

type HeimdallTransactionCountObserver struct {
	// contains filtered or unexported fields
}

type HeimdallValidator struct {
	Address          string `json:"address"`
	VotingPower      string `json:"voting_power"`
	ProposerPriority string `json:"proposer_priority"`
}

type HeimdallValidators struct {
	Result struct {
		BlockHeight string               `json:"block_height"`
		Validators  []*HeimdallValidator `json:"validators"`
	} `json:"result"`
}

type Message interface {
	Time() time.Time
	Network() network.Network
	Provider() string
	Data() any
}

type MilestoneObserver struct {
	// contains filtered or unexported fields
}

type MissedBlockProposal map[uint64][]string

type MissedBlockProposalObserver struct {
	// contains filtered or unexported fields
}

type Observer interface {
	// Notify is called when a message is published.
	Notify(context.Context, Message)

	// Register allows the observer to substribe to whatever topics it cares about
	// and setup any metrics.
	Register(*EventBus)

	// GetCollectors will return a slice of the collectors that are
	// being tracked in this observer.
	GetCollectors() []prometheus.Collector
}

type ObserverSet []Observer

type PreCommit struct {
	Type    uint64 `json:"type"`
	Height  string `json:"height"`
	Round   string `json:"round"`
	BlockId struct {
		Hash  string `json:"hash"`
		Parts struct {
			Total uint64 `json:"total"`
			Hash  string `json:"hash"`
		} `json:"parts"`
	} `json:"block_id"`
	Timestamp        string `json:"timestamp"`
	ValidatorAddress string `json:"validator_address"`
	ValidatorIndex   string `json:"validator_index"`
	Signature        string `json:"signature"`
	SideTxResults    []struct {
		TxHash string `json:"tx_hash"`
		Result uint64 `json:"result"`
		Sig    string `json:"sig"`
	} `json:"side_tx_results"`
}

type RefreshStateTimeObserver struct {
	// contains filtered or unexported fields
}

type ReorgObserver struct {
	// contains filtered or unexported fields
}

type RollupData struct {
	LastBatchSequenced          *uint64
	LastSequencedTimestamp      *uint64
	TimeBetweenSequencedBatches []uint64
	SequencedBatchesTxFees      []RollupTx

	LastForceBatch          *uint64
	LastForceBatchSequenced *uint64

	LastVerifiedBatch          *uint64
	LastVerifiedTimestamp      *uint64
	TimeBetweenVerifiedBatches []uint64
	VerifiedBatchesTxFees      []RollupTx

	TrustedSequencerBalances TokenBalances

	ChainID     *uint64
	Pessimistic bool
}

type RollupManager struct {
	TotalSequencedBatches *uint64
	TotalVerifiedBatches  *uint64

	BatchFee       *big.Int
	ForcedBatchFee *big.Int
	RewardPerBatch *big.Int

	AggregatorBalances       map[common.Address]TokenBalances
	LastAggregationTimestamp *uint64

	Rollups         map[uint32]*RollupData
	RollupCount     *uint32
	RollupTypeCount *uint32
}

type RollupManagerObserver struct {
	// contains filtered or unexported fields
}

type RollupTx struct {
	Fee     *big.Int
	Address common.Address
}

type SealedOutOfTurnObserver struct {
	// contains filtered or unexported fields
}

type SensorBlockEvents struct {
	Block  *database.DatastoreBlock
	Events []database.DatastoreEvent
}

type SensorBlocks struct {
	Start  uint64
	End    uint64
	Blocks types.Blocks
}

type SensorBlocksObserver struct {
	// contains filtered or unexported fields
}

type SensorBogonBlockObserver struct {
	// contains filtered or unexported fields
}

type StateSync struct {
	ID        uint64
	Time      time.Time // The time the state sync was first observed
	Finalized bool
}

type StateSyncObserver struct {
	// contains filtered or unexported fields
}

type StolenBlockObserver struct {
	// contains filtered or unexported fields
}

type System struct {
	StartTime    time.Time
	EventBusJobs int
}

type SystemObserver struct {
	// contains filtered or unexported fields
}

type TimeToFinalizedObserver struct {
	// contains filtered or unexported fields
}

type TimeToMine struct {
	Seconds        float64
	GasPrice       *big.Int
	GasPriceFactor int64
}

type TimeToMineObserver struct {
	// contains filtered or unexported fields
}

type TokenBalances struct {
	ETH *big.Int
	POL *big.Int
}

type Topic interface {
	String() string
}

type TransactionCostObserver struct {
	// contains filtered or unexported fields
}

type TransactionCountObserver struct {
	// contains filtered or unexported fields
}

type TransactionGasFeeCapObserver struct {
	// contains filtered or unexported fields
}

type TransactionGasLimitObserver struct {
	// contains filtered or unexported fields
}

type TransactionGasPriceObserver struct {
	// contains filtered or unexported fields
}

type TransactionGasTipCapObserver struct {
	// contains filtered or unexported fields
}

type TransactionPool struct {
	Pending uint64
	Queued  uint64
}

type TransactionPoolObserver struct {
	// contains filtered or unexported fields
}

type TransactionValueObserver struct {
	// contains filtered or unexported fields
}

type TrustedBatchObserver struct {
	// contains filtered or unexported fields
}

type UnclesObserver struct {
	// contains filtered or unexported fields
}

type ValidatorWalletBalanceObserver struct {
	// contains filtered or unexported fields
}

type ValidatorWalletBalances map[string]*big.Int

type ZkEVMBatch struct {
	Number uint64
	Time   time.Time
}

type ZkEVMBatchObserver struct {
	// contains filtered or unexported fields
}

type ZkEVMBatches struct {
	TrustedBatch  ZkEVMBatch
	VirtualBatch  ZkEVMBatch
	VerifiedBatch ZkEVMBatch
}