nfttradescrapers

Documentation

Index

• Constants
• type CryptoPunkScraper
  • func NewCryptoPunkScraper(rdb *models.RelDB) *CryptoPunkScraper
  • func (scraper *CryptoPunkScraper) Close() error
  • func (scraper *CryptoPunkScraper) FetchTrades() (trades []dia.NFTTrade, err error)
  • func (scraper *CryptoPunkScraper) GetTotalSupply() (*big.Int, error)
  • func (scraper *CryptoPunkScraper) GetTradeChannel() chan dia.NFTTrade
  • func (scraper *CryptoPunkScraper) UpdateTrades() error
• type NFTTradeScraper
• type SorareScraper
  • func NewSorareScraper(rdb *models.RelDB) *SorareScraper
  • func (scraper *SorareScraper) Close() error
  • func (scraper *SorareScraper) FetchTrades() (trades []dia.NFTTrade, err error)
  • func (scraper *SorareScraper) GetTotalSupply() (*big.Int, error)
  • func (scraper *SorareScraper) GetTradeChannel() chan dia.NFTTrade
  • func (scraper *SorareScraper) UpdateTrades() error
• type TradeScraper

Constants

const (
	CryptoPunkRefreshDelay = time.Second * 60
)

Types

type CryptoPunkScraper

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

func NewCryptoPunkScraper

func NewCryptoPunkScraper(rdb *models.RelDB) *CryptoPunkScraper

func (*CryptoPunkScraper) Close

func (scraper *CryptoPunkScraper) Close() error

Close closes any existing API connections

func (*CryptoPunkScraper) FetchTrades

func (scraper *CryptoPunkScraper) FetchTrades() (trades []dia.NFTTrade, err error)

func (*CryptoPunkScraper) GetTotalSupply

func (scraper *CryptoPunkScraper) GetTotalSupply() (*big.Int, error)

GetTotalSupply returns the total supply of the NFT from on-chain.

func (*CryptoPunkScraper) GetTradeChannel

func (scraper *CryptoPunkScraper) GetTradeChannel() chan dia.NFTTrade

GetDataChannel returns the scrapers data channel.

func (*CryptoPunkScraper) UpdateTrades

func (scraper *CryptoPunkScraper) UpdateTrades() error

type NFTTradeScraper

type NFTTradeScraper interface {
	GetTradeChannel() chan dia.NFTTrade
	FetchTrades() ([]dia.NFTTrade, error)
}

type SorareScraper

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

func NewSorareScraper

func NewSorareScraper(rdb *models.RelDB) *SorareScraper

func (*SorareScraper) Close

func (scraper *SorareScraper) Close() error

Close closes any existing API connections

func (*SorareScraper) FetchTrades

func (scraper *SorareScraper) FetchTrades() (trades []dia.NFTTrade, err error)

func (*SorareScraper) GetTotalSupply

func (scraper *SorareScraper) GetTotalSupply() (*big.Int, error)

GetTotalSupply returns the total supply of the NFT from on-chain.

func (*SorareScraper) GetTradeChannel

func (scraper *SorareScraper) GetTradeChannel() chan dia.NFTTrade

GetDataChannel returns the scrapers data channel.

func (*SorareScraper) UpdateTrades

func (scraper *SorareScraper) UpdateTrades() error

type TradeScraper

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