storiface

Jun 25, 2024

Changes in this version

+ type Reader interface

May 28, 2024

Changes in this version

+ type AcquireOption func(*AcquireSettings)

+ func AcquireInto(pathIDs PathsWithIDs) AcquireOption

+ type AcquireSettings struct

+ Into *PathsWithIDs

type LocalStorageMeta

+ AllowMiners []string

+ DenyMiners []string

+ type PathsWithIDs struct

+ IDs SectorPaths

+ Paths SectorPaths

+ func (p PathsWithIDs) HasAllSet(ft SectorFileType) bool

+ type PieceNumber uint64

+ func (pn PieceNumber) Ref() SectorRef

type SectorFileType

+ const FTPiece

+ func (t SectorFileType) IsNone() bool

+ func (t SectorFileType) Unset(toUnset SectorFileType) SectorFileType

type SectorPaths

+ Piece string

+ func (sp SectorPaths) HasAllSet(ft SectorFileType) bool

+ func (sp SectorPaths) Subset(filter SectorFileType) SectorPaths

type SectorStorageInfo

+ AllowMiners []string

+ DenyMiners []string

type StorageInfo

+ AllowMiners []string

+ DenyMiners []string

Nov 22, 2023

Changes in this version

type CallError

+ func (c *CallError) ErrCode() ErrorCode

+ type WorkError interface

+ ErrCode func() ErrorCode

Aug 9, 2023

Changes in this version

type UnpaddedByteIndex

+ func UnpaddedCeil(n uint64) UnpaddedByteIndex

+ func UnpaddedFloor(n uint64) UnpaddedByteIndex

Apr 23, 2023

Changes in this version

type WorkerResources

+ func (wr WorkerResources) PrepResourceSpec(spt abi.RegisteredSealProof, tt, prepTT sealtasks.TaskType) Resources

Dec 13, 2022

Changes in this version

+ type LocalPath struct

+ Path string

+ type LocalStorageMeta struct

+ AllowTo []string

+ AllowTypes []string

+ CanSeal bool

+ CanStore bool

+ DenyTypes []string

+ Groups []string

+ ID ID

+ MaxStorage uint64

+ Weight uint64

+ type StorageConfig struct

+ StoragePaths []LocalPath

Oct 5, 2022

Changes in this version

type Sealer

+ DownloadSectorData func(ctx context.Context, sector SectorRef, finalized bool, ...) error

+ type SecDataHttpHeader struct

+ Key string

+ Value string

+ func (t *SecDataHttpHeader) MarshalCBOR(w io.Writer) error

+ func (t *SecDataHttpHeader) UnmarshalCBOR(r io.Reader) (err error)

+ type SectorLocation struct

+ Headers []SecDataHttpHeader

+ Local bool

+ URL string

+ func (sd *SectorLocation) HttpHeaders() http.Header

+ func (t *SectorLocation) MarshalCBOR(w io.Writer) error

+ func (t *SectorLocation) UnmarshalCBOR(r io.Reader) (err error)

type WorkerCalls

+ DownloadSectorData func(ctx context.Context, sector SectorRef, finalized bool, ...) (CallID, error)

type WorkerReturn

+ ReturnDownloadSector func(ctx context.Context, callID CallID, err *CallError) error

Sep 8, 2022

Changes in this version

+ var FTAll = func() (out SectorFileType) { ... }()

type SectorFileType

+ func TypeFromString(s string) (SectorFileType, error)

+ func (t SectorFileType) AllSet() []SectorFileType

+ func (t SectorFileType) Allowed(allowTypes []string, denyTypes []string) bool

+ func (t SectorFileType) AnyAllowed(allowTypes []string, denyTypes []string) bool

+ func (t SectorFileType) Strings() []string

+ func (t SectorFileType) SubAllowed(allowTypes []string, denyTypes []string) SectorFileType

type SectorStorageInfo

+ AllowTypes []string

+ DenyTypes []string

type StorageInfo

+ AllowTypes []string

+ DenyTypes []string

Aug 3, 2022

Changes in this version

+ const FSOverheadDen

+ const IDSep

+ const RWPrepared

+ const RWRetDone

+ const RWRetWait

+ const RWReturned

+ const RWRunning

+ var ErrSectorNotFound = errors.New("sector not found")

+ var FSOverheadSeal = map[SectorFileType]int

+ var FsOverheadFinalized = map[SectorFileType]int

+ var NoSectorRef = SectorRef

+ var ParallelDenom uint64 = 100

+ var ParallelNum uint64 = 92

+ var PathTypes = []SectorFileType

+ var ResourceTable = map[sealtasks.TaskType]map[abi.RegisteredSealProof]Resources

+ func ParseResourceEnv(lookup func(key, def string) (string, bool)) (map[sealtasks.TaskType]map[abi.RegisteredSealProof]Resources, error)

+ 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) (err error)

+ type Commit1Out []byte

+ type Data = io.Reader

+ type Decl struct

+ type ErrorCode int

+ const ErrTempAllocateSpace

+ const ErrTempUnknown

+ const ErrTempWorkerRestart

+ const ErrUnknown

+ type FallbackChallenges struct

+ Challenges map[abi.SectorNumber][]uint64

+ Sectors []abi.SectorNumber

+ type Group = string

+ type HealthReport struct

+ Err string

+ Stat fsutil.FsStat

+ type ID string

+ type IDList []ID

+ func ParseIDList(s string) IDList

+ func (il IDList) String() string

+ type PaddedByteIndex uint64

+ type PathType string

+ const PathSealing

+ const PathStorage

+ type PostSectorChallenge struct

+ Challenge []uint64

+ SealProof abi.RegisteredSealProof

+ SealedCID cid.Cid

+ SectorNumber abi.SectorNumber

+ Update bool

+ type PreCommit1Out []byte

+ type Proof []byte

+ type Prover interface

+ AggregateSealProofs func(aggregateInfo proof.AggregateSealVerifyProofAndInfos, proofs [][]byte) ([]byte, error)

+ type ProverPoSt interface

+ GenerateWindowPoSt func(ctx context.Context, minerID abi.ActorID, ...) (proof []proof.PoStProof, skipped []abi.SectorID, err error)

+ GenerateWindowPoStWithVanilla func(ctx context.Context, proofType abi.RegisteredPoStProof, minerID abi.ActorID, ...) (proof.PoStProof, error)

+ GenerateWinningPoSt func(ctx context.Context, minerID abi.ActorID, ...) ([]proof.PoStProof, error)

+ GenerateWinningPoStWithVanilla func(ctx context.Context, proofType abi.RegisteredPoStProof, minerID abi.ActorID, ...) ([]proof.PoStProof, error)

+ type RGetter func(ctx context.Context, id abi.SectorID) (sealed cid.Cid, update bool, err error)

+ type Range struct

+ Offset abi.UnpaddedPieceSize

+ Size abi.UnpaddedPieceSize

+ type Refs struct

+ RefCount [FileTypes]uint

+ type ReplicaUpdateOut struct

+ NewSealed cid.Cid

+ NewUnsealed cid.Cid

+ type ReplicaUpdateProof []byte

+ type ReplicaVanillaProofs [][]byte

+ type Resources struct

+ BaseMinMemory uint64

+ GPUUtilization float64

+ MaxConcurrent int

+ MaxMemory uint64

+ MaxParallelism int

+ MaxParallelismGPU int

+ MinMemory uint64

+ func (r Resources) Threads(wcpus uint64, gpus int) uint64

+ type Sealer interface

+ AddPiece func(ctx context.Context, sector SectorRef, pieceSizes []abi.UnpaddedPieceSize, ...) (abi.PieceInfo, error)

+ DataCid func(ctx context.Context, pieceSize abi.UnpaddedPieceSize, pieceData Data) (abi.PieceInfo, error)

+ FinalizeReplicaUpdate func(ctx context.Context, sector SectorRef, keepUnsealed []Range) error

+ FinalizeSector func(ctx context.Context, sector SectorRef, keepUnsealed []Range) error

+ GenerateSectorKeyFromData func(ctx context.Context, sector SectorRef, unsealed cid.Cid) error

+ NewSector func(ctx context.Context, sector SectorRef) error

+ ProveReplicaUpdate1 func(ctx context.Context, sector SectorRef, ...) (ReplicaVanillaProofs, error)

+ ProveReplicaUpdate2 func(ctx context.Context, sector SectorRef, ...) (ReplicaUpdateProof, error)

+ ReleaseReplicaUpgrade func(ctx context.Context, sector SectorRef) error

+ ReleaseSectorKey func(ctx context.Context, sector SectorRef) error

+ ReleaseUnsealed func(ctx context.Context, sector SectorRef, safeToFree []Range) error

+ Remove func(ctx context.Context, sector SectorRef) error

+ ReplicaUpdate func(ctx context.Context, sector SectorRef, pieces []abi.PieceInfo) (ReplicaUpdateOut, error)

+ SealCommit1 func(ctx context.Context, sector SectorRef, ticket abi.SealRandomness, ...) (Commit1Out, error)

+ SealCommit2 func(ctx context.Context, sector SectorRef, c1o Commit1Out) (Proof, error)

+ SealPreCommit1 func(ctx context.Context, sector SectorRef, ticket abi.SealRandomness, ...) (PreCommit1Out, error)

+ SealPreCommit2 func(ctx context.Context, sector SectorRef, pc1o PreCommit1Out) (SectorCids, error)

+ type SectorCids struct

+ Sealed cid.Cid

+ Unsealed cid.Cid

+ type SectorFileType int

+ const FTCache

+ const FTNone

+ const FTSealed

+ const FTUnsealed

+ const FTUpdate

+ const FTUpdateCache

+ 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) StoreSpaceUse(ssize abi.SectorSize) (uint64, error)

+ func (t SectorFileType) String() string

+ type SectorLock struct

+ Read [FileTypes]uint

+ Sector abi.SectorID

+ Write [FileTypes]uint

+ type SectorLocks struct

+ Locks []SectorLock

+ type SectorPaths struct

+ Cache string

+ ID abi.SectorID

+ Sealed string

+ Unsealed string

+ Update string

+ UpdateCache string

+ type SectorRef struct

+ ID abi.SectorID

+ ProofType abi.RegisteredSealProof

+ type SectorStorageInfo struct

+ BaseURLs []string

+ CanSeal bool

+ CanStore bool

+ ID ID

+ Primary bool

+ URLs []string

+ Weight uint64

+ type Storage interface

+ type StorageInfo struct

+ AllowTo []Group

+ CanSeal bool

+ CanStore bool

+ Groups []Group

+ ID ID

+ MaxStorage uint64

+ URLs []string

+ Weight uint64

+ type StoragePath struct

+ CanSeal bool

+ CanStore bool

+ ID ID

+ LocalPath string

+ Weight uint64

+ type UnpaddedByteIndex uint64

+ func (i UnpaddedByteIndex) Padded() PaddedByteIndex

+ func (i UnpaddedByteIndex) Valid() error

+ type Unsealer interface

+ ReadPiece func(ctx context.Context, writer io.Writer, sector SectorRef, ...) (bool, error)

+ UnsealPiece func(ctx context.Context, sector SectorRef, offset UnpaddedByteIndex, ...) error

+ type Validator interface

+ CanCommit func(sector SectorPaths) (bool, error)

+ CanProve func(sector SectorPaths) (bool, error)

+ type Verifier interface

+ GenerateWinningPoStSectorChallenge func(context.Context, abi.RegisteredPoStProof, abi.ActorID, abi.PoStRandomness, ...) ([]uint64, error)

+ VerifyAggregateSeals func(aggregate proof.AggregateSealVerifyProofAndInfos) (bool, error)

+ VerifyReplicaUpdate func(update proof.ReplicaUpdateInfo) (bool, error)

+ VerifySeal func(proof.SealVerifyInfo) (bool, error)

+ VerifyWindowPoSt func(ctx context.Context, info proof.WindowPoStVerifyInfo) (bool, error)

+ VerifyWinningPoSt func(ctx context.Context, info proof.WinningPoStVerifyInfo) (bool, error)

+ type WindowPoStResult struct

+ PoStProofs proof.PoStProof

+ Skipped []abi.SectorID

+ type WorkerCalls interface

+ AddPiece func(ctx context.Context, sector SectorRef, pieceSizes []abi.UnpaddedPieceSize, ...) (CallID, error)

+ DataCid func(ctx context.Context, pieceSize abi.UnpaddedPieceSize, pieceData Data) (CallID, error)

+ Fetch func(context.Context, SectorRef, SectorFileType, PathType, AcquireMode) (CallID, error)

+ FinalizeReplicaUpdate func(ctx context.Context, sector SectorRef, keepUnsealed []Range) (CallID, error)

+ FinalizeSector func(ctx context.Context, sector SectorRef, keepUnsealed []Range) (CallID, error)

+ GenerateSectorKeyFromData func(ctx context.Context, sector SectorRef, commD cid.Cid) (CallID, error)

+ GenerateWindowPoSt func(ctx context.Context, ppt abi.RegisteredPoStProof, mid abi.ActorID, ...) (WindowPoStResult, error)

+ GenerateWinningPoSt func(ctx context.Context, ppt abi.RegisteredPoStProof, mid abi.ActorID, ...) ([]proof.PoStProof, error)

+ MoveStorage func(ctx context.Context, sector SectorRef, types SectorFileType) (CallID, error)

+ ProveReplicaUpdate1 func(ctx context.Context, sector SectorRef, ...) (CallID, error)

+ ProveReplicaUpdate2 func(ctx context.Context, sector SectorRef, ...) (CallID, error)

+ ReleaseUnsealed func(ctx context.Context, sector SectorRef, safeToFree []Range) (CallID, error)

+ ReplicaUpdate func(ctx context.Context, sector SectorRef, pieces []abi.PieceInfo) (CallID, error)

+ SealCommit1 func(ctx context.Context, sector SectorRef, ticket abi.SealRandomness, ...) (CallID, error)

+ SealCommit2 func(ctx context.Context, sector SectorRef, c1o Commit1Out) (CallID, error)

+ SealPreCommit1 func(ctx context.Context, sector SectorRef, ticket abi.SealRandomness, ...) (CallID, error)

+ SealPreCommit2 func(ctx context.Context, sector SectorRef, pc1o PreCommit1Out) (CallID, error)

+ UnsealPiece func(context.Context, SectorRef, UnpaddedByteIndex, abi.UnpaddedPieceSize, ...) (CallID, error)

+ type WorkerID uuid.UUID

+ func (w WorkerID) String() string

+ type WorkerInfo struct

+ Hostname string

+ IgnoreResources bool

+ 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

+ MemSwap uint64

+ MemSwapUsed uint64

+ MemUsed uint64

+ Resources map[sealtasks.TaskType]map[abi.RegisteredSealProof]Resources

+ func (wr WorkerResources) ResourceSpec(spt abi.RegisteredSealProof, tt sealtasks.TaskType) Resources

+ type WorkerReturn interface

+ ReturnAddPiece func(ctx context.Context, callID CallID, pi abi.PieceInfo, err *CallError) error

+ ReturnDataCid func(ctx context.Context, callID CallID, pi abi.PieceInfo, err *CallError) error

+ ReturnFetch func(ctx context.Context, callID CallID, err *CallError) error

+ ReturnFinalizeReplicaUpdate func(ctx context.Context, callID CallID, err *CallError) error

+ ReturnFinalizeSector func(ctx context.Context, callID CallID, err *CallError) error

+ ReturnGenerateSectorKeyFromData func(ctx context.Context, callID CallID, err *CallError) error

+ ReturnMoveStorage func(ctx context.Context, callID CallID, err *CallError) error

+ ReturnProveReplicaUpdate1 func(ctx context.Context, callID CallID, proofs ReplicaVanillaProofs, ...) error

+ ReturnProveReplicaUpdate2 func(ctx context.Context, callID CallID, proof ReplicaUpdateProof, 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

+ ReturnReplicaUpdate func(ctx context.Context, callID CallID, out ReplicaUpdateOut, err *CallError) error

+ ReturnSealCommit1 func(ctx context.Context, callID CallID, out Commit1Out, err *CallError) error

+ ReturnSealCommit2 func(ctx context.Context, callID CallID, proof Proof, err *CallError) error

+ ReturnSealPreCommit1 func(ctx context.Context, callID CallID, p1o PreCommit1Out, err *CallError) error

+ ReturnSealPreCommit2 func(ctx context.Context, callID CallID, sealed SectorCids, err *CallError) error

+ ReturnUnsealPiece func(ctx context.Context, callID CallID, err *CallError) error

+ type WorkerStats struct

+ CpuUse uint64

+ Enabled bool

+ GpuUsed float64

+ Info WorkerInfo

+ MemUsedMax uint64

+ MemUsedMin uint64

+ TaskCounts map[string]int

+ Tasks []sealtasks.TaskType