storage

Documentation

Index

• Constants
• type Miner
  • func NewMiner(api storageMinerApi, addr address.Address, h host.Host, ds datastore.Batching, ...) (*Miner, error)
  • func (m *Miner) AllocatePiece(size uint64) (sectorID uint64, offset uint64, err error)
  • func (m *Miner) ForceSectorState(ctx context.Context, id uint64, state api.SectorState) error
  • func (m *Miner) GetSectorInfo(sid uint64) (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 uint64, r io.Reader, sectorID uint64, dealID uint64) error
  • func (m *Miner) Stop(ctx context.Context) error
• type SectorBuilderEpp
  • func NewElectionPoStProver(sb sectorbuilder.Interface) *SectorBuilderEpp
  • func (epp *SectorBuilderEpp) ComputeProof(ctx context.Context, ssi sectorbuilder.SortedPublicSectorInfo, rand []byte, ...) ([]byte, error)
  • func (epp *SectorBuilderEpp) GenerateCandidates(ctx context.Context, ssi sectorbuilder.SortedPublicSectorInfo, rand []byte) ([]sectorbuilder.EPostCandidate, error)

Constants

const Inactive = 0

const StartConfidence = 4 // TODO: config

Types

type Miner

type Miner struct {
	// contains filtered or unexported fields
}

func NewMiner

func NewMiner(api storageMinerApi, addr address.Address, h host.Host, ds datastore.Batching, sb sectorbuilder.Interface, tktFn sealing.TicketFn) (*Miner, error)

func (*Miner) AllocatePiece

func (m *Miner) AllocatePiece(size uint64) (sectorID uint64, offset uint64, err error)

func (*Miner) ForceSectorState

func (m *Miner) ForceSectorState(ctx context.Context, id uint64, state api.SectorState) error

func (*Miner) GetSectorInfo

func (m *Miner) GetSectorInfo(sid uint64) (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 uint64, r io.Reader, sectorID uint64, dealID uint64) error

func (*Miner) Stop

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

type SectorBuilderEpp

type SectorBuilderEpp struct {
	// contains filtered or unexported fields
}

func NewElectionPoStProver

func NewElectionPoStProver(sb sectorbuilder.Interface) *SectorBuilderEpp

func (*SectorBuilderEpp) ComputeProof

func (epp *SectorBuilderEpp) ComputeProof(ctx context.Context, ssi sectorbuilder.SortedPublicSectorInfo, rand []byte, winners []sectorbuilder.EPostCandidate) ([]byte, error)

func (*SectorBuilderEpp) GenerateCandidates

func (epp *SectorBuilderEpp) GenerateCandidates(ctx context.Context, ssi sectorbuilder.SortedPublicSectorInfo, rand []byte) ([]sectorbuilder.EPostCandidate, error)