Documentation
¶
Index ¶
- Constants
- func AddBackfillCrawlerTask(ctx context.Context, sugar *zap.Logger, client *ethclient.Client, db *sql.DB, ...) error
- func CrawlSupportedChains(ctx context.Context, logger *zap.Logger, db *sql.DB, rdb *redis.Client) error
- func FilterEvents(ctx context.Context, sugar *zap.Logger, db *sql.DB, client *ethclient.Client, ...) error
- func InitBackfillProcessor(ctx context.Context, logger *zap.Logger, db *sql.DB, rdb *redis.Client, ...) error
- func NewBackfillCollectionTask(bf *models.GetCrawlingBackfillCrawlerRow) (*asynq.Task, error)
- func ProcessCrawlingBackfillCollection(ctx context.Context, sugar *zap.Logger, db *sql.DB, queueClient *asynq.Client) error
- func ProcessLatestBlocks(ctx context.Context, sugar *zap.Logger, client *ethclient.Client, db *sql.DB, ...) error
- func ProcessNewChainAssets(ctx context.Context, logger *zap.Logger, rdb *redis.Client) error
- func ProcessNewChains(ctx context.Context, logger *zap.Logger, rdb *redis.Client, db *sql.DB) error
- func StartChainCrawler(ctx context.Context, sugar *zap.Logger, client *ethclient.Client, db *sql.DB, ...)
- func StartWorker(db *sql.DB, rdb *redis.Client, queueClient *asynq.Client, config server.Config)
- type BackfillProcessor
Constants ¶
View Source
const ( AssetTypeERC20 = "ERC20" AssetTypeERC721 = "ERC721" AssetTypeERC1155 = "ERC1155" )
View Source
const (
BackfillCollection = "backfill_collection"
)
---------------------------------------------- Task ----------------------------------------------
Variables ¶
This section is empty.
Functions ¶
func AddBackfillCrawlerTask ¶
func CrawlSupportedChains ¶
func FilterEvents ¶
func InitBackfillProcessor ¶
func NewBackfillCollectionTask ¶
func NewBackfillCollectionTask(bf *models.GetCrawlingBackfillCrawlerRow) (*asynq.Task, error)
func ProcessLatestBlocks ¶
func ProcessNewChainAssets ¶
func ProcessNewChains ¶
func StartChainCrawler ¶
Types ¶
type BackfillProcessor ¶
type BackfillProcessor struct {
// contains filtered or unexported fields
}
BackfillProcessor implements asynq.Handler interface.
func NewBackfillProcessor ¶
func (*BackfillProcessor) ProcessTask ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.