sectorblocks

Documentation

Index

• Variables
• type SealSerialization
• type SectorBlockStore
  • func (s *SectorBlockStore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)
  • func (s *SectorBlockStore) DeleteBlock(cid.Cid) error
  • func (s *SectorBlockStore) Get(c cid.Cid) (blocks.Block, error)
  • func (s *SectorBlockStore) GetSize(cid.Cid) (int, error)
  • func (s *SectorBlockStore) Has(c cid.Cid) (bool, error)
  • func (s *SectorBlockStore) HashOnRead(enabled bool)
  • func (s *SectorBlockStore) Put(blocks.Block) error
  • func (s *SectorBlockStore) PutMany([]blocks.Block) error
• type SectorBlocks
  • func NewSectorBlocks(miner *storage.Miner, ds dtypes.MetadataDS, sb sectorbuilder.Interface) *SectorBlocks
  • func (st *SectorBlocks) AddUnixfsPiece(ctx context.Context, r UnixfsReader, dealID uint64) (sectorID uint64, err error)
  • func (st *SectorBlocks) GetRefs(k cid.Cid) ([]api.SealedRef, error)
  • func (st *SectorBlocks) GetSize(k cid.Cid) (uint64, error)
  • func (st *SectorBlocks) Has(k cid.Cid) (bool, error)
  • func (st *SectorBlocks) List() (map[cid.Cid][]api.SealedRef, error)
  • func (st *SectorBlocks) SealedBlockstore(approveUnseal func() error) *SectorBlockStore
• type UnixfsReader

Variables

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

Types

type SealSerialization

type SealSerialization uint8

const (
	SerializationUnixfs0 SealSerialization = 'u'
)

type SectorBlockStore

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

func (*SectorBlockStore) AllKeysChan

func (s *SectorBlockStore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)

func (*SectorBlockStore) DeleteBlock

func (s *SectorBlockStore) DeleteBlock(cid.Cid) error

func (*SectorBlockStore) Get

func (s *SectorBlockStore) Get(c cid.Cid) (blocks.Block, error)

func (*SectorBlockStore) GetSize

func (s *SectorBlockStore) GetSize(cid.Cid) (int, error)

func (*SectorBlockStore) Has

func (s *SectorBlockStore) Has(c cid.Cid) (bool, error)

func (*SectorBlockStore) HashOnRead

func (s *SectorBlockStore) HashOnRead(enabled bool)

func (*SectorBlockStore) Put

func (s *SectorBlockStore) Put(blocks.Block) error

func (*SectorBlockStore) PutMany

func (s *SectorBlockStore) PutMany([]blocks.Block) error

type SectorBlocks

type SectorBlocks struct {
	*storage.Miner
	// contains filtered or unexported fields
}

func NewSectorBlocks

func NewSectorBlocks(miner *storage.Miner, ds dtypes.MetadataDS, sb sectorbuilder.Interface) *SectorBlocks

func (*SectorBlocks) AddUnixfsPiece

func (st *SectorBlocks) AddUnixfsPiece(ctx context.Context, r UnixfsReader, dealID uint64) (sectorID uint64, err error)

func (*SectorBlocks) GetRefs

func (st *SectorBlocks) GetRefs(k cid.Cid) ([]api.SealedRef, error)

func (*SectorBlocks) GetSize

func (st *SectorBlocks) GetSize(k cid.Cid) (uint64, error)

func (*SectorBlocks) Has

func (st *SectorBlocks) Has(k cid.Cid) (bool, error)

func (*SectorBlocks) List

func (st *SectorBlocks) List() (map[cid.Cid][]api.SealedRef, error)

func (*SectorBlocks) SealedBlockstore

func (st *SectorBlocks) SealedBlockstore(approveUnseal func() error) *SectorBlockStore

type UnixfsReader

type UnixfsReader interface {
	files.File

	// ReadBlock reads data from a single unixfs block. Data is nil
	// for intermediate nodes
	ReadBlock(context.Context) (data []byte, offset uint64, nd ipld.Node, err error)
}