operations

package
v0.4.0 Latest Latest
Warning

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

Go to latest
Published: Nov 6, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AlluxioFileUtils

type AlluxioFileUtils struct {
	// contains filtered or unexported fields
}

func NewAlluxioFileUtils

func NewAlluxioFileUtils(podName string, containerName string, namespace string, log logr.Logger) AlluxioFileUtils

func (AlluxioFileUtils) CachedState

func (a AlluxioFileUtils) CachedState() (cached int64, err error)

func (AlluxioFileUtils) CleanCache

func (a AlluxioFileUtils) CleanCache(path string) (err error)

clean cache with a preset timeout of 60s

func (AlluxioFileUtils) Count

func (a AlluxioFileUtils) Count(alluxioPath string) (fileCount int64, folderCount int64, total int64, err error)

The count of the Alluxio Filesystem

func (AlluxioFileUtils) Du

func (a AlluxioFileUtils) Du(alluxioPath string) (ufs int64, cached int64, cachedPercentage string, err error)

func (AlluxioFileUtils) GetConf added in v0.4.0

func (a AlluxioFileUtils) GetConf(key string) (value string, err error)

Get Conf info of the Alluxio Engine

func (AlluxioFileUtils) IsExist

func (a AlluxioFileUtils) IsExist(alluxioPath string) (found bool, err error)

IsExist checks if the alluxioPath exists

func (AlluxioFileUtils) IsMounted

func (a AlluxioFileUtils) IsMounted(alluxioPath string) (mounted bool, err error)

func (AlluxioFileUtils) LoadMetaData

func (a AlluxioFileUtils) LoadMetaData(alluxioPath string, sync bool) (err error)

LoadMetaData loads the metadata.

func (AlluxioFileUtils) LoadMetadataWithoutTimeout added in v0.4.0

func (a AlluxioFileUtils) LoadMetadataWithoutTimeout(alluxioPath string) (err error)

Load the metadata without timeout

func (AlluxioFileUtils) Mkdir

func (a AlluxioFileUtils) Mkdir(alluxioPath string) (err error)

func (AlluxioFileUtils) Mount

func (a AlluxioFileUtils) Mount(alluxioPath string,
	ufsPath string,
	options map[string]string,
	readOnly bool,
	shared bool) (err error)

func (AlluxioFileUtils) Ready

func (a AlluxioFileUtils) Ready() (ready bool)

Check if the Alluxio is ready by running `alluxio fsadmin report` command

func (AlluxioFileUtils) ReportSummary added in v0.4.0

func (a AlluxioFileUtils) ReportSummary() (summary string, err error)

Get summary info of the Alluxio Engine

func (AlluxioFileUtils) SyncLocalDir added in v0.3.0

func (a AlluxioFileUtils) SyncLocalDir(path string) (err error)

* Sync local path by running command `du -sh <path>`. * Under the circumstance where some NAS(e.g. NFS) is mounted on the `<path>`, the function will sync metadata of all files in the NAS. * This is necessary for Alluxio to get consistent file metadata with UFS(i.e. NAS in this case).

Jump to

Keyboard shortcuts

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