fs

package
v3.57.0 Latest Latest
Warning

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

 Go to latest Published: Feb 4, 2026 License: AGPL-3.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ArchiveContentUploadTaskManager = &archiveContentUploadTaskManagerType{
	Manager: nil,
}
View Source 
var ArchiveDownloadTaskManager *tache.Manager[*ArchiveDownloadTask]
View Source 
var CopyTaskManager *tache.Manager[*CopyTask]
View Source 
var S3TransitionTaskManager *tache.Manager[*S3TransitionTask]

S3TransitionTaskManager holds asynchronous S3 archive/thaw tasks.

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

Functions

func ArchiveDecompress added in v3.42.0 

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

func ArchiveDriverExtract added in v3.42.0 

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

func ArchiveInternalExtract added in v3.42.0 

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

func ArchiveList added in v3.42.0 

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

func ArchiveMeta added in v3.42.0 

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) 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 added in v3.44.0 

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

type ArchiveContentUploadTask added in v3.42.0 

type ArchiveContentUploadTask struct {
	task.TaskExtension

	ObjName    string
	InPlace    bool
	FilePath   string
	DstDirPath string

	DstStorageMp string
	// contains filtered or unexported fields
}

func (*ArchiveContentUploadTask) Cancel added in v3.42.0 

func (t *ArchiveContentUploadTask) Cancel()

func (*ArchiveContentUploadTask) GetName added in v3.42.0 

func (t *ArchiveContentUploadTask) GetName() string

func (*ArchiveContentUploadTask) GetStatus added in v3.42.0 

func (t *ArchiveContentUploadTask) GetStatus() string

func (*ArchiveContentUploadTask) Run added in v3.42.0 

func (t *ArchiveContentUploadTask) Run() error

func (*ArchiveContentUploadTask) RunWithNextTaskCallback added in v3.42.0 

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

type ArchiveDownloadTask added in v3.42.0 

type ArchiveDownloadTask struct {
	task.TaskExtension
	model.ArchiveDecompressArgs

	SrcObjPath string
	DstDirPath string

	SrcStorageMp string
	DstStorageMp string
	// contains filtered or unexported fields
}

func (*ArchiveDownloadTask) GetName added in v3.42.0 

func (t *ArchiveDownloadTask) GetName() string

func (*ArchiveDownloadTask) GetStatus added in v3.42.0 

func (t *ArchiveDownloadTask) GetStatus() string

func (*ArchiveDownloadTask) Run added in v3.42.0 

func (t *ArchiveDownloadTask) Run() error

func (*ArchiveDownloadTask) RunWithoutPushUploadTask added in v3.42.0 

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

type CopyTask added in v3.29.0 

type CopyTask struct {
	task.TaskExtension
	Status     string `json:"-"` //don't save status to save space
	SrcObjPath string `json:"src_path"`
	DstDirPath string `json:"dst_path"`

	SrcStorageMp string `json:"src_storage_mp"`
	DstStorageMp string `json:"dst_storage_mp"`
	// contains filtered or unexported fields
}

func (*CopyTask) GetName added in v3.29.0 

func (t *CopyTask) GetName() string

func (*CopyTask) GetStatus added in v3.29.0 

func (t *CopyTask) GetStatus() string

func (*CopyTask) Run added in v3.29.0 

func (t *CopyTask) Run() error

type GetArgs added in v3.15.1 

type GetArgs struct {
	NoLog bool
}

type GetStoragesArgs added in v3.15.1 

type GetStoragesArgs struct {
}

type ListArgs added in v3.15.1 

type ListArgs struct {
	Refresh bool
	NoLog   bool
}

type S3TransitionTask added in v3.54.0 

type S3TransitionTask struct {
	task.TaskExtension

	StorageMountPath string          `json:"storage_mount_path"`
	ObjectPath       string          `json:"object_path"`
	DisplayPath      string          `json:"display_path"`
	ObjectName       string          `json:"object_name"`
	Transition       string          `json:"transition"`
	Payload          json.RawMessage `json:"payload,omitempty"`

	TargetStorageClass string `json:"target_storage_class,omitempty"`
	RequestID          string `json:"request_id,omitempty"`
	VersionID          string `json:"version_id,omitempty"`
	// contains filtered or unexported fields
}

S3TransitionTask represents an asynchronous S3 archive/thaw request that is tracked via the task manager so that clients can monitor the progress of the operation.

func (*S3TransitionTask) GetName added in v3.54.0 

func (t *S3TransitionTask) GetName() string

func (*S3TransitionTask) GetStatus added in v3.54.0 

func (t *S3TransitionTask) GetStatus() string

func (*S3TransitionTask) OnRestore added in v3.54.0 

func (t *S3TransitionTask) OnRestore()

Ensure compatibility with persistence when tasks are restored.

func (*S3TransitionTask) Run added in v3.54.0 

func (t *S3TransitionTask) Run() error

type UploadTask added in v3.29.0 

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

func (*UploadTask) GetName added in v3.29.0 

func (t *UploadTask) GetName() string

func (*UploadTask) GetStatus added in v3.29.0 

func (t *UploadTask) GetStatus() string

func (*UploadTask) Run added in v3.29.0 

func (t *UploadTask) Run() error

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.