Documentation ¶
Index ¶
- Variables
- func ClearCache(path string)
- func Copy(ctx context.Context, srcObjPath, dstDirPath string, lazyCache ...bool) (bool, error)
- func Get(ctx context.Context, path string) (model.Obj, error)
- func GetStorage(path string) (driver.Driver, error)
- func Link(ctx context.Context, path string, args model.LinkArgs) (*model.Link, model.Obj, error)
- func List(ctx context.Context, path string, refresh ...bool) ([]model.Obj, error)
- func MakeDir(ctx context.Context, path string, lazyCache ...bool) error
- func Move(ctx context.Context, srcPath, dstDirPath string, lazyCache ...bool) error
- func Other(ctx context.Context, args model.FsOtherArgs) (interface{}, error)
- func PutAsTask(dstDirPath string, file *model.FileStream) error
- func PutDirectly(ctx context.Context, dstDirPath string, file *model.FileStream, ...) error
- func Remove(ctx context.Context, path string) error
- func Rename(ctx context.Context, srcPath, dstName string, lazyCache ...bool) error
- func WalkFS(ctx context.Context, depth int, name string, info model.Obj, ...) error
Constants ¶
This section is empty.
Variables ¶
View Source
var CopyTaskManager = task.NewTaskManager(3, func(tid *uint64) { atomic.AddUint64(tid, 1) })
View Source
var UploadTaskManager = task.NewTaskManager(3, func(tid *uint64) { atomic.AddUint64(tid, 1) })
Functions ¶
func ClearCache ¶
func ClearCache(path string)
func PutDirectly ¶
func WalkFS ¶ added in v3.6.0
func WalkFS(ctx context.Context, depth int, name string, info model.Obj, walkFn func(reqPath string, info model.Obj) error) error
WalkFS traverses filesystem fs starting at name up to depth levels.
WalkFS will stop when current depth > `depth`. For each visited node, WalkFS calls walkFn. If a visited file system node is a directory and walkFn returns path.SkipDir, walkFS will skip traversal of this node.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.