Versions in this module Expand all Collapse all v0 v0.1.0 May 1, 2024 v0.0.1 Feb 21, 2024 Changes in this version + const BackFsLdiskfs + const BackFsZfs + const GroupID + const LogicalVolumeName + const RemoteStorageServiceId + const RemoteStorageServicePort + const StorageStatus_Disabled + const StorageStatus_Error + const StorageStatus_Ready + const StorageStatus_Starting + const TargetMDT + const TargetMGT + const TargetMGTMDT + const TargetOST + const UserID + const VolumeGroupName + var ErrServerControllerDisabled = fmt.Errorf("Server Controller Disabled") + var FileSystemRegistry fileSystemRegistry + func Initialize() error + type ConfigFile struct + FileSystems []FileSystemConfig + Metadata struct{ ... } + Version string + type DefaultServerControllerProvider struct + func (DefaultServerControllerProvider) NewServerController(opts ServerControllerOptions) ServerControllerApi + type DisabledServerController struct + func (*DisabledServerController) Connected() bool + func (*DisabledServerController) CreateFileSystem(*Storage, FileSystemApi, FileSystemOptions) error + func (*DisabledServerController) Delete(*Storage) error + func (*DisabledServerController) DeleteFileSystem(*Storage, FileSystemApi) error + func (*DisabledServerController) GetServerInfo() ServerInfo + func (*DisabledServerController) GetStatus(*Storage) (StorageStatus, error) + func (*DisabledServerController) MountFileSystem(*Storage, FileSystemApi, string) error + func (*DisabledServerController) NewStorage(uuid.UUID, []StorageNamespace) *Storage + func (*DisabledServerController) UnmountFileSystem(*Storage, FileSystemApi, string) error + type FileSystem struct + func (f *FileSystem) LoadDeviceList(devices []string) + func (f *FileSystem) Unmount(mountpoint string) error + type FileSystemApi interface + Create func(devices []string, opts FileSystemOptions) error + Delete func() error + GenerateRecoveryData func() map[string]string + IsMockable func() bool + IsType func(oem *FileSystemOem) bool + LoadDeviceList func(devices []string) + LoadRecoveryData func(data map[string]string) + MkfsDefault func() string + Mount func(mountpoint string) error + Name func() string + New func(oem FileSystemOem) (FileSystemApi, error) + Type func() string + Unmount func(mountpoint string) error + VgChangeActivateDefault func() string + type FileSystemConfig struct + Install []FileSystemInstallConfig + Name string + Operations []FileSystemOperationConfig + type FileSystemControllerApi interface + NewFileSystem func(oem *FileSystemOem) (FileSystemApi, error) + var FileSystemController FileSystemControllerApi + func NewFileSystemController(config *ConfigFile) FileSystemControllerApi + type FileSystemError struct + func (e *FileSystemError) Error() string + func (e *FileSystemError) Unwrap() error + type FileSystemGfs2 struct + MkfsMount FileSystemOemMkfsMount + Oem FileSystemOemGfs2 + func (*FileSystemGfs2) IsMockable() bool + func (*FileSystemGfs2) IsType(oem *FileSystemOem) bool + func (*FileSystemGfs2) MkfsDefault() string + func (*FileSystemGfs2) New(oem FileSystemOem) (FileSystemApi, error) + func (*FileSystemGfs2) Type() string + func (*FileSystemGfs2) VgChangeActivateDefault() string + func (f *FileSystemGfs2) Create(devices []string, opts FileSystemOptions) (err error) + func (f *FileSystemGfs2) Mount(mountpoint string) error + func (f *FileSystemGfs2) Name() string + type FileSystemInstallConfig struct + Command string + Dist string + Gpg string + type FileSystemLustre struct + MkfsMount FileSystemOemMkfsMount + Oem FileSystemOemLustre + TargetType string + ZfsArgs FileSystemOemZfs + func (*FileSystemLustre) IsMockable() bool + func (*FileSystemLustre) IsType(oem *FileSystemOem) bool + func (*FileSystemLustre) New(oem FileSystemOem) (FileSystemApi, error) + func (*FileSystemLustre) Type() string + func (f *FileSystemLustre) Create(devices []string, options FileSystemOptions) error + func (f *FileSystemLustre) Delete() error + func (f *FileSystemLustre) GenerateRecoveryData() map[string]string + func (f *FileSystemLustre) LoadRecoveryData(map[string]string) + func (f *FileSystemLustre) MkfsDefault() string + func (f *FileSystemLustre) Mount(mountpoint string) error + func (f *FileSystemLustre) Name() string + func (f *FileSystemLustre) VgChangeActivateDefault() string + type FileSystemLvm struct + CmdArgs FileSystemOemLvm + func (*FileSystemLvm) IsMockable() bool + func (*FileSystemLvm) IsType(oem *FileSystemOem) bool + func (*FileSystemLvm) New(oem FileSystemOem) (FileSystemApi, error) + func (*FileSystemLvm) Type() string + func (f *FileSystemLvm) Create(devices []string, opts FileSystemOptions) error + func (f *FileSystemLvm) Delete() error + func (f *FileSystemLvm) GenerateRecoveryData() map[string]string + func (f *FileSystemLvm) LoadRecoveryData(data map[string]string) + func (f *FileSystemLvm) MkfsDefault() string + func (f *FileSystemLvm) Mount(mountpoint string) error + func (f *FileSystemLvm) Name() string + func (f *FileSystemLvm) VgChangeActivateDefault() string + type FileSystemOem struct + Gfs2 FileSystemOemGfs2 + Lustre FileSystemOemLustre + LvmCmd FileSystemOemLvm + MkfsMount FileSystemOemMkfsMount + Name string + Type string + ZfsCmd FileSystemOemZfs + func (oem *FileSystemOem) IsEmpty() bool + func (oem *FileSystemOem) LoadDefaults(fs FileSystemApi) + type FileSystemOemGfs2 struct + ClusterName string + type FileSystemOemLustre struct + BackFs string + Index int + MgsNode string + TargetType string + type FileSystemOemLvm struct + LvCreate string + LvRemove string + PvCreate string + VgChange FileSystemOemVgChange + VgCreate string + VgRemove string + type FileSystemOemMkfsMount struct + Mkfs string + Mount []string + type FileSystemOemVgChange struct + Activate string + Deactivate string + LockStart string + type FileSystemOemZfs struct + ZpoolCreate string + type FileSystemOperationConfig struct + Arguments []string + Command string + Label string + Options []map[string]string + type FileSystemOptions = map[string]interface + type FileSystemRaw struct + func (*FileSystemRaw) IsType(oem *FileSystemOem) bool + func (*FileSystemRaw) New(oem FileSystemOem) (FileSystemApi, error) + func (*FileSystemRaw) Type() string + func (f *FileSystemRaw) Create(devices []string, opts FileSystemOptions) error + func (f *FileSystemRaw) Mount(mountpoint string) error + type FileSystemXfs struct + MkfsMount FileSystemOemMkfsMount + func (*FileSystemXfs) IsMockable() bool + func (*FileSystemXfs) IsType(oem *FileSystemOem) bool + func (*FileSystemXfs) New(oem FileSystemOem) (FileSystemApi, error) + func (*FileSystemXfs) Type() string + func (f *FileSystemXfs) Create(devices []string, opts FileSystemOptions) (err error) + func (f *FileSystemXfs) MkfsDefault() string + func (f *FileSystemXfs) Mount(mountpoint string) error + func (f *FileSystemXfs) Name() string + type FileSystemZfs struct + func (*FileSystemZfs) IsMockable() bool + func (*FileSystemZfs) IsType(oem *FileSystemOem) bool + func (*FileSystemZfs) New(oem FileSystemOem) (FileSystemApi, error) + func (*FileSystemZfs) Type() string + func (f *FileSystemZfs) Create(devices []string, options FileSystemOptions) error + func (f *FileSystemZfs) Delete() error + func (f *FileSystemZfs) GenerateRecoveryData() map[string]string + func (f *FileSystemZfs) LoadRecoveryData(map[string]string) + func (f *FileSystemZfs) MkfsDefault() string + func (f *FileSystemZfs) Mount(mountpoint string) error + func (f *FileSystemZfs) Name() string + func (f *FileSystemZfs) Unmount(mountpoint string) error + func (f *FileSystemZfs) VgChangeActivateDefault() string + type LocalServerController struct + func (c *LocalServerController) Connected() bool + func (c *LocalServerController) CreateFileSystem(s *Storage, fs FileSystemApi, opts FileSystemOptions) error + func (c *LocalServerController) Delete(s *Storage) error + func (c *LocalServerController) DeleteFileSystem(s *Storage, fs FileSystemApi) error + func (c *LocalServerController) Discover(s *Storage) error + func (c *LocalServerController) GetServerInfo() ServerInfo + func (c *LocalServerController) GetStatus(s *Storage) (StorageStatus, error) + func (c *LocalServerController) MountFileSystem(s *Storage, fs FileSystemApi, mountPoint string) error + func (c *LocalServerController) NewStorage(pid uuid.UUID, expectedNamespaces []StorageNamespace) *Storage + func (c *LocalServerController) UnmountFileSystem(s *Storage, fs FileSystemApi, mountPoint string) error + type MockServerController struct + func (*MockServerController) CreateFileSystem(s *Storage, fs FileSystemApi, opts FileSystemOptions) error + func (*MockServerController) DeleteFileSystem(s *Storage, fs FileSystemApi) error + func (*MockServerController) GetStatus(s *Storage) (StorageStatus, error) + func (*MockServerController) MountFileSystem(s *Storage, fs FileSystemApi, mountpoint string) error + func (*MockServerController) UnmountFileSystem(s *Storage, fs FileSystemApi, mountpoint string) error + func (c *MockServerController) Connected() bool + func (c *MockServerController) Delete(s *Storage) error + func (c *MockServerController) NewStorage(pid uuid.UUID, expectedNamespaces []StorageNamespace) *Storage + func (m *MockServerController) GetServerInfo() ServerInfo + type MockServerControllerProvider struct + func (MockServerControllerProvider) NewServerController(ServerControllerOptions) ServerControllerApi + type RemoteServerController struct + func (c *RemoteServerController) Connected() bool + func (c *RemoteServerController) CreateFileSystem(*Storage, FileSystemApi, FileSystemOptions) error + func (c *RemoteServerController) Delete(s *Storage) error + func (c *RemoteServerController) GetServerInfo() ServerInfo + func (c *RemoteServerController) GetStatus(s *Storage) (StorageStatus, error) + func (c *RemoteServerController) NewStorage(pid uuid.UUID, expectedNamespaces []StorageNamespace) *Storage + func (r *RemoteServerController) DeleteFileSystem(*Storage, FileSystemApi) error + func (r *RemoteServerController) MountFileSystem(*Storage, FileSystemApi, string) error + func (r *RemoteServerController) UnmountFileSystem(*Storage, FileSystemApi, string) error + type ServerControllerApi interface + Connected func() bool + CreateFileSystem func(*Storage, FileSystemApi, FileSystemOptions) error + Delete func(*Storage) error + DeleteFileSystem func(*Storage, FileSystemApi) error + GetServerInfo func() ServerInfo + GetStatus func(*Storage) (StorageStatus, error) + MountFileSystem func(*Storage, FileSystemApi, string) error + NewStorage func(uuid.UUID, []StorageNamespace) *Storage + UnmountFileSystem func(*Storage, FileSystemApi, string) error + func NewDisabledServerController() ServerControllerApi + func NewMockServerController() ServerControllerApi + func NewRemoteServerController(opts ServerControllerOptions) ServerControllerApi + type ServerControllerOptions struct + Address string + Local bool + type ServerControllerProvider interface + NewServerController func(ServerControllerOptions) ServerControllerApi + type ServerInfo struct + LNetNids []string + type Storage struct + Id uuid.UUID + func (s *Storage) CreateFileSystem(fs FileSystemApi, opts FileSystemOptions) error + func (s *Storage) Delete() error + func (s *Storage) DeleteFileSystem(fs FileSystemApi) error + func (s *Storage) Devices() []string + func (s *Storage) GetStatus() (StorageStatus, error) + func (s *Storage) MountFileSystem(fs FileSystemApi, mountPoint string) error + func (s *Storage) UnmountFileSystem(fs FileSystemApi, mountPoint string) error + type StorageNamespace struct + Id nvme.NamespaceIdentifier + SerialNumber string + type StoragePoolOem struct + Namespaces []StorageNamespace + type StorageStatus string + func (s StorageStatus) State() sf.ResourceState