fs

package
v4.3.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 8, 2025 License: AGPL-3.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CopyTaskManager *tache.Manager[*FileTransferTask]
	MoveTaskManager *tache.Manager[*FileTransferTask]
)
View Source 
var ArchiveContentUploadTaskManager = &archiveContentUploadTaskManagerType{
	Manager: nil,
}
View Source 
var ArchiveDownloadTaskManager *tache.Manager[*ArchiveDownloadTask]
View Source 
var ErrWalkFailed = errs.New("walk failed")

ErrWalkFailed 遍历失败错误

View Source 
var UploadTaskManager *tache.Manager[*UploadTask]

Functions

func ArchiveDecompress 

func ArchiveDecompress(ctx context.Context, srcObjPath, dstDirPath string, args model.ArchiveDecompressArgs, lazyCache ...bool) (task.TaskExtensionInfo, error)

func ArchiveDriverExtract 

func ArchiveDriverExtract(ctx context.Context, path string, args model.ArchiveInnerArgs) (*model.Link, model.Obj, error)

func ArchiveInternalExtract 

func ArchiveInternalExtract(ctx context.Context, path string, args model.ArchiveInnerArgs) (io.ReadCloser, int64, error)

func ArchiveList 

func ArchiveList(ctx context.Context, path string, args model.ArchiveListArgs) ([]model.Obj, error)

func ArchiveMeta 

func ArchiveMeta(ctx context.Context, path string, args model.ArchiveMetaArgs) (*model.ArchiveMetaProvider, error)

func Copy 

func Copy(ctx context.Context, srcObjPath, dstDirPath string, lazyCache ...bool) (task.TaskExtensionInfo, error)

func Get 

func Get(ctx context.Context, path string, args *GetArgs) (model.Obj, error)

func GetStorage 

func GetStorage(path string, args *GetStoragesArgs) (driver.Driver, error)
func Link(ctx context.Context, path string, args model.LinkArgs) (*model.Link, model.Obj, error)

func List 

func List(ctx context.Context, path string, args *ListArgs) ([]model.Obj, error)

func MakeDir 

func MakeDir(ctx context.Context, path string, lazyCache ...bool) error

func Move 

func Move(ctx context.Context, srcPath, dstDirPath string, lazyCache ...bool) (task.TaskExtensionInfo, error)

func Other 

func Other(ctx context.Context, args model.FsOtherArgs) (interface{}, error)

func PutAsTask 

func PutAsTask(ctx context.Context, dstDirPath string, file model.FileStreamer) (task.TaskExtensionInfo, error)

func PutDirectly 

func PutDirectly(ctx context.Context, dstDirPath string, file model.FileStreamer, lazyCache ...bool) error

func PutURL 

func PutURL(ctx context.Context, path, dstName, urlStr string) error

func Remove 

func Remove(ctx context.Context, path string) error

func Rename 

func Rename(ctx context.Context, srcPath, dstName string, lazyCache ...bool) error

func WalkFS 

func WalkFS(ctx context.Context, depth int, name string, info model.Obj, walkFn func(reqPath string, info model.Obj) error) error

WalkFS 遍历文件系统，从指定名称开始，最多遍历到指定深度

WalkFS 在当前深度 > `depth` 时停止。对于每个访问的节点， WalkFS 调用 walkFn。如果访问的文件系统节点是一个目录，并且 walkFn 返回 path.SkipDir，walkFS 将跳过该节点的遍历。

参数:

  • ctx: 上下文
  • depth: 最大遍历深度
  • name: 起始路径
  • info: 起始对象信息
  • walkFn: 遍历回调函数

返回:

  • error: 错误信息

Types

type ArchiveContentUploadTask 

type ArchiveContentUploadTask struct {
	task.TaskExtension

	ObjName       string
	InPlace       bool
	FilePath      string
	DstActualPath string

	DstStorageMp string
	// contains filtered or unexported fields
}

func (*ArchiveContentUploadTask) Cancel 

func (t *ArchiveContentUploadTask) Cancel()

func (*ArchiveContentUploadTask) GetName 

func (t *ArchiveContentUploadTask) GetName() string

func (*ArchiveContentUploadTask) GetStatus 

func (t *ArchiveContentUploadTask) GetStatus() string

func (*ArchiveContentUploadTask) OnFailed added in v4.2.7 

func (t *ArchiveContentUploadTask) OnFailed()

func (*ArchiveContentUploadTask) OnSucceeded added in v4.2.7 

func (t *ArchiveContentUploadTask) OnSucceeded()

func (*ArchiveContentUploadTask) Run 

func (t *ArchiveContentUploadTask) Run() error

func (*ArchiveContentUploadTask) RunWithNextTaskCallback 

func (t *ArchiveContentUploadTask) RunWithNextTaskCallback(f func(nextTask *ArchiveContentUploadTask) error) error

func (*ArchiveContentUploadTask) SetRetry added in v4.2.7 

func (t *ArchiveContentUploadTask) SetRetry(retry int, maxRetry int)

type ArchiveDownloadTask 

type ArchiveDownloadTask struct {
	TaskData
	model.ArchiveDecompressArgs
}

func (*ArchiveDownloadTask) GetName 

func (t *ArchiveDownloadTask) GetName() string

func (*ArchiveDownloadTask) Run 

func (t *ArchiveDownloadTask) Run() error

func (*ArchiveDownloadTask) RunWithoutPushUploadTask 

func (t *ArchiveDownloadTask) RunWithoutPushUploadTask() (*ArchiveContentUploadTask, error)

type FileTransferTask added in v4.2.7 

type FileTransferTask struct {
	TaskData
	TaskType taskType
	// contains filtered or unexported fields
}

func (*FileTransferTask) GetName added in v4.2.7 

func (t *FileTransferTask) GetName() string

func (*FileTransferTask) OnFailed added in v4.2.7 

func (t *FileTransferTask) OnFailed()

func (*FileTransferTask) OnSucceeded added in v4.2.7 

func (t *FileTransferTask) OnSucceeded()

func (*FileTransferTask) Run added in v4.2.7 

func (t *FileTransferTask) Run() error

func (*FileTransferTask) RunWithNextTaskCallback added in v4.2.9 

func (t *FileTransferTask) RunWithNextTaskCallback(f func(nextTask *FileTransferTask) error) error

func (*FileTransferTask) SetRetry added in v4.2.7 

func (t *FileTransferTask) SetRetry(retry int, maxRetry int)

type GetArgs 

type GetArgs struct {
	NoLog bool
}

type GetStoragesArgs 

type GetStoragesArgs struct {
}

type ListArgs 

type ListArgs struct {
	Refresh bool
	NoLog   bool
}

type TaskData added in v4.2.7 

type TaskData struct {
	task.TaskExtension
	Status        string        `json:"-"` // don't save status to save space
	SrcActualPath string        `json:"src_path"`
	DstActualPath string        `json:"dst_path"`
	SrcStorage    driver.Driver `json:"-"`
	DstStorage    driver.Driver `json:"-"`
	SrcStorageMp  string        `json:"src_storage_mp"`
	DstStorageMp  string        `json:"dst_storage_mp"`
}

func (*TaskData) GetStatus added in v4.2.7 

func (t *TaskData) GetStatus() string

type UploadTask 

type UploadTask struct {
	task.TaskExtension
	// contains filtered or unexported fields
}

func (*UploadTask) GetName 

func (t *UploadTask) GetName() string

func (*UploadTask) GetStatus 

func (t *UploadTask) GetStatus() string

func (*UploadTask) OnFailed added in v4.2.7 

func (t *UploadTask) OnFailed()

func (*UploadTask) OnSucceeded added in v4.2.7 

func (t *UploadTask) OnSucceeded()

func (*UploadTask) Run 

func (t *UploadTask) Run() error

func (*UploadTask) SetRetry added in v4.2.7 

func (t *UploadTask) SetRetry(retry int, maxRetry int)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.