nftofferscrapers

Documentation

Index

• Constants
• type CryptoPunksScraper
  • func NewCryptoPunksScraper(rdb *models.RelDB) *CryptoPunksScraper
  • func (scraper *CryptoPunksScraper) Close() error
  • func (scraper *CryptoPunksScraper) FetchOffers() error
  • func (scraper *CryptoPunksScraper) GetOfferChannel() chan dia.NFTOffer
• type CryptokittiesScraper
  • func NewCryptokittiesScraper(rdb *models.RelDB) *CryptokittiesScraper
  • func (scraper *CryptokittiesScraper) Close() error
  • func (scraper *CryptokittiesScraper) FetchOffers() error
  • func (scraper *CryptokittiesScraper) GetOfferChannel() chan dia.NFTOffer
• type NFTOfferScraper
• type OfferScraper

Constants

const (
	CryptoPunksRefreshDelay = time.Minute * 60 * 10
)

const (
	CryptokittiesRefreshDelay = time.Minute * 60 * 10
)

Types

type CryptoPunksScraper

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

func NewCryptoPunksScraper

func NewCryptoPunksScraper(rdb *models.RelDB) *CryptoPunksScraper

func (*CryptoPunksScraper) Close

func (scraper *CryptoPunksScraper) Close() error

Close closes any existing API connections

func (*CryptoPunksScraper) FetchOffers

func (scraper *CryptoPunksScraper) FetchOffers() error

func (*CryptoPunksScraper) GetOfferChannel

func (scraper *CryptoPunksScraper) GetOfferChannel() chan dia.NFTOffer

GetDataChannel returns the scrapers data channel.

type CryptokittiesScraper

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

func NewCryptokittiesScraper

func NewCryptokittiesScraper(rdb *models.RelDB) *CryptokittiesScraper

func (*CryptokittiesScraper) Close

func (scraper *CryptokittiesScraper) Close() error

Close closes any existing API connections

func (*CryptokittiesScraper) FetchOffers

func (scraper *CryptokittiesScraper) FetchOffers() error

func (*CryptokittiesScraper) GetOfferChannel

func (scraper *CryptokittiesScraper) GetOfferChannel() chan dia.NFTOffer

GetDataChannel returns the scrapers data channel.

type NFTOfferScraper

type NFTOfferScraper interface {
	// NFT bids should be streamed through dia.NFTBid channel.
	GetOfferChannel() chan dia.NFTOffer
	// Should fetch bids and send them to the channel.
	FetchOffers() error
}

type OfferScraper

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