pdp

package
v0.0.13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 29, 2025 License: Apache-2.0, MIT Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config added in v0.0.13 

type Config struct {
	PDPDatastore datastore.Datastore
	PDPServerURL *url.URL
	ProofSet     uint64
	DatabasePath string
}

type PDP 

type PDP interface {
	PieceAdder() pieceadder.PieceAdder
	PieceFinder() piecefinder.PieceFinder
	Aggregator() aggregator.Aggregator
}

type PDPService 

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

func NewRemote added in v0.0.13 

func NewRemote(cfg *Config, id principal.Signer, receiptStore receiptstore.ReceiptStore) (*PDPService, error)

func (*PDPService) Aggregator 

func (p *PDPService) Aggregator() aggregator.Aggregator

func (*PDPService) PieceAdder 

func (p *PDPService) PieceAdder() pieceadder.PieceAdder

func (*PDPService) PieceFinder 

func (p *PDPService) PieceFinder() piecefinder.PieceFinder

func (*PDPService) Shutdown 

func (p *PDPService) Shutdown(ctx context.Context) error

func (*PDPService) Startup 

func (p *PDPService) Startup(ctx context.Context) error

type Server 

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

func NewServer 

func NewServer(
	ctx context.Context,
	dataDir string,
	endpoint *url.URL,
	lotusEndpoint *url.URL,
	address common.Address,
	wlt *wallet.LocalWallet,
) (*Server, error)

func (*Server) Start 

func (s *Server) Start(ctx context.Context) error

func (*Server) Stop 

func (s *Server) Stop(ctx context.Context) error

Source Files

View all Source files

Directories

Path Synopsis
aggregate
fns
jobqueue
jobqueue/internal/sql
jobqueue/internal/testing
jobqueue/queue
jobqueue/serializer
jobqueue/worker
Package jobqueue provides a Worker which can run registered job [Func]s by name, when a message for it is received on the underlying queue.
 Package jobqueue provides a Worker which can run registered job [Func]s by name, when a message for it is received on the underlying queue.
client
server
server/middleware
Package scheduler implements a session-based task scheduler with the following features:
 Package scheduler implements a session-based task scheduler with the following features:
contract
contract/internal
contract/mocks
Package mocks is a generated GoMock package.
 Package mocks is a generated GoMock package.
models
types

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.