fs

package
v4.1.9 Latest Latest
Warning

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

 Go to latest Published: Jan 1, 2026 License: AGPL-3.0 Imports: 23 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 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, skipHook ...bool) (task.TaskExtensionInfo, error)

func Get 

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

func GetDirectUploadInfo added in v4.1.7 

func GetDirectUploadInfo(ctx context.Context, tool, path, dstName string, fileSize int64) (any, 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) error

func Merge added in v4.1.8 

func Merge(ctx context.Context, srcObjPath, dstDirPath string, skipHook ...bool) (task.TaskExtensionInfo, error)

func Move 

func Move(ctx context.Context, srcPath, dstDirPath string, skipHook ...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, skipHook ...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, skipHook ...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 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

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.0.9 

func (t *ArchiveContentUploadTask) OnFailed()

func (*ArchiveContentUploadTask) OnSucceeded added in v4.0.9 

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.0.9 

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.0.9 

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

func (*FileTransferTask) GetName added in v4.0.9 

func (t *FileTransferTask) GetName() string

func (*FileTransferTask) OnFailed added in v4.0.9 

func (t *FileTransferTask) OnFailed()

func (*FileTransferTask) OnSucceeded added in v4.0.9 

func (t *FileTransferTask) OnSucceeded()

func (*FileTransferTask) Run added in v4.0.9 

func (t *FileTransferTask) Run() error

func (*FileTransferTask) RunWithNextTaskCallback added in v4.1.0 

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

func (*FileTransferTask) SetRetry added in v4.0.9 

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

type GetArgs 

type GetArgs struct {
	NoLog              bool
	WithStorageDetails bool
}

type GetStoragesArgs 

type GetStoragesArgs struct {
}

type ListArgs 

type ListArgs struct {
	Refresh            bool
	NoLog              bool
	WithStorageDetails bool
}

type TaskData added in v4.0.9 

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.0.9 

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.0.9 

func (t *UploadTask) OnFailed()

func (*UploadTask) OnSucceeded added in v4.0.9 

func (t *UploadTask) OnSucceeded()

func (*UploadTask) Run 

func (t *UploadTask) Run() error

func (*UploadTask) SetRetry added in v4.0.9 

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.