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) GetSectorInfo(sid uint64) (SectorInfo, error)
  • func (m *Miner) ListSectors() ([]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
  • func (m *Miner) UpdateSectorState(ctx context.Context, sector uint64, snonce uint64, state api.SectorState) error
• type Piece
  • func (t *Piece) MarshalCBOR(w io.Writer) error
  • func (t *Piece) UnmarshalCBOR(r io.Reader) error
• type SealSeed
  • func (t *SealSeed) MarshalCBOR(w io.Writer) error
  • func (t *SealSeed) SB() sectorbuilder.SealSeed
  • func (t *SealSeed) UnmarshalCBOR(r io.Reader) error
• type SealTicket
  • func (t *SealTicket) MarshalCBOR(w io.Writer) error
  • func (t *SealTicket) SB() sectorbuilder.SealTicket
  • func (t *SealTicket) UnmarshalCBOR(r io.Reader) 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)
• type SectorInfo
  • func (t *SectorInfo) MarshalCBOR(w io.Writer) error
  • func (t *SectorInfo) UnmarshalCBOR(r io.Reader) error
• type TicketFn

Constants

const Inactive = 0

const NonceIncrement = math.MaxUint64

const SectorStorePrefix = "/sectors"

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 TicketFn) (*Miner, error)

func (*Miner) AllocatePiece

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

func (*Miner) GetSectorInfo

func (m *Miner) GetSectorInfo(sid uint64) (SectorInfo, error)

func (*Miner) ListSectors

func (m *Miner) ListSectors() ([]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

func (*Miner) UpdateSectorState

func (m *Miner) UpdateSectorState(ctx context.Context, sector uint64, snonce uint64, state api.SectorState) error

type Piece

type Piece struct {
	DealID uint64

	Size  uint64
	CommP []byte
}

func (*Piece) MarshalCBOR

func (t *Piece) MarshalCBOR(w io.Writer) error

func (*Piece) UnmarshalCBOR

func (t *Piece) UnmarshalCBOR(r io.Reader) error

type SealSeed

type SealSeed struct {
	BlockHeight uint64
	TicketBytes []byte
}

func (*SealSeed) MarshalCBOR

func (t *SealSeed) MarshalCBOR(w io.Writer) error

func (*SealSeed) SB

func (t *SealSeed) SB() sectorbuilder.SealSeed

func (*SealSeed) UnmarshalCBOR

func (t *SealSeed) UnmarshalCBOR(r io.Reader) error

type SealTicket

type SealTicket struct {
	BlockHeight uint64
	TicketBytes []byte
}

func (*SealTicket) MarshalCBOR

func (t *SealTicket) MarshalCBOR(w io.Writer) error

func (*SealTicket) SB

func (t *SealTicket) SB() sectorbuilder.SealTicket

func (*SealTicket) UnmarshalCBOR

func (t *SealTicket) UnmarshalCBOR(r io.Reader) 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)

type SectorInfo

type SectorInfo struct {
	State    api.SectorState
	SectorID uint64
	Nonce    uint64

	Pieces []Piece

	// PreCommit
	CommD  []byte
	CommR  []byte
	Proof  []byte
	Ticket SealTicket

	PreCommitMessage *cid.Cid

	// PreCommitted
	Seed SealSeed

	// Committing
	CommitMessage *cid.Cid

	// Faults
	FaultReportMsg *cid.Cid

	// Debug
	LastErr string
}

func (*SectorInfo) MarshalCBOR

func (t *SectorInfo) MarshalCBOR(w io.Writer) error

func (*SectorInfo) UnmarshalCBOR

func (t *SectorInfo) UnmarshalCBOR(r io.Reader) error

type TicketFn

type TicketFn func(context.Context) (*sectorbuilder.SealTicket, error)