blockchain

Documentation

Index

• type BlockchainProcessor
  • func NewBlockchainProcessor(cfg *config.Config) *BlockchainProcessor
  • func (p *BlockchainProcessor) CloseClients()
  • func (p *BlockchainProcessor) GetBlockByNumber(ctx context.Context, blockNumber *big.Int) (*types.Block, error)
  • func (p *BlockchainProcessor) ListenNewBlocks(startBlockNumber int) <-chan *types.Block

Types

type BlockchainProcessor

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

func NewBlockchainProcessor

func NewBlockchainProcessor(cfg *config.Config) *BlockchainProcessor

NewBlockchainProcessor initializes BlockchainProcessor with HTTP and WebSocket clients

func (*BlockchainProcessor) CloseClients

func (p *BlockchainProcessor) CloseClients()

CloseClients closes both HTTP and WebSocket clients gracefully

func (*BlockchainProcessor) GetBlockByNumber

func (p *BlockchainProcessor) GetBlockByNumber(ctx context.Context, blockNumber *big.Int) (*types.Block, error)

func (*BlockchainProcessor) ListenNewBlocks

func (p *BlockchainProcessor) ListenNewBlocks(startBlockNumber int) <-chan *types.Block