pdptracker

package

v1.0.0 Latest Latest Go to latest Published: Aug 7, 2026 License: Apache-2.0, MIT Imports: 24 Imported by: 0

Documentation ¶

Index ¶

Variables
type ChainPDPClient
- func NewPDPClient(ctx context.Context, rpcURL string, contractAddr common.Address) (*ChainPDPClient, error)
type PDPConfig
- func (c PDPConfig) Validate() error
type PDPIndexer
- 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
- 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

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrAlreadyRunning = errors.New("another PDP tracker worker already running")

View Source

var Logger = log.Logger("pdptracker")

Functions ¶

This section is empty.

Types ¶

type ChainPDPClient ¶

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

func NewPDPClient ¶

func NewPDPClient(ctx context.Context, rpcURL string, contractAddr common.Address) (*ChainPDPClient, error)

func (*ChainPDPClient) Close ¶

func (c *ChainPDPClient) Close() error

func (*ChainPDPClient) GetActivePieces ¶

func (c *ChainPDPClient) GetActivePieces(ctx context.Context, setID uint64) ([]cid.Cid, error)

paginates internally

func (*ChainPDPClient) GetDataSetListener ¶

func (c *ChainPDPClient) GetDataSetListener(ctx context.Context, setID uint64) (common.Address, error)

type PDPConfig ¶

type PDPConfig struct {
	PollingInterval time.Duration
}

func (PDPConfig) Validate ¶

func (c PDPConfig) Validate() error

type PDPIndexer ¶

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

func NewPDPIndexer ¶

func NewPDPIndexer(ctx context.Context, pgURL string, rpcURL string, chainID uint64, contractAddr common.Address, fullResync bool) (*PDPIndexer, error)

func (*PDPIndexer) Name ¶

func (*PDPIndexer) Name() string

func (*PDPIndexer) Start ¶

func (idx *PDPIndexer) Start(ctx context.Context, exitErr chan<- error) error

type PDPTracker ¶

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

func NewPDPTracker ¶

func NewPDPTracker(
	db *gorm.DB,
	config PDPConfig,
	rpcClient *ChainPDPClient,
	once bool,
) PDPTracker

func (*PDPTracker) Name ¶

func (*PDPTracker) Name() string

func (*PDPTracker) Start ¶

func (p *PDPTracker) Start(ctx context.Context, exitErr chan<- error) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL