Versions in this module Expand all Collapse all v1 v1.0.0 Aug 15, 2021 Changes in this version + const FSOverheadDen + const RWRetDone + const RWRetWait + const RWReturned + var ErrSectorNotFound = errors.New("sector not found") + var FSOverheadSeal = map[SectorFileType]int + var FsOverheadFinalized = map[SectorFileType]int + var PathTypes = []SectorFileType + func ParseSectorID(baseName string) (abi.SectorID, error) + func PathByType(sps SectorPaths, fileType SectorFileType) string + func SectorName(sid abi.SectorID) string + func SetPathByType(sps *SectorPaths, fileType SectorFileType, p string) + type AcquireMode string + const AcquireCopy + const AcquireMove + type CallError struct + Code ErrorCode + Message string + func Err(code ErrorCode, sub error) *CallError + func (c *CallError) Error() string + func (c *CallError) Unwrap() error + type CallID struct + ID uuid.UUID + Sector abi.SectorID + var UndefCall CallID + func (c CallID) String() string + func (t *CallID) MarshalCBOR(w io.Writer) error + func (t *CallID) UnmarshalCBOR(r io.Reader) error + type ErrorCode int + const ErrTempAllocateSpace + const ErrTempUnknown + const ErrTempWorkerRestart + const ErrUnknown + type PaddedByteIndex uint64 + type PathType string + const PathSealing + const PathStorage + type RGetter func(ctx context.Context, id abi.SectorID) (cid.Cid, error) + type SectorFileType int + const FTCache + const FTNone + const FTSealed + const FTUnsealed + const FileTypes + func (t SectorFileType) All() [FileTypes]bool + func (t SectorFileType) Has(singleType SectorFileType) bool + func (t SectorFileType) SealSpaceUse(ssize abi.SectorSize) (uint64, error) + func (t SectorFileType) String() string + type SectorPaths struct + Cache string + ID abi.SectorID + Sealed string + Unsealed string + type UnpaddedByteIndex uint64 + func (i UnpaddedByteIndex) Padded() PaddedByteIndex + type WorkerCalls interface + AddPiece func(ctx context.Context, sector storage.SectorRef, ...) (CallID, error) + Fetch func(context.Context, storage.SectorRef, SectorFileType, PathType, AcquireMode) (CallID, error) + FinalizeSector func(ctx context.Context, sector storage.SectorRef, keepUnsealed []storage.Range) (CallID, error) + MoveStorage func(ctx context.Context, sector storage.SectorRef, types SectorFileType) (CallID, error) + ReadPiece func(context.Context, io.Writer, storage.SectorRef, UnpaddedByteIndex, ...) (CallID, error) + ReleaseUnsealed func(ctx context.Context, sector storage.SectorRef, safeToFree []storage.Range) (CallID, error) + SealCommit1 func(ctx context.Context, sector storage.SectorRef, ticket abi.SealRandomness, ...) (CallID, error) + SealCommit2 func(ctx context.Context, sector storage.SectorRef, c1o storage.Commit1Out) (CallID, error) + SealPreCommit1 func(ctx context.Context, sector storage.SectorRef, ticket abi.SealRandomness, ...) (CallID, error) + SealPreCommit2 func(ctx context.Context, sector storage.SectorRef, pc1o storage.PreCommit1Out) (CallID, error) + UnsealPiece func(context.Context, storage.SectorRef, UnpaddedByteIndex, abi.UnpaddedPieceSize, ...) (CallID, error) + type WorkerInfo struct + Hostname string + Resources WorkerResources + type WorkerJob struct + Hostname string + ID CallID + RunWait int + Sector abi.SectorID + Start time.Time + Task sealtasks.TaskType + type WorkerResources struct + CPUs uint64 + GPUs []string + MemPhysical uint64 + MemReserved uint64 + MemSwap uint64 + type WorkerReturn interface + ReturnAddPiece func(ctx context.Context, callID CallID, pi abi.PieceInfo, err *CallError) error + ReturnFetch func(ctx context.Context, callID CallID, err *CallError) error + ReturnFinalizeSector func(ctx context.Context, callID CallID, err *CallError) error + ReturnMoveStorage func(ctx context.Context, callID CallID, err *CallError) error + ReturnReadPiece func(ctx context.Context, callID CallID, ok bool, err *CallError) error + ReturnReleaseUnsealed func(ctx context.Context, callID CallID, err *CallError) error + ReturnSealCommit1 func(ctx context.Context, callID CallID, out storage.Commit1Out, err *CallError) error + ReturnSealCommit2 func(ctx context.Context, callID CallID, proof storage.Proof, err *CallError) error + ReturnSealPreCommit1 func(ctx context.Context, callID CallID, p1o storage.PreCommit1Out, err *CallError) error + ReturnSealPreCommit2 func(ctx context.Context, callID CallID, sealed storage.SectorCids, err *CallError) error + ReturnUnsealPiece func(ctx context.Context, callID CallID, err *CallError) error + type WorkerStats struct + CpuUse uint64 + Enabled bool + GpuUsed bool + Info WorkerInfo + MemUsedMax uint64 + MemUsedMin uint64