Documentation
¶
Index ¶
- type PieceIO
- type Store
- func (s *Store) PieceReader(ctx context.Context, id storiface.PieceNumber) (io.ReadCloser, error)
- func (s *Store) RemovePiece(ctx context.Context, id storiface.PieceNumber) error
- func (s *Store) WritePiece(ctx context.Context, taskID *harmonytask.TaskID, pieceID storiface.PieceNumber, ...) error
- func (s *Store) WriteUploadPiece(ctx context.Context, pieceID storiface.PieceNumber, size int64, data io.Reader, ...) (abi.PieceInfo, uint64, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PieceIO ¶
type PieceIO interface {
WritePiece(ctx context.Context, taskID *harmonytask.TaskID, pieceID storiface.PieceNumber, size int64, data io.Reader, storageType storiface.PathType) error
WriteUploadPiece(ctx context.Context, pieceID storiface.PieceNumber, size int64, data io.Reader, storageType storiface.PathType, verifySize bool) (abi.PieceInfo, uint64, error)
PieceReader(ctx context.Context, id storiface.PieceNumber) (io.ReadCloser, error)
RemovePiece(ctx context.Context, id storiface.PieceNumber) error
}
PieceIO provides FFI-free piece storage operations.
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store implements PieceIO using local/remote path storage without filecoin-ffi.
func (*Store) PieceReader ¶
func (s *Store) PieceReader(ctx context.Context, id storiface.PieceNumber) (io.ReadCloser, error)
func (*Store) RemovePiece ¶
func (*Store) WritePiece ¶
Source Files
Click to show internal directories.
Click to hide internal directories.