Documentation ¶
Index ¶
- Constants
- type EventsAdapter
- type Miner
- func (m *Miner) Address() address.Address
- func (m *Miner) AllocatePiece(size abi.UnpaddedPieceSize) (sectorID abi.SectorNumber, offset uint64, err error)
- func (m *Miner) ForceSectorState(ctx context.Context, id abi.SectorNumber, state sealing.SectorState) error
- func (m *Miner) GetSectorInfo(sid abi.SectorNumber) (sealing.SectorInfo, error)
- func (m *Miner) ListSectors() ([]sealing.SectorInfo, error)
- func (m *Miner) PledgeSector() error
- func (m *Miner) Run(ctx context.Context) error
- func (m *Miner) SealPiece(ctx context.Context, size abi.UnpaddedPieceSize, r io.Reader, ...) error
- func (m *Miner) Stop(ctx context.Context) error
- type SealingAPIAdapter
- func (s SealingAPIAdapter) ChainGetRandomness(ctx context.Context, tok sealing.TipSetToken, ...) (abi.Randomness, error)
- func (s SealingAPIAdapter) ChainHead(ctx context.Context) (sealing.TipSetToken, abi.ChainEpoch, error)
- func (s SealingAPIAdapter) ChainReadObj(ctx context.Context, ocid cid.Cid) ([]byte, error)
- func (s SealingAPIAdapter) SendMsg(ctx context.Context, from, to address.Address, method abi.MethodNum, ...) (cid.Cid, error)
- func (s SealingAPIAdapter) StateComputeDataCommitment(ctx context.Context, maddr address.Address, sectorType abi.RegisteredProof, ...) (cid.Cid, error)
- func (s SealingAPIAdapter) StateMarketStorageDeal(ctx context.Context, dealID abi.DealID, tok sealing.TipSetToken) (market.DealProposal, error)
- func (s SealingAPIAdapter) StateMinerDeadlines(ctx context.Context, maddr address.Address, tok sealing.TipSetToken) (*miner.Deadlines, error)
- func (s SealingAPIAdapter) StateMinerInitialPledgeCollateral(ctx context.Context, a address.Address, n abi.SectorNumber, ...) (big.Int, error)
- func (s SealingAPIAdapter) StateMinerSectorSize(ctx context.Context, maddr address.Address, tok sealing.TipSetToken) (abi.SectorSize, error)
- func (s SealingAPIAdapter) StateMinerWorkerAddress(ctx context.Context, maddr address.Address, tok sealing.TipSetToken) (address.Address, error)
- func (s SealingAPIAdapter) StateSectorGetInfo(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, ...) (*miner.SectorOnChainInfo, error)
- func (s SealingAPIAdapter) StateSectorPreCommitInfo(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, ...) (*miner.SectorPreCommitOnChainInfo, error)
- func (s SealingAPIAdapter) StateWaitMsg(ctx context.Context, mcid cid.Cid) (sealing.MsgLookup, error)
- type StorageWpp
- type WindowPoStScheduler
Constants ¶
View Source
const StartConfidence = 4 // TODO: config
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventsAdapter ¶ added in v0.3.0
type EventsAdapter struct {
// contains filtered or unexported fields
}
func NewEventsAdapter ¶ added in v0.3.0
func NewEventsAdapter(api *events.Events) EventsAdapter
func (EventsAdapter) ChainAt ¶ added in v0.3.0
func (e EventsAdapter) ChainAt(hnd sealing.HeightHandler, rev sealing.RevertHandler, confidence int, h abi.ChainEpoch) error
type Miner ¶
type Miner struct {
// contains filtered or unexported fields
}
func NewMiner ¶
func NewMiner(api storageMinerApi, maddr, worker address.Address, h host.Host, ds datastore.Batching, sealer sectorstorage.SectorManager, sc sealing.SectorIDCounter, verif ffiwrapper.Verifier) (*Miner, error)
func (*Miner) AllocatePiece ¶
func (m *Miner) AllocatePiece(size abi.UnpaddedPieceSize) (sectorID abi.SectorNumber, offset uint64, err error)
func (*Miner) ForceSectorState ¶ added in v0.2.5
func (m *Miner) ForceSectorState(ctx context.Context, id abi.SectorNumber, state sealing.SectorState) error
func (*Miner) GetSectorInfo ¶
func (m *Miner) GetSectorInfo(sid abi.SectorNumber) (sealing.SectorInfo, error)
func (*Miner) ListSectors ¶
func (m *Miner) ListSectors() ([]sealing.SectorInfo, error)
func (*Miner) PledgeSector ¶
type SealingAPIAdapter ¶ added in v0.3.0
type SealingAPIAdapter struct {
// contains filtered or unexported fields
}
func NewSealingAPIAdapter ¶ added in v0.3.0
func NewSealingAPIAdapter(api storageMinerApi) SealingAPIAdapter
func (SealingAPIAdapter) ChainGetRandomness ¶ added in v0.3.0
func (s SealingAPIAdapter) ChainGetRandomness(ctx context.Context, tok sealing.TipSetToken, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte) (abi.Randomness, error)
func (SealingAPIAdapter) ChainHead ¶ added in v0.3.0
func (s SealingAPIAdapter) ChainHead(ctx context.Context) (sealing.TipSetToken, abi.ChainEpoch, error)
func (SealingAPIAdapter) ChainReadObj ¶ added in v0.3.0
func (s SealingAPIAdapter) ChainReadObj(ctx context.Context, ocid cid.Cid) ([]byte, error)
func (SealingAPIAdapter) StateComputeDataCommitment ¶ added in v0.3.0
func (s SealingAPIAdapter) StateComputeDataCommitment(ctx context.Context, maddr address.Address, sectorType abi.RegisteredProof, deals []abi.DealID, tok sealing.TipSetToken) (cid.Cid, error)
func (SealingAPIAdapter) StateMarketStorageDeal ¶ added in v0.3.0
func (s SealingAPIAdapter) StateMarketStorageDeal(ctx context.Context, dealID abi.DealID, tok sealing.TipSetToken) (market.DealProposal, error)
func (SealingAPIAdapter) StateMinerDeadlines ¶ added in v0.3.0
func (s SealingAPIAdapter) StateMinerDeadlines(ctx context.Context, maddr address.Address, tok sealing.TipSetToken) (*miner.Deadlines, error)
func (SealingAPIAdapter) StateMinerInitialPledgeCollateral ¶ added in v0.3.0
func (s SealingAPIAdapter) StateMinerInitialPledgeCollateral(ctx context.Context, a address.Address, n abi.SectorNumber, tok sealing.TipSetToken) (big.Int, error)
func (SealingAPIAdapter) StateMinerSectorSize ¶ added in v0.3.0
func (s SealingAPIAdapter) StateMinerSectorSize(ctx context.Context, maddr address.Address, tok sealing.TipSetToken) (abi.SectorSize, error)
func (SealingAPIAdapter) StateMinerWorkerAddress ¶ added in v0.3.0
func (s SealingAPIAdapter) StateMinerWorkerAddress(ctx context.Context, maddr address.Address, tok sealing.TipSetToken) (address.Address, error)
func (SealingAPIAdapter) StateSectorGetInfo ¶ added in v0.3.1
func (s SealingAPIAdapter) StateSectorGetInfo(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tok sealing.TipSetToken) (*miner.SectorOnChainInfo, error)
func (SealingAPIAdapter) StateSectorPreCommitInfo ¶ added in v0.3.0
func (s SealingAPIAdapter) StateSectorPreCommitInfo(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tok sealing.TipSetToken) (*miner.SectorPreCommitOnChainInfo, error)
func (SealingAPIAdapter) StateWaitMsg ¶ added in v0.3.0
type StorageWpp ¶ added in v0.3.0
type StorageWpp struct {
// contains filtered or unexported fields
}
func NewWinningPoStProver ¶ added in v0.3.0
func NewWinningPoStProver(api api.FullNode, prover storage.Prover, verifier ffiwrapper.Verifier, miner dtypes.MinerID) (*StorageWpp, error)
func (*StorageWpp) ComputeProof ¶ added in v0.3.0
func (wpp *StorageWpp) ComputeProof(ctx context.Context, ssi []abi.SectorInfo, rand abi.PoStRandomness) ([]abi.PoStProof, error)
func (*StorageWpp) GenerateCandidates ¶ added in v0.3.0
func (wpp *StorageWpp) GenerateCandidates(ctx context.Context, randomness abi.PoStRandomness, eligibleSectorCount uint64) ([]uint64, error)
type WindowPoStScheduler ¶ added in v0.3.0
type WindowPoStScheduler struct {
// contains filtered or unexported fields
}
func NewWindowedPoStScheduler ¶ added in v0.3.0
func NewWindowedPoStScheduler(api storageMinerApi, sb storage.Prover, ft sectorstorage.FaultTracker, actor address.Address, worker address.Address) (*WindowPoStScheduler, error)
func (*WindowPoStScheduler) Run ¶ added in v0.3.0
func (s *WindowPoStScheduler) Run(ctx context.Context)
Source Files ¶
Click to show internal directories.
Click to hide internal directories.