Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BlockTransactionsHandler ¶
type BlockTransactionsHandler[TxIn any] struct { // contains filtered or unexported fields }
func NewBlockTransactionsHandler ¶
func NewBlockTransactionsHandler[TxIn any]( cfg configs.ChainConfig, rpc rpc.Client[TxIn], transactionPub bus.Publisher[entities.Transaction[TxIn]], blockPub bus.Publisher[entities.Block], inflightState state.MapState[entities.BlockHash, bool], metrics BlockTransactionsHandlerMetrics, ) *BlockTransactionsHandler[TxIn]
type BlockTransactionsHandlerMetrics ¶
type BlockTransactionsHandlerMetrics struct {
RequestToNodeCounter metrics.RequestToNodeCounter
}
type BlockchainDigger ¶
type BlockchainDigger[TxIn any] struct { // contains filtered or unexported fields }
func NewBlockchainDigger ¶
func NewBlockchainDigger[TxIn any]( cfg configs.ChainConfig, blockState state.SliceState[entities.BlockHash], inflightState state.MapState[entities.BlockHash, bool], rpcClient rpc.Client[TxIn], workerCh runner.ChanWrite[*entities.Block], metrics BlocksJobMetrics, ) *BlockchainDigger[TxIn]
type BlocksJobMetrics ¶
type BlocksJobMetrics struct {
RequestToNodeCounter metrics.RequestToNodeCounter
}
type BlocksPersister ¶
type BlocksPersister struct {
// contains filtered or unexported fields
}
func NewBlocksPersister ¶
func NewBlocksPersister( cfg configs.ChainConfig, db database.StateDB, state state.SliceState[entities.BlockHash], ) *BlocksPersister
type MempoolDigger ¶
type MempoolDigger[TxIn any] struct { // contains filtered or unexported fields }
func NewMempoolDigger ¶
func NewMempoolDigger[TxIn any]( cfg configs.ChainConfig, rpcClient rpc.Client[TxIn], txIDCh runner.ChanWrite[entities.TxID], oldMempool []entities.TxID, metrics MempoolJobMetrics, ) *MempoolDigger[TxIn]
type MempoolJobMetrics ¶
type MempoolJobMetrics struct {
RequestToNodeCounter metrics.RequestToNodeCounter
}
type TxIDHandler ¶
type TxIDHandler[TxIn any] struct { // contains filtered or unexported fields }
func NewTxIDHandler ¶
func NewTxIDHandler[TxIn any]( cfg configs.ChainConfig, rpcClient rpc.Client[TxIn], publisher bus.Publisher[entities.Transaction[TxIn]], metrics TxIDHandlerMetrics, ) *TxIDHandler[TxIn]
type TxIDHandlerMetrics ¶
type TxIDHandlerMetrics struct {
RequestToNodeCounter metrics.RequestToNodeCounter
}
Source Files
Click to show internal directories.
Click to hide internal directories.