piecemgr

type Opts struct {
	// The datastore path of the piece info store.
	PsPath string
	// The datastore path of the block store.
	BsPath string
	// The datastore path of the block reference store.
	BrefsPath string
}

type PieceManager interface {
	// Import imports a file.
	//
	// @input - context, file path.
	//
	// @output - cid imported, error.
	Import(ctx context.Context, path string) (cid.Cid, error)

	// ImportCar imports a car file.
	//
	// @input - context, file path.
	//
	// @output - cid imported, error.
	ImportCar(ctx context.Context, path string) (cid.Cid, error)

	// ImportSector imports an unsealed sector copy.
	//
	// @input - context, file path, whether to keep a copy in datastore.
	//
	// @output - list of cid imported, error.
	ImportSector(ctx context.Context, path string, copy bool) ([]cid.Cid, error)

	// ListImported lists all imported pieces.
	//
	// @input - context.
	//
	// @output - cid chan out, error chan out.
	ListImported(ctx context.Context) (<-chan cid.Cid, <-chan error)

	// Inspect inspects a piece.
	//
	// @input - context, cid.
	//
	// @output - if exists, path, index (applicable in sector), the size, whether a copy is kept, error.
	Inspect(ctx context.Context, id cid.Cid) (bool, string, int, uint64, bool, error)

	// Remove removes a piece.
	//
	// @input - context, cid.
	//
	// @output - error.
	Remove(ctx context.Context, id cid.Cid) error

	// LinkSystem returns the linksystem for retrieval.
	//
	// @output - linksystem.
	LinkSystem() ipld.LinkSystem
}

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