fs

package

Go to main page

Versions in this module

v0

v0.14.7-rc1

May 10, 2023

v0.14.6

Mar 23, 2023

Changes in this version

type FileSystemService

+ func (s *FileSystemService) SessionToken(username, fsName string) (*GetStsResponse, error)

+ type GetSessionRequest struct

+ FsName string

+ Username string

+ type GetStsResponse struct

+ AccessKeyId string

+ Bucket string

+ CreateTime string

+ Duration int

+ Endpoint string

+ Expiration string

+ Region string

+ SecretAccessKey string

+ SessionToken string

+ SubPath string

+ UserId string

v0.14.6-beta0

Nov 24, 2022

v0.14.5

Nov 4, 2022

Changes in this version

+ const MaxMountPodCpuLimit

+ const MaxMountPodMemLimit

+ func MountPodController(mountPodExpire, interval time.Duration, stopChan chan struct{})

type CreateFileSystemCacheRequest

+ BlockSize int

+ CacheDir string

+ CleanCache bool

+ Debug bool

+ ExtraConfig map[string]string

+ FsID string

+ MetaDriver string

+ NodeTaintToleration map[string]interface{}

+ Quota int

+ Resource model.ResourceLimit

type FileSystemCacheResponse

+ CleanCache bool

+ Resource model.ResourceLimit

v0.14.4

Sep 9, 2022

v0.14.3

Sep 1, 2022

Changes in this version

+ func CleanMountPodController(mountPodExpire, cleanMountPodIntervalTime time.Duration, ...)

type CreateFileSystemRequest

+ IndependentMountProcess bool

type FileSystemResponse

+ IndependentMountProcess bool

type FileSystemService

+ func (s *FileSystemService) CheckFsMountedAndCleanResources(fsID string) (bool, error)

+ func (s *FileSystemService) HasFsPermission(username, fsID string) (bool, error)

v0.14.2

Jun 1, 2022

Changes in this version

+ const TimeFormat

+ func CreateFileSystemCacheConfig(ctx *logger.RequestContext, req CreateFileSystemCacheRequest) error

+ func CreateMount(ctx *logger.RequestContext, req CreateMountRequest) error

+ func DeleteFileSystemCacheConfig(ctx *logger.RequestContext, fsID string) error

+ func DeleteMount(ctx *logger.RequestContext, req DeleteMountRequest) error

+ func GetCacheID(clusterID, nodeName, CacheDir string) string

+ func GetMountID(clusterID, nodeName, mountPoint string) string

+ func ListMount(ctx *logger.RequestContext, req ListMountRequest) ([]models.FsMount, string, error)

+ func ReportCache(ctx *logger.RequestContext, req CacheReportRequest) error

+ func UpdateFileSystemCacheConfig(ctx *logger.RequestContext, req UpdateFileSystemCacheRequest) error

+ type CacheReportRequest struct

+ CacheDir string

+ ClusterID string

+ FsName string

+ NodeName string

+ UsedSize int

+ Username string

+ type CreateFileSystemCacheRequest struct

+ FsName string

+ Username string

+ type CreateFileSystemClaimsRequest struct

+ FsIDs []string

+ Namespaces []string

+ type CreateFileSystemClaimsResponse struct

+ Message string

+ type CreateFileSystemRequest struct

+ Name string

+ Properties map[string]string

+ Url string

+ Username string

+ type CreateFileSystemResponse struct

+ FsID string

+ FsName string

+ type CreateLinkRequest struct

+ FsName string

+ FsPath string

+ Properties map[string]string

+ Url string

+ Username string

+ type CreateMountRequest struct

+ ClusterID string

+ FsName string

+ MountPoint string

+ NodeName string

+ Username string

+ type DeleteFileSystemRequest struct

+ FsName string

+ Username string

+ type DeleteLinkRequest struct

+ FsName string

+ FsPath string

+ Username string

+ type DeleteMountRequest struct

+ ClusterID string

+ FsName string

+ MountPoint string

+ NodeName string

+ Username string

+ type FileSystemCacheResponse struct

+ BlockSize int

+ CacheDir string

+ CreateTime string

+ ExtraConfig map[string]string

+ FsName string

+ MetaDriver string

+ NodeAffinity map[string]interface{}

+ NodeTaintToleration map[string]interface{}

+ Quota int

+ UpdateTime string

+ Username string

+ func GetFileSystemCacheConfig(ctx *logger.RequestContext, fsID string) (FileSystemCacheResponse, error)

+ type FileSystemResponse struct

+ Id string

+ Name string

+ Properties map[string]string

+ ServerAddress string

+ SubPath string

+ Type string

+ Username string

+ type FileSystemService struct

+ func GetFileSystemService() *FileSystemService

+ func (s *FileSystemService) CreateFileSystem(ctx *logger.RequestContext, req *CreateFileSystemRequest) (models.FileSystem, error)

+ func (s *FileSystemService) CreateFileSystemClaims(ctx *logger.RequestContext, req *CreateFileSystemClaimsRequest) error

+ func (s *FileSystemService) DeleteFileSystem(ctx *logger.RequestContext, fsID string) error

+ func (s *FileSystemService) GetFileSystem(fsID string) (models.FileSystem, error)

+ func (s *FileSystemService) ListFileSystem(ctx *logger.RequestContext, req *ListFileSystemRequest) ([]models.FileSystem, string, error)

+ type GetFileSystemRequest struct

+ FsName string

+ Username string

+ type GetFileSystemResponse struct

+ Id string

+ Name string

+ Properties map[string]string

+ ServerAddress string

+ SubPath string

+ Type string

+ Username string

+ type GetLinkRequest struct

+ FsID string

+ FsPath string

+ Marker string

+ MaxKeys int32

+ type GetLinkResponse struct

+ LinkList []*LinkResponse

+ Marker string

+ NextMarker string

+ Truncated bool

+ type LinkResponse struct

+ FsName string

+ FsPath string

+ Properties map[string]string

+ ServerAddress string

+ SubPath string

+ Type string

+ Username string

+ type LinkService struct

+ func GetLinkService() *LinkService

+ func (s *LinkService) CreateLink(ctx *logger.RequestContext, req *CreateLinkRequest) (models.Link, error)

+ func (s *LinkService) DeleteLink(ctx *logger.RequestContext, req *DeleteLinkRequest) error

+ func (s *LinkService) FsLock(fsID string) func()

+ func (s *LinkService) GetLink(req *GetLinkRequest) ([]models.Link, string, error)

+ func (s *LinkService) PersistLinksMeta(fsID string) error

+ type ListFileSystemRequest struct

+ FsName string

+ Marker string

+ MaxKeys int32

+ Username string

+ type ListFileSystemResponse struct

+ FsList []*FileSystemResponse

+ Marker string

+ NextMarker string

+ Truncated bool

+ type ListMountRequest struct

+ ClusterID string

+ FsName string

+ Marker string

+ MaxKeys int32

+ NodeName string

+ Username string

+ type ListMountResponse struct

+ Marker string

+ MountList []*MountResponse

+ NextMarker string

+ Truncated bool

+ type MountResponse struct

+ ClusterID string

+ FsID string

+ MountID string

+ MountPoint string

+ NodeName string

+ type UpdateFileSystemCacheRequest struct

+ BlockSize int

+ CacheDir string

+ Debug bool

+ ExtraConfig map[string]string

+ FsID string

+ MetaDriver string

+ NodeAffinity map[string]interface{}

+ NodeTaintToleration map[string]interface{}

+ Quota int

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL