op

package
v3.46.0 Latest Latest
Warning

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

 Go to latest Published: Jul 26, 2025 License: AGPL-3.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	WORK     = "work"
	DISABLED = "disabled"
	RootName = "root"
)

Variables

This section is empty.

Functions

func ArchiveDecompress added in v3.42.0 

func ArchiveDecompress(ctx context.Context, storage driver.Driver, srcPath, dstDirPath string, args model.ArchiveDecompressArgs, lazyCache ...bool) error

func ArchiveGet added in v3.42.0 

func ArchiveGet(ctx context.Context, storage driver.Driver, path string, args model.ArchiveListArgs) (model.Obj, model.Obj, error)

func Cancel2FAById added in v3.7.1 

func Cancel2FAById(id uint) error

func Cancel2FAByUser added in v3.7.1 

func Cancel2FAByUser(u *model.User) error

func ClearCache 

func ClearCache(storage driver.Driver, path string)

func Copy 

func Copy(ctx context.Context, storage driver.Driver, srcPath, dstDirPath string, lazyCache ...bool) error

Copy Just copy file[s] in a storage

func CreateLabelFileBinDing added in v3.46.0 

func CreateLabelFileBinDing(req CreateLabelFileBinDingReq, userId uint) error

func CreateMeta added in v3.7.1 

func CreateMeta(u *model.Meta) error

func CreateRole added in v3.46.0 

func CreateRole(r *model.Role) error

func CreateSSHPublicKey added in v3.42.0 

func CreateSSHPublicKey(k *model.SSHPublicKey) (error, bool)

func CreateStorage 

func CreateStorage(ctx context.Context, storage model.Storage) (uint, error)

CreateStorage Save the storage to database so storage can get an id then instantiate corresponding driver and save it in memory

func CreateUser added in v3.7.1 

func CreateUser(u *model.User) error

func DelUserCache added in v3.25.0 

func DelUserCache(username string) error

func DeleteLabelById added in v3.46.0 

func DeleteLabelById(ctx context.Context, id, userId uint) error

func DeleteMetaById added in v3.7.1 

func DeleteMetaById(id uint) error

func DeleteRole added in v3.46.0 

func DeleteRole(id uint) error

func DeleteSSHPublicKeyById added in v3.42.0 

func DeleteSSHPublicKeyById(keyId uint) error

func DeleteSettingItemByKey added in v3.7.1 

func DeleteSettingItemByKey(key string) error

func DeleteStorageById 

func DeleteStorageById(ctx context.Context, id uint) error

func DeleteUserById added in v3.7.1 

func DeleteUserById(id uint) error

func DisableStorage 

func DisableStorage(ctx context.Context, id uint) error

func DriverExtract added in v3.42.0 

func DriverExtract(ctx context.Context, storage driver.Driver, path string, args model.ArchiveInnerArgs) (*model.Link, model.Obj, error)

func EnableStorage 

func EnableStorage(ctx context.Context, id uint) error

func Get 

func Get(ctx context.Context, storage driver.Driver, path string) (model.Obj, error)

Get object from list of files

func GetAdmin added in v3.7.1 

func GetAdmin() (*model.User, error)

func GetAllStorages added in v3.7.1 

func GetAllStorages() []driver.Driver

func GetArchiveMeta added in v3.42.0 

func GetArchiveMeta(ctx context.Context, storage driver.Driver, path string, args model.ArchiveMetaArgs) (*model.ArchiveMetaProvider, error)

func GetArchiveToolAndStream added in v3.44.0 

func GetArchiveToolAndStream(ctx context.Context, storage driver.Driver, path string, args model.LinkArgs) (model.Obj, tool.Tool, []*stream.SeekableStream, error)

func GetBalancedStorage 

func GetBalancedStorage(path string) driver.Driver

GetBalancedStorage get storage by path

func GetDriverInfoMap 

func GetDriverInfoMap() map[string]driver.Info

func GetDriverNames 

func GetDriverNames() []string

func GetGuest added in v3.7.1 

func GetGuest() (*model.User, error)

func GetLabelByFileName added in v3.46.0 

func GetLabelByFileName(userId uint, fileName string) ([]model.Label, error)

func GetMetaById added in v3.7.1 

func GetMetaById(id uint) (*model.Meta, error)

func GetMetaByPath added in v3.7.1 

func GetMetaByPath(path string) (*model.Meta, error)

func GetMetas added in v3.7.1 

func GetMetas(pageIndex, pageSize int) (metas []model.Meta, count int64, err error)

func GetNearestMeta added in v3.7.1 

func GetNearestMeta(path string) (*model.Meta, error)

func GetPublicSettingItems added in v3.7.1 

func GetPublicSettingItems() ([]model.SettingItem, error)

func GetPublicSettingsMap added in v3.7.1 

func GetPublicSettingsMap() map[string]string

func GetRole added in v3.46.0 

func GetRole(id uint) (*model.Role, error)

func GetRoleByName added in v3.46.0 

func GetRoleByName(name string) (*model.Role, error)

func GetRoles added in v3.46.0 

func GetRoles(pageIndex, pageSize int) ([]model.Role, int64, error)

func GetRolesByUserID added in v3.46.0 

func GetRolesByUserID(userID uint) ([]model.Role, error)

func GetSSHPublicKeyByIdAndUserId added in v3.42.0 

func GetSSHPublicKeyByIdAndUserId(id uint, userId uint) (*model.SSHPublicKey, error)

func GetSSHPublicKeyByUserId added in v3.42.0 

func GetSSHPublicKeyByUserId(userId uint, pageIndex, pageSize int) (keys []model.SSHPublicKey, count int64, err error)

func GetSettingItemByKey added in v3.7.1 

func GetSettingItemByKey(key string) (*model.SettingItem, error)

func GetSettingItemInKeys added in v3.7.1 

func GetSettingItemInKeys(keys []string) ([]model.SettingItem, error)

func GetSettingItems added in v3.7.1 

func GetSettingItems() ([]model.SettingItem, error)

func GetSettingItemsByGroup added in v3.7.1 

func GetSettingItemsByGroup(group int) ([]model.SettingItem, error)

func GetSettingItemsInGroups added in v3.7.1 

func GetSettingItemsInGroups(groups []int) ([]model.SettingItem, error)

func GetSettingsMap added in v3.7.1 

func GetSettingsMap() map[string]string

func GetStorageAndActualPath 

func GetStorageAndActualPath(rawPath string) (storage driver.Driver, actualPath string, err error)

GetStorageAndActualPath Get the corresponding storage and actual path for path: remove the mount path prefix and join the actual root folder if exists

func GetStorageByMountPath added in v3.7.1 

func GetStorageByMountPath(mountPath string) (driver.Driver, error)

func GetStorageVirtualFilesByPath 

func GetStorageVirtualFilesByPath(prefix string) []model.Obj

GetStorageVirtualFilesByPath Obtain the virtual file generated by the storage according to the path for example, there are: /a/b,/a/c,/a/d/e,/a/b.balance1,/av GetStorageVirtualFilesByPath(/a) => b,c,d

func GetUnwrap added in v3.7.1 

func GetUnwrap(ctx context.Context, storage driver.Driver, path string) (model.Obj, error)

func GetUserById added in v3.7.1 

func GetUserById(id uint) (*model.User, error)

func GetUserByName added in v3.7.1 

func GetUserByName(username string) (*model.User, error)

func GetUserByRole added in v3.7.1 

func GetUserByRole(role int) (*model.User, error)

func GetUsers added in v3.7.1 

func GetUsers(pageIndex, pageSize int) (users []model.User, count int64, err error)

func HandleObjsUpdateHook added in v3.7.1 

func HandleObjsUpdateHook(parent string, objs []model.Obj)

func HandleSettingItemHook added in v3.7.1 

func HandleSettingItemHook(item *model.SettingItem) (hasHook bool, err error)

func HasStorage added in v3.7.1 

func HasStorage(mountPath string) bool

func InternalExtract added in v3.42.0 

func InternalExtract(ctx context.Context, storage driver.Driver, path string, args model.ArchiveInnerArgs) (io.ReadCloser, int64, error)

func Key 

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

Link get link, if is an url. should have an expiry time

func List 

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

List files in storage, not contains virtual file

func ListArchive added in v3.42.0 

func ListArchive(ctx context.Context, storage driver.Driver, path string, args model.ArchiveListArgs) ([]model.Obj, error)

func LoadStorage 

func LoadStorage(ctx context.Context, storage model.Storage) error

LoadStorage load exist storage in db to memory

func MakeDir 

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

func Move 

func Move(ctx context.Context, storage driver.Driver, srcPath, dstDirPath string, lazyCache ...bool) error

func MustSaveDriverStorage 

func MustSaveDriverStorage(driver driver.Driver)

MustSaveDriverStorage call from specific driver

func Other 

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

Other api

func Put 

func Put(ctx context.Context, storage driver.Driver, dstDirPath string, file model.FileStreamer, up driver.UpdateProgress, lazyCache ...bool) error

func PutURL added in v3.42.0 

func PutURL(ctx context.Context, storage driver.Driver, dstDirPath, dstName, url string, lazyCache ...bool) error

func RegisterDriver 

func RegisterDriver(driver DriverConstructor)

func RegisterObjsUpdateHook added in v3.6.0 

func RegisterObjsUpdateHook(hook ObjsUpdateHook)

func RegisterSettingChangingCallback added in v3.43.0 

func RegisterSettingChangingCallback(f func())

func RegisterSettingItemHook added in v3.7.1 

func RegisterSettingItemHook(key string, hook SettingItemHook)

func RegisterStorageHook added in v3.7.1 

func RegisterStorageHook(hook StorageHook)

func Remove 

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

func Rename 

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

func SaveSettingItem added in v3.7.1 

func SaveSettingItem(item *model.SettingItem) (err error)

func SaveSettingItems added in v3.7.1 

func SaveSettingItems(items []model.SettingItem) error

func SettingCacheUpdate added in v3.42.0 

func SettingCacheUpdate()

func StringSliceToUintSlice added in v3.46.0 

func StringSliceToUintSlice(strSlice []string) ([]uint, error)

func UpdateMeta added in v3.7.1 

func UpdateMeta(u *model.Meta) error

func UpdateRole added in v3.46.0 

func UpdateRole(r *model.Role) error

func UpdateSSHPublicKey added in v3.42.0 

func UpdateSSHPublicKey(k *model.SSHPublicKey) error

func UpdateStorage 

func UpdateStorage(ctx context.Context, storage model.Storage) error

UpdateStorage update storage get old storage first drop the storage then reinitialize

func UpdateUser added in v3.7.1 

func UpdateUser(u *model.User) error

Types

type CreateLabelFileBinDingReq added in v3.46.0 

type CreateLabelFileBinDingReq struct {
	Id          string    `json:"id"`
	Path        string    `json:"path"`
	Name        string    `json:"name"`
	Size        int64     `json:"size"`
	IsDir       bool      `json:"is_dir"`
	Modified    time.Time `json:"modified"`
	Created     time.Time `json:"created"`
	Sign        string    `json:"sign"`
	Thumb       string    `json:"thumb"`
	Type        int       `json:"type"`
	HashInfoStr string    `json:"hashinfo"`
	LabelIds    string    `json:"label_ids"`
}

type DriverConstructor added in v3.25.0 

type DriverConstructor func() driver.Driver

func GetDriver added in v3.25.0 

func GetDriver(name string) (DriverConstructor, error)

type ObjLabelResp added in v3.46.0 

type ObjLabelResp struct {
	Id          string        `json:"id"`
	Path        string        `json:"path"`
	Name        string        `json:"name"`
	Size        int64         `json:"size"`
	IsDir       bool          `json:"is_dir"`
	Modified    time.Time     `json:"modified"`
	Created     time.Time     `json:"created"`
	Sign        string        `json:"sign"`
	Thumb       string        `json:"thumb"`
	Type        int           `json:"type"`
	HashInfoStr string        `json:"hashinfo"`
	LabelList   []model.Label `json:"label_list"`
}

func GetFileByLabel added in v3.46.0 

func GetFileByLabel(userId uint, labelId string) (result []ObjLabelResp, err error)

type ObjsUpdateHook added in v3.6.0 

type ObjsUpdateHook = func(parent string, objs []model.Obj)

Obj

type SettingItemHook added in v3.7.1 

type SettingItemHook func(item *model.SettingItem) error

Setting

type StorageHook added in v3.7.1 

type StorageHook func(typ string, storage driver.Driver)

Storage

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.