sectoraccessor

Documentation

Index

• func NewSectorAccessor(maddr dtypes.MinerAddress, secb sectorblocks.SectorBuilder, ...) dagstore.SectorAccessor
• type CachingSectorAccessor
  • func (c *CachingSectorAccessor) IsUnsealed(ctx context.Context, sectorID abi.SectorNumber, offset abi.UnpaddedPieceSize, ...) (bool, error)
• type SectorAccessorConstructor
  • func NewCachingSectorAccessor(maxCacheSize int, cacheExpire time.Duration) SectorAccessorConstructor

Functions

func NewSectorAccessor

func NewSectorAccessor(maddr dtypes.MinerAddress, secb sectorblocks.SectorBuilder, pp sealer.PieceProvider, full v1api.FullNode) dagstore.SectorAccessor

Types

type CachingSectorAccessor

type CachingSectorAccessor struct {
	dagstore.SectorAccessor
	// contains filtered or unexported fields
}

CachingSectorAccessor caches calls to isUnsealed

func (*CachingSectorAccessor) IsUnsealed

func (c *CachingSectorAccessor) IsUnsealed(ctx context.Context, sectorID abi.SectorNumber, offset abi.UnpaddedPieceSize, length abi.UnpaddedPieceSize) (bool, error)

type SectorAccessorConstructor

type SectorAccessorConstructor func(maddr dtypes.MinerAddress, secb sectorblocks.SectorBuilder, pp sealer.PieceProvider, full v1api.FullNode) dagstore.SectorAccessor

func NewCachingSectorAccessor

func NewCachingSectorAccessor(maxCacheSize int, cacheExpire time.Duration) SectorAccessorConstructor