Directories
¶
| Path | Synopsis |
|---|---|
|
internal
|
|
|
ipldstore
Package ipldstore provides a small KV-store adapter that round-trips cborgen-marshalable values to a SimpleStore.
|
Package ipldstore provides a small KV-store adapter that round-trips cborgen-marshalable values to a SimpleStore. |
|
jobqueue/internal/testing
Package testing provides test utilities for the jobqueue package.
|
Package testing provides test utilities for the jobqueue package. |
|
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. |
|
pkg
|
|
|
curiopdp
Package curiopdp adapts Piri's storage to the storage interfaces that Curio's tasks/pdpv0 pipeline depends on, so Piri can run the shared prove / proving-period tasks over its own S3 blobstore.
|
Package curiopdp adapts Piri's storage to the storage interfaces that Curio's tasks/pdpv0 pipeline depends on, so Piri can run the shared prove / proving-period tasks over its own S3 blobstore. |
|
curiopdp/schema
Package schema holds Piri's curated PDP closure schema (pdp_* plus the harmonytask / eth-message / parked-piece closure — NOT Curio's full migration set) and builds harmonydb handles that apply it.
|
Package schema holds Piri's curated PDP closure schema (pdp_* plus the harmonytask / eth-message / parked-piece closure — NOT Curio's full migration set) and builds harmonydb handles that apply it. |
|
internal/revision
Package revision provides the vsc revision, embedded by the compiler, as a global variable.
|
Package revision provides the vsc revision, embedded by the compiler, as a global variable. |
|
internal/testutil/pdpfake
Package pdpfake provides in-memory fakes of the PDP storage backend for tests.
|
Package pdpfake provides in-memory fakes of the PDP storage backend for tests. |
|
pdp/aggregation/aggregator/policy
Package policy binds the aggregation threshold to the dynamic config registry, so an operator can retune it at runtime without a restart.
|
Package policy binds the aggregation threshold to the dynamic config registry, so an operator can retune it at runtime without a restart. |
|
pdp/aggregation/commp
Package commp defines the aggregation pipeline's ingress seam.
|
Package commp defines the aggregation pipeline's ingress seam. |
|
pdp/aggregation/types/gen
command
|
|
|
pdp/piecesize
Package piecesize is the single source of truth for how large a piece Piri will accept, and for converting between the two units the question is asked in.
|
Package piecesize is the single source of truth for how large a piece Piri will accept, and for converting between the two units the question is asked in. |
|
pdp/piecesize/policy
Package policy binds the piece-size limits to the dynamic config registry, so an operator can retune them at runtime via `piri client admin config set` or PATCH /admin/config without restarting the node.
|
Package policy binds the piece-size limits to the dynamic config registry, so an operator can retune them at runtime via `piri client admin config set` or PATCH /admin/config without restarting the node. |
|
pdp/pipeline
Package pipeline implements Piri's aggregation pipeline as harmonytask tasks on Curio's harmonydb: commP calculation (PDPCommP), aggregate folding (PDPAggregate), batched on-chain root submission (PDPAddRoots), and the asynchronous blob-removal sweep (PDPRemoveSweep).
|
Package pipeline implements Piri's aggregation pipeline as harmonytask tasks on Curio's harmonydb: commP calculation (PDPCommP), aggregate folding (PDPAggregate), batched on-chain root submission (PDPAddRoots), and the asynchronous blob-removal sweep (PDPRemoveSweep). |
|
pdp/tasks
Package tasks retains the eth-client interface contracts and constants used by the PDP service.
|
Package tasks retains the eth-client interface contracts and constants used by the PDP service. |
|
store/objectstore/flatfs
Package flatfs is a Datastore implementation that stores all objects in a two-level directory structure in the local file system, regardless of the hierarchy of the keys.
|
Package flatfs is a Datastore implementation that stores all objects in a two-level directory structure in the local file system, regardless of the hierarchy of the keys. |
|
ucanhandlers/ucanfxtest/base
Package base provides testify/suite scaffolding for end-to-end integration tests of piri's UCAN HTTP surface (both the body-CAR RPC server and the header-container retrieval server).
|
Package base provides testify/suite scaffolding for end-to-end integration tests of piri's UCAN HTTP surface (both the body-CAR RPC server and the header-container retrieval server). |
Click to show internal directories.
Click to hide internal directories.