paths

package

Go to main page

Versions in this module

v1

v1.24.4

Jan 24, 2025

v1.24.3

Jan 7, 2025

Changes in this version

+ var GenerateSingleVanillaProofCalls = stats.Int64(pre + "generate_single_vanilla_proof_calls", ...)

+ var GenerateSingleVanillaProofDuration = stats.Int64(pre + "generate_single_vanilla_proof_duration_seconds", ...)

+ var GenerateSingleVanillaProofErrors = stats.Int64(pre + "generate_single_vanilla_proof_errors", ...)

+ var SlowPoStCheckThreshold = 45 * time.Second

+ func MaxCapacity(st fsutil.FsStat) int64

v1.24.2

Nov 11, 2024

v1.24.1

Oct 22, 2024

v1.24.0

Oct 21, 2024

v1.23.1

Sep 23, 2024

Changes in this version

+ const BatchMetaFile

+ const CommitPhase1OutputFileSupra

+ var SpaceUseKey = spaceUseCtxKey

+ func ParentsForProof(spt abi.RegisteredSealProof) (string, error)

+ func StorageFromFile(path string, def *storiface.StorageConfig) (*storiface.StorageConfig, error)

+ func StorageFromReader(reader io.Reader) (*storiface.StorageConfig, error)

+ func WriteStorageFile(filePath string, config storiface.StorageConfig) error

+ type BatchMeta struct

+ BatchSectors int

+ BlockOffset uint64

+ NumInPipeline int

+ SupraSeal bool

type DBIndex

+ func (dbi *DBIndex) BatchStorageDeclareSectors(ctx context.Context, declarations []SectorDeclaration) error

+ type SectorDeclaration struct

+ FileType storiface.SectorFileType

+ Primary bool

+ SectorID abi.SectorID

+ StorageID storiface.ID

type SectorIndex

+ BatchStorageDeclareSectors func(ctx context.Context, declarations []SectorDeclaration) error

+ type SpaceUseFunc func(ft storiface.SectorFileType, ssize abi.SectorSize) (uint64, error)

type URLs

+ func UrlsFromString(in string) URLs

v1.23.0

Jul 29, 2024

Changes in this version

+ const SnapVproofFile

type Local

+ func (st *Local) ReadSnapVanillaProof(ctx context.Context, sr storiface.SectorRef) ([]byte, error)

type Remote

+ func (r *Remote) ReadMinCacheInto(ctx context.Context, s storiface.SectorRef, ft storiface.SectorFileType, ...) error

+ func (r *Remote) ReadSnapVanillaProof(ctx context.Context, sr storiface.SectorRef) ([]byte, error)

+ type SnapVanillaParams struct

+ Sector storiface.SectorRef

type Store

+ ReadSnapVanillaProof func(ctx context.Context, sr storiface.SectorRef) ([]byte, error)

v1.22.1

Jul 15, 2024

v1.22.0

Jun 12, 2024

Changes in this version

+ const LockTimeOut

+ const MetaFile

+ const MinFreeStoragePercentage

+ const NoMinerFilter

+ const URLSeparator

+ var CopyBuf = 1 << 20

+ var FetchTempSubdir = "fetching"

+ var HeartbeatInterval = 10 * time.Second

+ var LocalReaderTimeout = 5 * time.Second

+ var MaxDiskUsageDuration = time.Second

+ var SkippedHeartbeatThresh = HeartbeatInterval * 5

+ var StatTimeout = 5 * time.Second

+ func DoubleCallWrap(f func()) func()

+ func FetchWithTemp(ctx context.Context, urls []string, dest string, header http.Header) (string, error)

+ func FileTypeFromString(t string) (storiface.SectorFileType, error)

+ func MinerFilter(allowMiners, denyMiners []string, miner abi.ActorID) (bool, string, error)

+ func Move(from, to string) error

+ type BasicLocalStorage struct

+ PathToJSON string

+ func (ls *BasicLocalStorage) DiskUsage(path string) (int64, error)

+ func (ls *BasicLocalStorage) GetStorage() (storiface.StorageConfig, error)

+ func (ls *BasicLocalStorage) SetStorage(f func(*storiface.StorageConfig)) error

+ func (ls *BasicLocalStorage) Stat(path string) (fsutil.FsStat, error)

+ type DBIndex struct

+ func NewDBIndex(al *alerting.Alerting, db *harmonydb.DB) *DBIndex

+ func (dbi *DBIndex) StorageAttach(ctx context.Context, si storiface.StorageInfo, st fsutil.FsStat) error

+ func (dbi *DBIndex) StorageBestAlloc(ctx context.Context, allocate storiface.SectorFileType, ssize abi.SectorSize, ...) ([]storiface.StorageInfo, error)

+ func (dbi *DBIndex) StorageDeclareSector(ctx context.Context, storageID storiface.ID, s abi.SectorID, ...) error

+ func (dbi *DBIndex) StorageDetach(ctx context.Context, id storiface.ID, url string) error

+ func (dbi *DBIndex) StorageDropSector(ctx context.Context, storageID storiface.ID, s abi.SectorID, ...) error

+ func (dbi *DBIndex) StorageFindSector(ctx context.Context, s abi.SectorID, ft storiface.SectorFileType, ...) ([]storiface.SectorStorageInfo, error)

+ func (dbi *DBIndex) StorageGetLocks(ctx context.Context) (storiface.SectorLocks, error)

+ func (dbi *DBIndex) StorageInfo(ctx context.Context, id storiface.ID) (storiface.StorageInfo, error)

+ func (dbi *DBIndex) StorageList(ctx context.Context) (map[storiface.ID][]storiface.Decl, error)

+ func (dbi *DBIndex) StorageLock(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, ...) error

+ func (dbi *DBIndex) StorageReportHealth(ctx context.Context, id storiface.ID, report storiface.HealthReport) error

+ func (dbi *DBIndex) StorageTryLock(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, ...) (bool, error)

+ type DefaultPartialFileHandler struct

+ func (d *DefaultPartialFileHandler) Close(pf *partialfile.PartialFile) error

+ func (d *DefaultPartialFileHandler) HasAllocated(pf *partialfile.PartialFile, offset storiface.UnpaddedByteIndex, ...) (bool, error)

+ func (d *DefaultPartialFileHandler) OpenPartialFile(maxPieceSize abi.PaddedPieceSize, path string) (*partialfile.PartialFile, error)

+ func (d *DefaultPartialFileHandler) Reader(pf *partialfile.PartialFile, offset storiface.PaddedByteIndex, ...) (io.Reader, error)

+ type FetchHandler struct

+ Local Store

+ PfHandler PartialFileHandler

+ func (handler *FetchHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Local struct

+ func NewLocal(ctx context.Context, ls LocalStorage, index SectorIndex, urls []string) (*Local, error)

+ func (st *Local) AcquireSector(ctx context.Context, sid storiface.SectorRef, ...) (storiface.SectorPaths, storiface.SectorPaths, error)

+ func (st *Local) ClosePath(ctx context.Context, id storiface.ID) error

+ func (st *Local) FsStat(ctx context.Context, id storiface.ID) (fsutil.FsStat, error)

+ func (st *Local) GeneratePoRepVanillaProof(ctx context.Context, sr storiface.SectorRef, sealed, unsealed cid.Cid, ...) ([]byte, error)

+ func (st *Local) GenerateSingleVanillaProof(ctx context.Context, minerID abi.ActorID, si storiface.PostSectorChallenge, ...) ([]byte, error)

+ func (st *Local) Local(ctx context.Context) ([]storiface.StoragePath, error)

+ func (st *Local) MoveStorage(ctx context.Context, s storiface.SectorRef, types storiface.SectorFileType, ...) error

+ func (st *Local) OpenPath(ctx context.Context, p string) error

+ func (st *Local) Redeclare(ctx context.Context, filterId *storiface.ID, dropMissingDecls bool) error

+ func (st *Local) Remove(ctx context.Context, sid abi.SectorID, typ storiface.SectorFileType, ...) error

+ func (st *Local) RemoveCopies(ctx context.Context, sid abi.SectorID, typ storiface.SectorFileType) error

+ func (st *Local) Reserve(ctx context.Context, sid storiface.SectorRef, ft storiface.SectorFileType, ...) (func(), error)

+ type LocalStorage interface

+ DiskUsage func(path string) (int64, error)

+ GetStorage func() (storiface.StorageConfig, error)

+ SetStorage func(func(*storiface.StorageConfig)) error

+ Stat func(path string) (fsutil.FsStat, error)

+ type MemIndex struct

+ func NewMemIndex(al *alerting.Alerting) *MemIndex

+ func (i *MemIndex) FindSector(id abi.SectorID, typ storiface.SectorFileType) ([]storiface.ID, error)

+ func (i *MemIndex) StorageAttach(ctx context.Context, si storiface.StorageInfo, st fsutil.FsStat) error

+ func (i *MemIndex) StorageBestAlloc(ctx context.Context, allocate storiface.SectorFileType, ssize abi.SectorSize, ...) ([]storiface.StorageInfo, error)

+ func (i *MemIndex) StorageDeclareSector(ctx context.Context, storageID storiface.ID, s abi.SectorID, ...) error

+ func (i *MemIndex) StorageDetach(ctx context.Context, id storiface.ID, url string) error

+ func (i *MemIndex) StorageDropSector(ctx context.Context, storageID storiface.ID, s abi.SectorID, ...) error

+ func (i *MemIndex) StorageFindSector(ctx context.Context, s abi.SectorID, ft storiface.SectorFileType, ...) ([]storiface.SectorStorageInfo, error)

+ func (i *MemIndex) StorageInfo(ctx context.Context, id storiface.ID) (storiface.StorageInfo, error)

+ func (i *MemIndex) StorageList(ctx context.Context) (map[storiface.ID][]storiface.Decl, error)

+ func (i *MemIndex) StorageReportHealth(ctx context.Context, id storiface.ID, report storiface.HealthReport) error

+ func (i MemIndex) StorageGetLocks(context.Context) (storiface.SectorLocks, error)

+ func (i MemIndex) StorageLock(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, ...) error

+ func (i MemIndex) StorageTryLock(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, ...) (bool, error)

+ type PartialFileHandler interface

+ Close func(pf *partialfile.PartialFile) error

+ HasAllocated func(pf *partialfile.PartialFile, offset storiface.UnpaddedByteIndex, ...) (bool, error)

+ OpenPartialFile func(maxPieceSize abi.PaddedPieceSize, path string) (*partialfile.PartialFile, error)

+ Reader func(pf *partialfile.PartialFile, offset storiface.PaddedByteIndex, ...) (io.Reader, error)

+ type PoRepVanillaParams struct

+ Sealed cid.Cid

+ Sector storiface.SectorRef

+ Seed abi.InteractiveSealRandomness

+ Ticket abi.SealRandomness

+ Unsealed cid.Cid

+ type Remote struct

+ func NewRemote(local Store, index SectorIndex, auth http.Header, fetchLimit int, ...) *Remote

+ func (r *Remote) AcquireSector(ctx context.Context, s storiface.SectorRef, existing storiface.SectorFileType, ...) (storiface.SectorPaths, storiface.SectorPaths, error)

+ func (r *Remote) CheckIsUnsealed(ctx context.Context, s storiface.SectorRef, offset, size abi.PaddedPieceSize) (bool, error)

+ func (r *Remote) FsStat(ctx context.Context, id storiface.ID) (fsutil.FsStat, error)

+ func (r *Remote) GeneratePoRepVanillaProof(ctx context.Context, sr storiface.SectorRef, sealed, unsealed cid.Cid, ...) ([]byte, error)

+ func (r *Remote) GenerateSingleVanillaProof(ctx context.Context, minerID abi.ActorID, sinfo storiface.PostSectorChallenge, ...) ([]byte, error)

+ func (r *Remote) MoveStorage(ctx context.Context, s storiface.SectorRef, types storiface.SectorFileType, ...) error

+ func (r *Remote) Reader(ctx context.Context, s storiface.SectorRef, offset, size abi.PaddedPieceSize) (...)

+ func (r *Remote) ReaderSeq(ctx context.Context, s storiface.SectorRef, ft storiface.SectorFileType) (io.ReadCloser, error)

+ func (r *Remote) Remove(ctx context.Context, sid abi.SectorID, typ storiface.SectorFileType, ...) error

+ func (r *Remote) RemoveCopies(ctx context.Context, s abi.SectorID, typ storiface.SectorFileType) error

+ func (r *Remote) Reserve(ctx context.Context, sid storiface.SectorRef, ft storiface.SectorFileType, ...) (func(), error)

+ func (r *Remote) StatUrl(ctx context.Context, urlStr string, id storiface.ID) (fsutil.FsStat, error)

+ type SectorIndex interface

+ StorageAttach func(context.Context, storiface.StorageInfo, fsutil.FsStat) error

+ StorageBestAlloc func(ctx context.Context, allocate storiface.SectorFileType, ssize abi.SectorSize, ...) ([]storiface.StorageInfo, error)

+ StorageDeclareSector func(ctx context.Context, storageID storiface.ID, s abi.SectorID, ...) error

+ StorageDetach func(ctx context.Context, id storiface.ID, url string) error

+ StorageDropSector func(ctx context.Context, storageID storiface.ID, s abi.SectorID, ...) error

+ StorageFindSector func(ctx context.Context, sector abi.SectorID, ft storiface.SectorFileType, ...) ([]storiface.SectorStorageInfo, error)

+ StorageGetLocks func(ctx context.Context) (storiface.SectorLocks, error)

+ StorageInfo func(context.Context, storiface.ID) (storiface.StorageInfo, error)

+ StorageList func(ctx context.Context) (map[storiface.ID][]storiface.Decl, error)

+ StorageLock func(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, ...) error

+ StorageReportHealth func(context.Context, storiface.ID, storiface.HealthReport) error

+ StorageTryLock func(ctx context.Context, sector abi.SectorID, read storiface.SectorFileType, ...) (bool, error)

+ type SingleVanillaParams struct

+ Miner abi.ActorID

+ ProofType abi.RegisteredPoStProof

+ Sector storiface.PostSectorChallenge

+ type Store interface

+ AcquireSector func(ctx context.Context, s storiface.SectorRef, existing storiface.SectorFileType, ...) (paths storiface.SectorPaths, stores storiface.SectorPaths, err error)

+ FsStat func(ctx context.Context, id storiface.ID) (fsutil.FsStat, error)

+ GeneratePoRepVanillaProof func(ctx context.Context, sr storiface.SectorRef, sealed, unsealed cid.Cid, ...) ([]byte, error)

+ GenerateSingleVanillaProof func(ctx context.Context, minerID abi.ActorID, si storiface.PostSectorChallenge, ...) ([]byte, error)

+ MoveStorage func(ctx context.Context, s storiface.SectorRef, types storiface.SectorFileType, ...) error

+ Remove func(ctx context.Context, s abi.SectorID, types storiface.SectorFileType, ...) error

+ RemoveCopies func(ctx context.Context, s abi.SectorID, types storiface.SectorFileType) error

+ Reserve func(ctx context.Context, sid storiface.SectorRef, ft storiface.SectorFileType, ...) (func(), error)

+ type URLs []string

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