Versions in this module Expand all Collapse all v1 v1.0.0 Aug 15, 2021 Changes in this version + const InteractivePoRepConfidence + const RetCommitFailed + const RetPreCommit1 + const RetPreCommitFailed + const RetPreCommitting + const SectorStorePrefix + var DealSectorPriority = 1024 + var ErrSectorAllocated = errors.New("sectorNumber is allocated, but PreCommit info wasn't found on chain") + var ErrTooManySectorsSealing = xerrors.New("too many sectors sealing") + var ExistSectorStateList = map[SectorState]struct + var MaxTicketAge = abi.ChainEpoch(builtin.EpochsInDay * 2) + var StorageMsgSearchLimit = 5 * build.Finality + var TerminateBatchMax uint64 = 100 + var TerminateBatchMin uint64 = 1 + var TerminateBatchWait = 5 * time.Minute + func NewNullReader(size abi.UnpaddedPieceSize) io.Reader + type AddrSel func(ctx context.Context, mi miner.MinerInfo, use api.AddrUse, ...) (address.Address, abi.TokenAmount, error) + type CurrentDealInfo struct + DealID abi.DealID + MarketDeal *api.MarketDeal + PublishMsgTipSet TipSetToken + type CurrentDealInfoAPI interface + ChainGetMessage func(context.Context, cid.Cid) (*types.Message, error) + StateLookupID func(context.Context, address.Address, TipSetToken) (address.Address, error) + StateMarketStorageDeal func(context.Context, abi.DealID, TipSetToken) (*api.MarketDeal, error) + StateSearchMsgLimited func(context.Context, cid.Cid, abi.ChainEpoch) (*MsgLookup, error) + type CurrentDealInfoAPIAdapter struct + func (c *CurrentDealInfoAPIAdapter) StateLookupID(ctx context.Context, a address.Address, tok TipSetToken) (address.Address, error) + func (c *CurrentDealInfoAPIAdapter) StateMarketStorageDeal(ctx context.Context, dealID abi.DealID, tok TipSetToken) (*api.MarketDeal, error) + func (c *CurrentDealInfoAPIAdapter) StateSearchMsgLimited(ctx context.Context, k cid.Cid, limit abi.ChainEpoch) (*MsgLookup, error) + type CurrentDealInfoManager struct + CDAPI CurrentDealInfoAPI + func (mgr *CurrentDealInfoManager) CheckDealEquality(ctx context.Context, tok TipSetToken, p1, p2 market.DealProposal) (bool, error) + func (mgr *CurrentDealInfoManager) GetCurrentDealInfo(ctx context.Context, tok TipSetToken, proposal *market.DealProposal, ...) (CurrentDealInfo, error) + type CurrentDealInfoTskAPI interface + ChainGetMessage func(ctx context.Context, mc cid.Cid) (*types.Message, error) + StateLookupID func(context.Context, address.Address, types.TipSetKey) (address.Address, error) + StateMarketStorageDeal func(context.Context, abi.DealID, types.TipSetKey) (*api.MarketDeal, error) + StateSearchMsgLimited func(context.Context, cid.Cid, abi.ChainEpoch) (*api.MsgLookup, error) + type DealInfo struct + DealID abi.DealID + DealProposal *market.DealProposal + DealSchedule DealSchedule + KeepUnsealed bool + PublishCid *cid.Cid + func (t *DealInfo) MarshalCBOR(w io.Writer) error + func (t *DealInfo) UnmarshalCBOR(r io.Reader) error + type DealSchedule struct + StartEpoch abi.ChainEpoch + func (t *DealSchedule) MarshalCBOR(w io.Writer) error + func (t *DealSchedule) UnmarshalCBOR(r io.Reader) error + type ErrApi struct + type ErrBadCommD struct + type ErrBadSeed struct + type ErrBadTicket struct + type ErrCommitWaitFailed struct + type ErrExpiredDeals struct + type ErrExpiredTicket struct + type ErrInvalidDeals struct + type ErrInvalidPiece struct + type ErrInvalidProof struct + type ErrNoPrecommit struct + type ErrPrecommitOnChain struct + type ErrSectorNumberAllocated struct + type Events interface + ChainAt func(hnd HeightHandler, rev RevertHandler, confidence int, h abi.ChainEpoch) error + type FeeConfig struct + MaxCommitGasFee abi.TokenAmount + MaxPreCommitGasFee abi.TokenAmount + MaxTerminateGasFee abi.TokenAmount + type GetSealingConfigFunc func() (sealiface.Config, error) + type HeightHandler func(ctx context.Context, tok TipSetToken, curH abi.ChainEpoch) error + type Ignorable interface + Ignore func() + type Log struct + Kind string + Message string + Timestamp uint64 + Trace string + func (t *Log) MarshalCBOR(w io.Writer) error + func (t *Log) UnmarshalCBOR(r io.Reader) error + type MessageReceipt struct + ExitCode exitcode.ExitCode + GasUsed int64 + Return []byte + func (mr *MessageReceipt) Equals(o *MessageReceipt) bool + type MsgLookup struct + Height abi.ChainEpoch + Receipt MessageReceipt + TipSetTok TipSetToken + type NullReader struct + func (m NullReader) NullBytes() int64 + type Piece struct + DealInfo *DealInfo + Piece abi.PieceInfo + func (t *Piece) MarshalCBOR(w io.Writer) error + func (t *Piece) UnmarshalCBOR(r io.Reader) error + type PieceWithDealInfo struct + DealInfo DealInfo + Piece abi.PieceInfo + type ReturnState string + type RevertHandler func(ctx context.Context, tok TipSetToken) error + type Sealing struct + func New(api SealingAPI, fc FeeConfig, events Events, maddr address.Address, ...) *Sealing + func (m *Sealing) AddPieceToAnySector(ctx context.Context, size abi.UnpaddedPieceSize, data storage.Data, ...) (abi.SectorNumber, abi.PaddedPieceSize, error) + func (m *Sealing) Address() address.Address + func (m *Sealing) ForceSectorState(ctx context.Context, id abi.SectorNumber, state SectorState) error + func (m *Sealing) GetSectorInfo(sid abi.SectorNumber) (SectorInfo, error) + func (m *Sealing) ListSectors() ([]SectorInfo, error) + func (m *Sealing) Plan(events []statemachine.Event, user interface{}) (interface{}, uint64, error) + func (m *Sealing) PledgeSector(ctx context.Context) (storage.SectorRef, error) + func (m *Sealing) Remove(ctx context.Context, sid abi.SectorNumber) error + func (m *Sealing) Run(ctx context.Context) error + func (m *Sealing) StartPacking(sid abi.SectorNumber) error + func (m *Sealing) Stop(ctx context.Context) error + func (m *Sealing) Terminate(ctx context.Context, sid abi.SectorNumber) error + func (m *Sealing) TerminateFlush(ctx context.Context) (*cid.Cid, error) + func (m *Sealing) TerminatePending(ctx context.Context) ([]abi.SectorID, error) + type SealingAPI interface + ChainGetMessage func(ctx context.Context, mc cid.Cid) (*types.Message, error) + ChainGetRandomnessFromBeacon func(ctx context.Context, tok TipSetToken, ...) (abi.Randomness, error) + ChainGetRandomnessFromTickets func(ctx context.Context, tok TipSetToken, ...) (abi.Randomness, error) + ChainHead func(ctx context.Context) (TipSetToken, abi.ChainEpoch, error) + ChainReadObj func(context.Context, cid.Cid) ([]byte, error) + SendMsg func(ctx context.Context, from, to address.Address, method abi.MethodNum, ...) (cid.Cid, error) + StateComputeDataCommitment func(ctx context.Context, maddr address.Address, sectorType abi.RegisteredSealProof, ...) (cid.Cid, error) + StateLookupID func(context.Context, address.Address, TipSetToken) (address.Address, error) + StateMarketStorageDeal func(context.Context, abi.DealID, TipSetToken) (*api.MarketDeal, error) + StateMarketStorageDealProposal func(context.Context, abi.DealID, TipSetToken) (market.DealProposal, error) + StateMinerInfo func(context.Context, address.Address, TipSetToken) (miner.MinerInfo, error) + StateMinerPartitions func(ctx context.Context, m address.Address, dlIdx uint64, tok TipSetToken) ([]api.Partition, error) + StateMinerProvingDeadline func(context.Context, address.Address, TipSetToken) (*dline.Info, error) + StateMinerSectorAllocated func(context.Context, address.Address, abi.SectorNumber, TipSetToken) (bool, error) + StateMinerSectorSize func(context.Context, address.Address, TipSetToken) (abi.SectorSize, error) + StateMinerWorkerAddress func(ctx context.Context, maddr address.Address, tok TipSetToken) (address.Address, error) + StateNetworkVersion func(ctx context.Context, tok TipSetToken) (network.Version, error) + StateSearchMsgLimited func(context.Context, cid.Cid, abi.ChainEpoch) (*MsgLookup, error) + StateSectorGetInfo func(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, ...) (*miner.SectorOnChainInfo, error) + StateSectorPartition func(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, ...) (*SectorLocation, error) + StateSectorPreCommitInfo func(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, ...) (*miner.SectorPreCommitOnChainInfo, error) + StateWaitMsg func(context.Context, cid.Cid) (MsgLookup, error) + type SectorAddPiece struct + type SectorAddPieceFailed struct + func (evt SectorAddPieceFailed) FormatError(xerrors.Printer) (next error) + type SectorChainPreCommitFailed struct + func (evt SectorChainPreCommitFailed) FormatError(xerrors.Printer) (next error) + type SectorCommitFailed struct + func (evt SectorCommitFailed) FormatError(xerrors.Printer) (next error) + type SectorCommitSubmitted struct + Message cid.Cid + type SectorCommitted struct + Proof []byte + type SectorComputeProofFailed struct + func (evt SectorComputeProofFailed) FormatError(xerrors.Printer) (next error) + type SectorDealsExpired struct + func (evt SectorDealsExpired) FormatError(xerrors.Printer) (next error) + type SectorFatalError struct + func (evt SectorFatalError) FormatError(xerrors.Printer) (next error) + type SectorFaultReported struct + type SectorFaultedFinal struct + type SectorFaulty struct + type SectorFinalizeFailed struct + func (evt SectorFinalizeFailed) FormatError(xerrors.Printer) (next error) + type SectorFinalized struct + type SectorForceState struct + State SectorState + type SectorIDCounter interface + Next func() (abi.SectorNumber, error) + type SectorInfo struct + CommD *cid.Cid + CommR *cid.Cid + CommitMessage *cid.Cid + CreationTime int64 + FaultReportMsg *cid.Cid + InvalidProofs uint64 + LastErr string + Log []Log + Pieces []Piece + PreCommit1Out storage.PreCommit1Out + PreCommit2Fails uint64 + PreCommitInfo *miner.SectorPreCommitInfo + PreCommitMessage *cid.Cid + PreCommitTipSet TipSetToken + Proof []byte + Return ReturnState + SectorNumber abi.SectorNumber + SectorType abi.RegisteredSealProof + SeedEpoch abi.ChainEpoch + SeedValue abi.InteractiveSealRandomness + State SectorState + TerminateMessage *cid.Cid + TerminatedAt abi.ChainEpoch + TicketEpoch abi.ChainEpoch + TicketValue abi.SealRandomness + func (t *SectorInfo) MarshalCBOR(w io.Writer) error + func (t *SectorInfo) UnmarshalCBOR(r io.Reader) error + type SectorInvalidDealIDs struct + Return ReturnState + type SectorLocation struct + Deadline uint64 + Partition uint64 + type SectorOldTicket struct + type SectorPacked struct + FillerPieces []abi.PieceInfo + type SectorPieceAdded struct + NewPieces []Piece + type SectorPreCommit1 struct + PreCommit1Out storage.PreCommit1Out + type SectorPreCommit2 struct + Sealed cid.Cid + Unsealed cid.Cid + type SectorPreCommitLanded struct + TipSet TipSetToken + type SectorPreCommitted struct + Message cid.Cid + PreCommitInfo miner.SectorPreCommitInfo + type SectorProving struct + type SectorRemove struct + type SectorRemoveFailed struct + func (evt SectorRemoveFailed) FormatError(xerrors.Printer) (next error) + type SectorRemoved struct + type SectorRestart struct + type SectorRetryCommitWait struct + type SectorRetryComputeProof struct + type SectorRetryFinalize struct + type SectorRetryInvalidProof struct + type SectorRetryPreCommit struct + type SectorRetryPreCommitWait struct + type SectorRetrySealPreCommit1 struct + type SectorRetrySealPreCommit2 struct + type SectorRetrySubmitCommit struct + type SectorRetryWaitSeed struct + type SectorSealPreCommit1Failed struct + func (evt SectorSealPreCommit1Failed) FormatError(xerrors.Printer) (next error) + type SectorSealPreCommit2Failed struct + func (evt SectorSealPreCommit2Failed) FormatError(xerrors.Printer) (next error) + type SectorSeedReady struct + SeedEpoch abi.ChainEpoch + SeedValue abi.InteractiveSealRandomness + type SectorStart struct + ID abi.SectorNumber + SectorType abi.RegisteredSealProof + type SectorStartCC struct + ID abi.SectorNumber + SectorType abi.RegisteredSealProof + type SectorStartPacking struct + func (evt SectorStartPacking) Ignore() + type SectorState string + const AddPiece + const AddPieceFailed + const CommitFailed + const CommitWait + const Committing + const ComputeProofFailed + const DealsExpired + const Empty + const FailedUnrecoverable + const FaultReported + const FaultedFinal + const Faulty + const FinalizeFailed + const FinalizeSector + const GetTicket + const Packing + const PackingFailed + const PreCommit1 + const PreCommit2 + const PreCommitFailed + const PreCommitWait + const PreCommitting + const Proving + const RecoverDealIDs + const RemoveFailed + const Removed + const Removing + const SealPreCommit1Failed + const SealPreCommit2Failed + const SubmitCommit + const TerminateFailed + const TerminateFinality + const TerminateWait + const Terminating + const UndefinedSectorState + const WaitDeals + const WaitSeed + type SectorStateNotifee func(before, after SectorInfo) + type SectorStats struct + type SectorTerminate struct + type SectorTerminateFailed struct + func (evt SectorTerminateFailed) FormatError(xerrors.Printer) (next error) + type SectorTerminated struct + TerminatedAt abi.ChainEpoch + type SectorTerminating struct + Message *cid.Cid + type SectorTicket struct + TicketEpoch abi.ChainEpoch + TicketValue abi.SealRandomness + type SectorTicketExpired struct + func (evt SectorTicketExpired) FormatError(xerrors.Printer) (next error) + type SectorUpdateDealIDs struct + Updates map[int]abi.DealID + type TerminateBatcher struct + func NewTerminationBatcher(mctx context.Context, maddr address.Address, api TerminateBatcherApi, ...) *TerminateBatcher + func (b *TerminateBatcher) AddTermination(ctx context.Context, s abi.SectorID) (mcid cid.Cid, terminated bool, err error) + func (b *TerminateBatcher) Flush(ctx context.Context) (*cid.Cid, error) + func (b *TerminateBatcher) Pending(ctx context.Context) ([]abi.SectorID, error) + func (b *TerminateBatcher) Stop(ctx context.Context) error + type TerminateBatcherApi interface + SendMsg func(ctx context.Context, from, to address.Address, method abi.MethodNum, ...) (cid.Cid, error) + StateMinerInfo func(context.Context, address.Address, TipSetToken) (miner.MinerInfo, error) + StateMinerPartitions func(ctx context.Context, m address.Address, dlIdx uint64, tok TipSetToken) ([]api.Partition, error) + StateMinerProvingDeadline func(context.Context, address.Address, TipSetToken) (*dline.Info, error) + StateSectorPartition func(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, ...) (*SectorLocation, error) + type TipSetToken []byte