blockscrapers

Documentation

Index

• type BlockScraper
• type BlockScraperInterface
• type EthereumScraper
  • func NewEthereumScraper(rdb *models.RelDB) *EthereumScraper
  • func (scraper *EthereumScraper) Close() error
  • func (scraper *EthereumScraper) FetchData() error
  • func (scraper *EthereumScraper) GetDataChannel() chan dia.BlockData

Types

type BlockScraper

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

type BlockScraperInterface

type BlockScraperInterface interface {
	// NFT data should be streamed through dia.NFT channel.
	GetDataChannel() chan dia.BlockData
	// Should fetch nft data and send it to the channel.
	FetchData() error
}

type EthereumScraper

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

func NewEthereumScraper

func NewEthereumScraper(rdb *models.RelDB) *EthereumScraper

func (*EthereumScraper) Close

func (scraper *EthereumScraper) Close() error

Close closes any existing API connections

func (*EthereumScraper) FetchData

func (scraper *EthereumScraper) FetchData() error

func (*EthereumScraper) GetDataChannel

func (scraper *EthereumScraper) GetDataChannel() chan dia.BlockData