sectorblocks

Documentation

Index

• Variables
• func DealIDToDsKey(dealID abi.DealID) datastore.Key
• func DsKeyToDealID(key datastore.Key) (uint64, error)
• type SectorBlocks
  • func NewSectorBlocks(sb SectorBuilder, ds dtypes.MetadataDS) *SectorBlocks
  • func (st *SectorBlocks) AddPiece(ctx context.Context, size abi.UnpaddedPieceSize, r io.Reader, ...) (abi.SectorNumber, abi.PaddedPieceSize, error)
  • func (st *SectorBlocks) GetRefs(ctx context.Context, dealID abi.DealID) ([]api.SealedRef, error)
  • func (st *SectorBlocks) GetSize(ctx context.Context, dealID abi.DealID) (uint64, error)
  • func (st *SectorBlocks) Has(ctx context.Context, dealID abi.DealID) (bool, error)
  • func (st *SectorBlocks) List(ctx context.Context) (map[uint64][]api.SealedRef, error)
• type SectorBuilder

Variables

var ErrNotFound = errors.New("not found")

Functions

func DealIDToDsKey

func DealIDToDsKey(dealID abi.DealID) datastore.Key

func DsKeyToDealID

func DsKeyToDealID(key datastore.Key) (uint64, error)

Types

type SectorBlocks

type SectorBlocks struct {
	SectorBuilder
	// contains filtered or unexported fields
}

func NewSectorBlocks

func NewSectorBlocks(sb SectorBuilder, ds dtypes.MetadataDS) *SectorBlocks

func (*SectorBlocks) AddPiece

func (st *SectorBlocks) AddPiece(ctx context.Context, size abi.UnpaddedPieceSize, r io.Reader, d piece.PieceDealInfo) (abi.SectorNumber, abi.PaddedPieceSize, error)

func (*SectorBlocks) GetRefs

func (st *SectorBlocks) GetRefs(ctx context.Context, dealID abi.DealID) ([]api.SealedRef, error)

func (*SectorBlocks) GetSize

func (st *SectorBlocks) GetSize(ctx context.Context, dealID abi.DealID) (uint64, error)

func (*SectorBlocks) Has

func (st *SectorBlocks) Has(ctx context.Context, dealID abi.DealID) (bool, error)

func (*SectorBlocks) List

func (st *SectorBlocks) List(ctx context.Context) (map[uint64][]api.SealedRef, error)

type SectorBuilder

type SectorBuilder interface {
	SectorAddPieceToAny(ctx context.Context, size abi.UnpaddedPieceSize, r storiface.Data, d piece.PieceDealInfo) (api.SectorOffset, error)
	SectorsStatus(ctx context.Context, sid abi.SectorNumber, showOnChainInfo bool) (api.SectorInfo, error)
}