Versions in this module Expand all Collapse all v1 v1.0.0 Aug 7, 2026 Changes in this version + var ErrAlreadyRunning = errors.New("another PDP tracker worker already running") + var Logger = log.Logger("pdptracker") + type ChainPDPClient struct + func NewPDPClient(ctx context.Context, rpcURL string, contractAddr common.Address) (*ChainPDPClient, error) + func (c *ChainPDPClient) Close() error + func (c *ChainPDPClient) GetActivePieces(ctx context.Context, setID uint64) ([]cid.Cid, error) + func (c *ChainPDPClient) GetDataSetListener(ctx context.Context, setID uint64) (common.Address, error) + type PDPConfig struct + PollingInterval time.Duration + func (c PDPConfig) Validate() error + type PDPIndexer struct + func NewPDPIndexer(ctx context.Context, pgURL string, rpcURL string, chainID uint64, ...) (*PDPIndexer, error) + func (*PDPIndexer) Name() string + func (idx *PDPIndexer) Start(ctx context.Context, exitErr chan<- error) error + type PDPTracker struct + func NewPDPTracker(db *gorm.DB, config PDPConfig, rpcClient *ChainPDPClient, once bool) PDPTracker + func (*PDPTracker) Name() string + func (p *PDPTracker) Start(ctx context.Context, exitErr chan<- error) error v1.0.0-RC1 Jul 13, 2026
Go to main page