storage

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 18, 2020 License: Apache-2.0, MIT Imports: 34 Imported by: 3

Documentation

Index

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) Address added in v0.3.0 

func (m *Miner) Address() address.Address

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 

func (m *Miner) PledgeSector() error

func (*Miner) Run 

func (m *Miner) Run(ctx context.Context) error

func (*Miner) SealPiece 

func (m *Miner) SealPiece(ctx context.Context, size abi.UnpaddedPieceSize, r io.Reader, sectorID abi.SectorNumber, d sealing.DealInfo) error

func (*Miner) Stop 

func (m *Miner) Stop(ctx context.Context) error

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) SendMsg added in v0.3.0 

func (s SealingAPIAdapter) SendMsg(ctx context.Context, from, to address.Address, method abi.MethodNum, value, gasPrice big.Int, gasLimit int64, params []byte) (cid.Cid, error)

func (SealingAPIAdapter) StateComputeDataCommitment added in v0.3.0 

func (s SealingAPIAdapter) StateComputeDataCommitment(ctx context.Context, maddr address.Address, sectorType abi.RegisteredSealProof, 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 

func (s SealingAPIAdapter) StateWaitMsg(ctx context.Context, mcid cid.Cid) (sealing.MsgLookup, error)

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

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.