storage

package
v0.5.8 Latest Latest
Warning

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

 Go to latest Published: Sep 3, 2020 License: Apache-2.0, MIT Imports: 35 Imported by: 4

Documentation

Index

Constants

View Source 
const StartConfidence = 4 // TODO: config

Variables

This section is empty.

Functions

func AddressFor added in v0.5.0 

func AddressFor(ctx context.Context, a addrSelectApi, mi api.MinerInfo, use AddrUse, minFunds abi.TokenAmount) (address.Address, error)

Types

type AddrUse added in v0.5.0 

type AddrUse int
const (
	PreCommitAddr AddrUse = iota
	CommitAddr
	PoStAddr
)

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, gsd dtypes.GetSealingConfigFunc, feeCfg config.MinerFeeConfig) (*Miner, error)

func (*Miner) AddPieceToAnySector added in v0.5.0 

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

func (*Miner) Address added in v0.3.0 

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

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) IsMarkedForUpgrade added in v0.5.2 

func (m *Miner) IsMarkedForUpgrade(id abi.SectorNumber) bool

func (*Miner) ListSectors 

func (m *Miner) ListSectors() ([]sealing.SectorInfo, error)

func (*Miner) MarkForUpgrade added in v0.5.0 

func (m *Miner) MarkForUpgrade(id abi.SectorNumber) error

func (*Miner) PledgeSector 

func (m *Miner) PledgeSector() error

func (*Miner) RemoveSector added in v0.4.1 

func (m *Miner) RemoveSector(ctx context.Context, id abi.SectorNumber) error

func (*Miner) Run 

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

func (*Miner) StartPackingSector added in v0.5.0 

func (m *Miner) StartPackingSector(sectorNum abi.SectorNumber) 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) ChainGetRandomnessFromBeacon added in v0.5.0 

func (s SealingAPIAdapter) ChainGetRandomnessFromBeacon(ctx context.Context, tok sealing.TipSetToken, personalization crypto.DomainSeparationTag, randEpoch abi.ChainEpoch, entropy []byte) (abi.Randomness, error)

func (SealingAPIAdapter) ChainGetRandomnessFromTickets added in v0.5.0 

func (s SealingAPIAdapter) ChainGetRandomnessFromTickets(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, maxFee abi.TokenAmount, 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.Deadline, error)

func (SealingAPIAdapter) StateMinerInitialPledgeCollateral added in v0.3.0 

func (s SealingAPIAdapter) StateMinerInitialPledgeCollateral(ctx context.Context, a address.Address, pci miner.SectorPreCommitInfo, tok sealing.TipSetToken) (big.Int, error)

func (SealingAPIAdapter) StateMinerPreCommitDepositForPower added in v0.5.0 

func (s SealingAPIAdapter) StateMinerPreCommitDepositForPower(ctx context.Context, a address.Address, pci miner.SectorPreCommitInfo, 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) StateSearchMsg added in v0.5.0 

func (s SealingAPIAdapter) StateSearchMsg(ctx context.Context, c cid.Cid) (*sealing.MsgLookup, 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) StateSectorPartition added in v0.5.0 

func (s SealingAPIAdapter) StateSectorPartition(ctx context.Context, maddr address.Address, sectorNumber abi.SectorNumber, tok sealing.TipSetToken) (*sealing.SectorLocation, 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, fc config.MinerFeeConfig, 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.