Versions in this module Expand all Collapse all v1 v1.0.0 Aug 15, 2021 Changes in this version + var ClosedWorkerID = uuid.UUID + var DefaultSchedPriority = 0 + var ErrNoWorkers = errors.New("no suitable workers found") + var InitWait = 3 * time.Second + var ParallelDenom uint64 = 100 + var ParallelNum uint64 = 92 + var ResourceTable = map[sealtasks.TaskType]map[abi.RegisteredSealProof]Resources + var SchedPriorityKey schedPrioCtxKey + var SchedWindows = 2 + var SelectorTimeout = 5 * time.Second + func WithPriority(ctx context.Context, priority int) context.Context + type Call struct + ID storiface.CallID + Result *ManyBytes + RetType ReturnType + State CallState + func (t *Call) MarshalCBOR(w io.Writer) error + func (t *Call) UnmarshalCBOR(r io.Reader) error + type CallState uint64 + const CallDone + const CallStarted + type ExecutorFunc func() (ffiwrapper.Storage, error) + type FaultTracker interface + CheckProvable func(ctx context.Context, pp abi.RegisteredPoStProof, sectors []storage.SectorRef, ...) (map[abi.SectorID]string, error) + type LocalWorker struct + func NewLocalWorker(wcfg WorkerConfig, store stores.Store, local *stores.Local, ...) *LocalWorker + func (l *LocalWorker) AddPiece(ctx context.Context, sector storage.SectorRef, epcs []abi.UnpaddedPieceSize, ...) (storiface.CallID, error) + func (l *LocalWorker) Close() error + func (l *LocalWorker) Fetch(ctx context.Context, sector storage.SectorRef, ...) (storiface.CallID, error) + func (l *LocalWorker) FinalizeSector(ctx context.Context, sector storage.SectorRef, keepUnsealed []storage.Range) (storiface.CallID, error) + func (l *LocalWorker) Info(context.Context) (storiface.WorkerInfo, error) + func (l *LocalWorker) MoveStorage(ctx context.Context, sector storage.SectorRef, types storiface.SectorFileType) (storiface.CallID, error) + func (l *LocalWorker) NewSector(ctx context.Context, sector storage.SectorRef) error + func (l *LocalWorker) Paths(ctx context.Context) ([]stores.StoragePath, error) + func (l *LocalWorker) ReadPiece(ctx context.Context, writer io.Writer, sector storage.SectorRef, ...) (storiface.CallID, error) + func (l *LocalWorker) ReleaseUnsealed(ctx context.Context, sector storage.SectorRef, safeToFree []storage.Range) (storiface.CallID, error) + func (l *LocalWorker) Remove(ctx context.Context, sector abi.SectorID) error + func (l *LocalWorker) SealCommit1(ctx context.Context, sector storage.SectorRef, ticket abi.SealRandomness, ...) (storiface.CallID, error) + func (l *LocalWorker) SealCommit2(ctx context.Context, sector storage.SectorRef, phase1Out storage.Commit1Out) (storiface.CallID, error) + func (l *LocalWorker) SealPreCommit1(ctx context.Context, sector storage.SectorRef, ticket abi.SealRandomness, ...) (storiface.CallID, error) + func (l *LocalWorker) SealPreCommit2(ctx context.Context, sector storage.SectorRef, phase1Out storage.PreCommit1Out) (storiface.CallID, error) + func (l *LocalWorker) Session(ctx context.Context) (uuid.UUID, error) + func (l *LocalWorker) TaskDisable(ctx context.Context, tt sealtasks.TaskType) error + func (l *LocalWorker) TaskEnable(ctx context.Context, tt sealtasks.TaskType) error + func (l *LocalWorker) TaskTypes(context.Context) (map[sealtasks.TaskType]struct{}, error) + func (l *LocalWorker) UnsealPiece(ctx context.Context, sector storage.SectorRef, ...) (storiface.CallID, error) + func (l *LocalWorker) WaitQuiet() + type Manager struct + func New(ctx context.Context, ls stores.LocalStorage, si stores.SectorIndex, ...) (*Manager, error) + func (m *Manager) Abort(ctx context.Context, call storiface.CallID) error + func (m *Manager) AddLocalStorage(ctx context.Context, path string) error + func (m *Manager) AddPiece(ctx context.Context, sector storage.SectorRef, ...) (abi.PieceInfo, error) + func (m *Manager) AddWorker(ctx context.Context, w Worker) error + func (m *Manager) CheckProvable(ctx context.Context, pp abi.RegisteredPoStProof, sectors []storage.SectorRef, ...) (map[abi.SectorID]string, error) + func (m *Manager) Close(ctx context.Context) error + func (m *Manager) FinalizeSector(ctx context.Context, sector storage.SectorRef, keepUnsealed []storage.Range) error + func (m *Manager) FsStat(ctx context.Context, id stores.ID) (fsutil.FsStat, error) + func (m *Manager) NewSector(ctx context.Context, sector storage.SectorRef) error + func (m *Manager) ReadPiece(ctx context.Context, sink io.Writer, sector storage.SectorRef, ...) error + func (m *Manager) ReleaseUnsealed(ctx context.Context, sector storage.SectorRef, safeToFree []storage.Range) error + func (m *Manager) Remove(ctx context.Context, sector storage.SectorRef) error + func (m *Manager) ReturnAddPiece(ctx context.Context, callID storiface.CallID, pi abi.PieceInfo, ...) error + func (m *Manager) ReturnFetch(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error + func (m *Manager) ReturnFinalizeSector(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error + func (m *Manager) ReturnMoveStorage(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error + func (m *Manager) ReturnReadPiece(ctx context.Context, callID storiface.CallID, ok bool, ...) error + func (m *Manager) ReturnReleaseUnsealed(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error + func (m *Manager) ReturnSealCommit1(ctx context.Context, callID storiface.CallID, out storage.Commit1Out, ...) error + func (m *Manager) ReturnSealCommit2(ctx context.Context, callID storiface.CallID, proof storage.Proof, ...) error + func (m *Manager) ReturnSealPreCommit1(ctx context.Context, callID storiface.CallID, p1o storage.PreCommit1Out, ...) error + func (m *Manager) ReturnSealPreCommit2(ctx context.Context, callID storiface.CallID, sealed storage.SectorCids, ...) error + func (m *Manager) ReturnUnsealPiece(ctx context.Context, callID storiface.CallID, err *storiface.CallError) error + func (m *Manager) SchedDiag(ctx context.Context, doSched bool) (interface{}, error) + func (m *Manager) SealCommit1(ctx context.Context, sector storage.SectorRef, ticket abi.SealRandomness, ...) (out storage.Commit1Out, err error) + func (m *Manager) SealCommit2(ctx context.Context, sector storage.SectorRef, phase1Out storage.Commit1Out) (out storage.Proof, err error) + func (m *Manager) SealPreCommit1(ctx context.Context, sector storage.SectorRef, ticket abi.SealRandomness, ...) (out storage.PreCommit1Out, err error) + func (m *Manager) SealPreCommit2(ctx context.Context, sector storage.SectorRef, phase1Out storage.PreCommit1Out) (out storage.SectorCids, err error) + func (m *Manager) ServeHTTP(w http.ResponseWriter, r *http.Request) + func (m *Manager) StorageLocal(ctx context.Context) (map[stores.ID]string, error) + func (m *Manager) WorkerJobs() map[uuid.UUID][]storiface.WorkerJob + func (m *Manager) WorkerStats() map[uuid.UUID]storiface.WorkerStats + type ManagerStateStore *statestore.StateStore + type ManyBytes struct + func (t *ManyBytes) MarshalCBOR(w io.Writer) error + func (t *ManyBytes) UnmarshalCBOR(r io.Reader) error + type Resources struct + BaseMinMemory uint64 + CanGPU bool + MaxMemory uint64 + MaxParallelism int + MinMemory uint64 + func (r Resources) Threads(wcpus uint64) uint64 + type ReturnType string + const AddPiece + const Fetch + const FinalizeSector + const MoveStorage + const ReadPiece + const ReleaseUnsealed + const SealCommit1 + const SealCommit2 + const SealPreCommit1 + const SealPreCommit2 + const UnsealPiece + type SchedDiagInfo struct + OpenWindows []string + Requests []SchedDiagRequestInfo + type SchedDiagRequestInfo struct + Priority int + Sector abi.SectorID + TaskType sealtasks.TaskType + type SealerConfig struct + AllowAddPiece bool + AllowCommit bool + AllowPreCommit1 bool + AllowPreCommit2 bool + AllowUnseal bool + ParallelFetchLimit int + type SectorManager interface + ReadPiece func(context.Context, io.Writer, storage.SectorRef, storiface.UnpaddedByteIndex, ...) error + type StorageAuth http.Header + type URLs []string + type WorkID struct + Method sealtasks.TaskType + Params string + func (t *WorkID) MarshalCBOR(w io.Writer) error + func (t *WorkID) UnmarshalCBOR(r io.Reader) error + func (w WorkID) String() string + type WorkState struct + ID WorkID + StartTime int64 + Status WorkStatus + WorkError string + WorkerCall storiface.CallID + WorkerHostname string + func (t *WorkState) MarshalCBOR(w io.Writer) error + func (t *WorkState) UnmarshalCBOR(r io.Reader) error + type WorkStatus string + type Worker interface + Close func() error + Info func(context.Context) (storiface.WorkerInfo, error) + Paths func(context.Context) ([]stores.StoragePath, error) + Session func(context.Context) (uuid.UUID, error) + TaskTypes func(context.Context) (map[sealtasks.TaskType]struct{}, error) + type WorkerAction func(ctx context.Context, w Worker) error + type WorkerConfig struct + NoSwap bool + TaskTypes []sealtasks.TaskType + type WorkerID uuid.UUID + func (w WorkerID) String() string + type WorkerSelector interface + Cmp func(ctx context.Context, task sealtasks.TaskType, a, b *workerHandle) (bool, error) + Ok func(ctx context.Context, task sealtasks.TaskType, spt abi.RegisteredSealProof, ...) (bool, error) + type WorkerStateStore *statestore.StateStore
Go to main page