pdp

package

v0.0.6 Latest Latest Go to latest Published: Jun 18, 2025 License: Apache-2.0, MIT Imports: 30 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/storacha/piri

Links

Open Source Insights

Documentation ¶

Index ¶

type PDP
type PDPService
- func NewRemotePDPService(ds datastore.Datastore, dbPath string, client *curio.Client, proofSet uint64, ...) (*PDPService, error)
type Server
- func NewServer(ctx context.Context, dataDir string, port int, lotusClientAddr string, ...) (*Server, error)
- func (s *Server) Start(ctx context.Context) error
- func (s *Server) Stop(ctx context.Context) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

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 NewRemotePDPService ¶

func NewRemotePDPService(
	ds datastore.Datastore,
	dbPath string,
	client *curio.Client,
	proofSet uint64,
	issuer ucan.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,
	port int,
	lotusClientAddr string,
	ethClientAddr string,
	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
aggregator
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.
api
middleware
curio
ethereum
pieceadder
piecefinder
promise
proof
scheduler Package scheduler implements a session-based task scheduler with the following features:	Package scheduler implements a session-based task scheduler with the following features:
service
contract
contract/internal
contract/mocks Package mocks is a generated GoMock package.	Package mocks is a generated GoMock package.
models
types
store
tasks
testing

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