storage

Documentation

Index

• Variables
• func API_Rclone_remountAll(w http.ResponseWriter, req *http.Request)
• func CreateSinglePartition(diskPath string) (io.Reader, error)
• func CreateSnapRAID(raidOptions utils.SnapRAIDConfig, editRaid string) error
• func DeleteSnapRAID(name string) error
• func FormatDisk(diskPath string, filesystemType string) (io.Reader, error)
• func FormatDiskRoute(w http.ResponseWriter, req *http.Request)
• func GetDiskUsage(path string) (perc uint64, err error)
• func InitRemoteStorage() bool
• func InitSnapRAIDConfig()
• func IsDiskMounted(diskPath string) (bool, error)
• func ListDirectoryRoute(w http.ResponseWriter, req *http.Request)
• func ListDisksRoute(w http.ResponseWriter, req *http.Request)
• func ListMountsRoute(w http.ResponseWriter, req *http.Request)
• func ListSmartDef(w http.ResponseWriter, req *http.Request)
• func MergeRoute(w http.ResponseWriter, req *http.Request)
• func Mount(path, mountpoint string, permanent bool, chown string) error
• func MountMergerFS(paths []string, mountpoint string, opts string, permanent bool, chown string) error
• func MountRoute(w http.ResponseWriter, req *http.Request)
• func Restart()
• func RunRClone(args []string)
• func RunRCloneCommand(command []string) (*exec.Cmd, io.WriteCloser, *bytes.Buffer, *bytes.Buffer)
• func RunSnapRAIDFix(raid utils.SnapRAIDConfig) error
• func RunSnapRAIDScrub(raid utils.SnapRAIDConfig) error
• func RunSnapRAIDStatus(raid utils.SnapRAIDConfig) (string, error)
• func RunSnapRAIDSync(raid utils.SnapRAIDConfig) error
• func SNAPRaidCRUDRoute(w http.ResponseWriter, req *http.Request)
• func SnapRAIDEditRoute(w http.ResponseWriter, req *http.Request)
• func SnapRAIDRunRoute(w http.ResponseWriter, req *http.Request)
• func ToggleSnapRAID(name string, enable bool) error
• func Unmount(mountpoint string, permanent bool) error
• func UnmountRoute(w http.ResponseWriter, req *http.Request)
• type BlockDevice
  • func GetRecursiveDiskUsageAndSMARTInfo(devices []lsblk.BlockDevice) ([]BlockDevice, error)
  • func ListDisks() ([]BlockDevice, error)
• type DirectoryListing
  • func ListDirectory(path string) ([]DirectoryListing, error)
• type DiskInfo
• type FormatDiskJSON
• type MergeRequest
• type MountPoint
  • func ListMounts() ([]MountPoint, error)
• type MountRequest
• type RCloneProcess
  • func (rp *RCloneProcess) SetLastRestart(v time.Time)
  • func (rp *RCloneProcess) SetRcloneRestartCount(v int)
• type RcloneStatsObj
  • func RCloneStats() (RcloneStatsObj, error)
• type RemoteStorage
• type SMARTData
• type SnapRAIDStatus
• type StorageInfo
  • func ListStorage() ([]StorageInfo, error)

Variables

var CachedRemoteStorageList []StorageInfo

Functions

func API_Rclone_remountAll

func API_Rclone_remountAll(w http.ResponseWriter, req *http.Request)

func CreateSinglePartition

func CreateSinglePartition(diskPath string) (io.Reader, error)

func CreateSnapRAID

func CreateSnapRAID(raidOptions utils.SnapRAIDConfig, editRaid string) error

Create a SnapRAID configuration

func DeleteSnapRAID

func DeleteSnapRAID(name string) error

func FormatDisk

func FormatDisk(diskPath string, filesystemType string) (io.Reader, error)

func FormatDiskRoute

func FormatDiskRoute(w http.ResponseWriter, req *http.Request)

func GetDiskUsage

func GetDiskUsage(path string) (perc uint64, err error)

func InitRemoteStorage

func InitRemoteStorage() bool

func InitSnapRAIDConfig

func InitSnapRAIDConfig()

func IsDiskMounted

func IsDiskMounted(diskPath string) (bool, error)

check if disk is mounted

func ListDirectoryRoute

func ListDirectoryRoute(w http.ResponseWriter, req *http.Request)

func ListDisksRoute

func ListDisksRoute(w http.ResponseWriter, req *http.Request)

func ListMountsRoute

func ListMountsRoute(w http.ResponseWriter, req *http.Request)

func ListSmartDef

func ListSmartDef(w http.ResponseWriter, req *http.Request)

func MergeRoute

func MergeRoute(w http.ResponseWriter, req *http.Request)

MergeRoute handles merging filesystem requests

func Mount

func Mount(path, mountpoint string, permanent bool, chown string) error

Mount mounts a filesystem located at 'path' to 'mountpoint'.

func MountMergerFS

func MountMergerFS(paths []string, mountpoint string, opts string, permanent bool, chown string) error

Mount mounts a filesystem located at 'path' to 'mountpoint'.

func MountRoute

func MountRoute(w http.ResponseWriter, req *http.Request)

MountRoute handles mounting filesystem requests

func Restart

func Restart()

func RunRClone

func RunRClone(args []string)

func RunRCloneCommand

func RunRCloneCommand(command []string) (*exec.Cmd, io.WriteCloser, *bytes.Buffer, *bytes.Buffer)

func RunSnapRAIDFix

func RunSnapRAIDFix(raid utils.SnapRAIDConfig) error

func RunSnapRAIDScrub

func RunSnapRAIDScrub(raid utils.SnapRAIDConfig) error

func RunSnapRAIDStatus

func RunSnapRAIDStatus(raid utils.SnapRAIDConfig) (string, error)

func RunSnapRAIDSync

func RunSnapRAIDSync(raid utils.SnapRAIDConfig) error

func SNAPRaidCRUDRoute

func SNAPRaidCRUDRoute(w http.ResponseWriter, req *http.Request)

func SnapRAIDEditRoute

func SnapRAIDEditRoute(w http.ResponseWriter, req *http.Request)

func SnapRAIDRunRoute

func SnapRAIDRunRoute(w http.ResponseWriter, req *http.Request)

UnmountRoute handles unmounting filesystem requests

func ToggleSnapRAID

func ToggleSnapRAID(name string, enable bool) error

func Unmount

func Unmount(mountpoint string, permanent bool) error

Unmount unmounts the filesystem at 'mountpoint'.

func UnmountRoute

func UnmountRoute(w http.ResponseWriter, req *http.Request)

UnmountRoute handles unmounting filesystem requests

Types

type BlockDevice

type BlockDevice struct {
	lsblk.BlockDevice
	Children []BlockDevice `json:"children"`
	Usage    uint64        `json:"usage"`
	SMART    SMARTData     `json:"smart"` // Add SMART data field
}

func GetRecursiveDiskUsageAndSMARTInfo

func GetRecursiveDiskUsageAndSMARTInfo(devices []lsblk.BlockDevice) ([]BlockDevice, error)

Function to get recursive disk usage and SMART information

func ListDisks

func ListDisks() ([]BlockDevice, error)

type DirectoryListing

type DirectoryListing struct {
	Name     string `json:"name"`
	Type     string `json:"type"`
	Size     int64  `json:"size"`
	IsDir    bool   `json:"isDir"`
	Ext      string `json:"ext"`
	Created  int64  `json:"created"`
	UID      uint32 `json:"uid"`
	GID      uint32 `json:"gid"`
	FullPath string `json:"fullPath"`
}

func ListDirectory

func ListDirectory(path string) ([]DirectoryListing, error)

type DiskInfo

type DiskInfo struct {
	Path string
	Name string
	Size uint64
	Used uint64
}

type FormatDiskJSON

type FormatDiskJSON struct {
	Disk     string `json:"disk"`
	Format   string `json:"format"`
	Password string `json:"password"`
}

type MergeRequest

type MergeRequest struct {
	Branches   []string `json:"branches"`
	MountPoint string   `json:"mountPoint"`
	Permanent  bool     `json:"permanent"`
	Chown      string   `json:"chown"`
	Opts       string   `json:"opts"`
}

Assuming the structure for the mount/unmount request

type MountPoint

type MountPoint struct {
	Path      string   `json:"path"`
	Permenant bool     `json:"permenant"`
	Device    string   `json:"device"`
	Type      string   `json:"type"`
	Opts      []string `json:"opts"`
}

func ListMounts

func ListMounts() ([]MountPoint, error)

ListMounts lists all the mount points on the system

type MountRequest

type MountRequest struct {
	Path       string `json:"path"`
	MountPoint string `json:"mountPoint"`
	Permanent  bool   `json:"permanent"`
	Chown      string `json:"chown"`
}

Assuming the structure for the mount/unmount request

type RCloneProcess

type RCloneProcess struct {
	RcloneCmd     *exec.Cmd
	RcloneRestart chan bool
	RestartCount  int
	LastRestart   time.Time
	Main          bool
}

func (*RCloneProcess) SetLastRestart

func (rp *RCloneProcess) SetLastRestart(v time.Time)

func (*RCloneProcess) SetRcloneRestartCount

func (rp *RCloneProcess) SetRcloneRestartCount(v int)

type RcloneStatsObj

type RcloneStatsObj struct {
	Bytes  float64
	Errors float64
}

func RCloneStats

func RCloneStats() (RcloneStatsObj, error)

type RemoteStorage

type RemoteStorage struct {
	Name  string
	Chown string
}

type SMARTData

type SMARTData struct {
	smart.GenericAttributes

	AdditionalData interface{}
	Thresholds     interface{}
}

type SnapRAIDStatus

type SnapRAIDStatus struct {
	utils.SnapRAIDConfig
	Status string
}

type StorageInfo

type StorageInfo struct {
	Name string `json:"name"`
	Path string `json:"path"`
}

func ListStorage

func ListStorage() ([]StorageInfo, error)