spectrumscale

Documentation

Index

• Constants
• func NewSpectrumLocalClient(config resources.UbiquityServerConfig) (resources.StorageClient, error)
• func NewSpectrumLocalClientWithConnectors(logger logs.Logger, connector connectors.SpectrumScaleConnector, ...) (resources.StorageClient, error)
• type SpectrumDataModel
  • func NewSpectrumDataModel(log logs.Logger, db *gorm.DB, backend string) SpectrumDataModel
• type SpectrumDataModelWrapper
  • func NewSpectrumDataModelWrapper(backend string) SpectrumDataModelWrapper
• type SpectrumScaleConfigError
  • func (e *SpectrumScaleConfigError) Error() string
• type SpectrumScaleFileSetLinkError
  • func (e *SpectrumScaleFileSetLinkError) Error() string
• type SpectrumScaleFileSetNotLinkError
  • func (e *SpectrumScaleFileSetNotLinkError) Error() string
• type SpectrumScaleFileSystemMountError
  • func (e *SpectrumScaleFileSystemMountError) Error() string
• type SpectrumScaleFileSystemNotMounted
  • func (e *SpectrumScaleFileSystemNotMounted) Error() string
• type SpectrumScaleFileSystemNotPresent
  • func (e *SpectrumScaleFileSystemNotPresent) Error() string
• type SpectrumScaleGetClusterIdError
  • func (e *SpectrumScaleGetClusterIdError) Error() string
• type SpectrumScaleQuotaNotEnabledError
  • func (e *SpectrumScaleQuotaNotEnabledError) Error() string
• type SpectrumScaleVolume
• type VolumeType

Constants

const (
	UserSpecifiedUID string = "uid"
	UserSpecifiedGID string = "gid"
)

const (
	Type        string = "type"
	TypeFileset string = "fileset"

	FilesetID string = "fileset"
	Directory string = "directory"
	Quota     string = "quota"

	Filesystem string = "filesystem"

	IsPreexisting string = "isPreexisting"

	SpectrumScaleConfigUser       = "REST_USER"
	SpectrumScaleConfigPassword   = "REST_PASSWORD"
	SpectrumScaleConfigFilesystem = "DEFAULT_FILESYSTEM_NAME"
)

const SpectrumScaleGetClusterIdErrorStr = "Failed to get Spectrum Scale ClusterID"

Functions

func NewSpectrumLocalClient

func NewSpectrumLocalClient(config resources.UbiquityServerConfig) (resources.StorageClient, error)

func NewSpectrumLocalClientWithConnectors

func NewSpectrumLocalClientWithConnectors(logger logs.Logger, connector connectors.SpectrumScaleConnector, spectrumExecutor utils.Executor, config resources.SpectrumScaleConfig, datamodel SpectrumDataModelWrapper) (resources.StorageClient, error)

Types

type SpectrumDataModel

type SpectrumDataModel interface {
	CreateVolumeTable() error
	DeleteVolume(name string) error
	InsertFilesetVolume(fileset, volumeName string, filesystem string, isPreexisting bool, opts map[string]interface{}) error
	InsertFilesetQuotaVolume(fileset, quota, volumeName string, filesystem string, isPreexisting bool, opts map[string]interface{}) error
	GetVolume(name string) (SpectrumScaleVolume, bool, error)
	ListVolumes() ([]resources.Volume, error)
	UpdateVolumeMountpoint(name string, mountpoint string) error
}

func NewSpectrumDataModel

func NewSpectrumDataModel(log logs.Logger, db *gorm.DB, backend string) SpectrumDataModel

type SpectrumDataModelWrapper

type SpectrumDataModelWrapper interface {
	DeleteVolume(name string) error
	InsertFilesetVolume(fileset, volumeName string, filesystem string, isPreexisting bool, opts map[string]interface{}) error
	InsertFilesetQuotaVolume(fileset, quota, volumeName string, filesystem string, isPreexisting bool, opts map[string]interface{}) error
	GetVolume(name string) (SpectrumScaleVolume, bool, error)
	ListVolumes() ([]resources.Volume, error)
	UpdateDatabaseVolume(newVolume *SpectrumScaleVolume)
	IsDbVolume(name string) bool
	GetDbName() string
}

func NewSpectrumDataModelWrapper

func NewSpectrumDataModelWrapper(backend string) SpectrumDataModelWrapper

type SpectrumScaleConfigError

type SpectrumScaleConfigError struct {
	ConfigParam string
}

func (*SpectrumScaleConfigError) Error

func (e *SpectrumScaleConfigError) Error() string

type SpectrumScaleFileSetLinkError

type SpectrumScaleFileSetLinkError struct {
	Filesystem string
	Fileset    string
}

func (*SpectrumScaleFileSetLinkError) Error

func (e *SpectrumScaleFileSetLinkError) Error() string

type SpectrumScaleFileSetNotLinkError

type SpectrumScaleFileSetNotLinkError struct {
	Filesystem string
	Fileset    string
}

func (*SpectrumScaleFileSetNotLinkError) Error

func (e *SpectrumScaleFileSetNotLinkError) Error() string

type SpectrumScaleFileSystemMountError

type SpectrumScaleFileSystemMountError struct {
	Filesystem string
}

func (*SpectrumScaleFileSystemMountError) Error

func (e *SpectrumScaleFileSystemMountError) Error() string

type SpectrumScaleFileSystemNotMounted

type SpectrumScaleFileSystemNotMounted struct {
	Filesystem string
}

func (*SpectrumScaleFileSystemNotMounted) Error

func (e *SpectrumScaleFileSystemNotMounted) Error() string

type SpectrumScaleFileSystemNotPresent

type SpectrumScaleFileSystemNotPresent struct {
	Filesystem string
}

func (*SpectrumScaleFileSystemNotPresent) Error

func (e *SpectrumScaleFileSystemNotPresent) Error() string

type SpectrumScaleGetClusterIdError

type SpectrumScaleGetClusterIdError struct {
	ErrorMsg string
}

func (*SpectrumScaleGetClusterIdError) Error

func (e *SpectrumScaleGetClusterIdError) Error() string

type SpectrumScaleQuotaNotEnabledError

type SpectrumScaleQuotaNotEnabledError struct {
	Filesystem string
}

func (*SpectrumScaleQuotaNotEnabledError) Error

func (e *SpectrumScaleQuotaNotEnabledError) Error() string

type SpectrumScaleVolume

type SpectrumScaleVolume struct {
	ID            uint
	Volume        resources.Volume
	VolumeID      uint
	Type          VolumeType
	ClusterId     string
	FileSystem    string
	Fileset       string
	Directory     string
	UID           string
	GID           string
	Quota         string
	IsPreexisting bool
}

type VolumeType

type VolumeType int

const (
	Fileset VolumeType = iota
	Lightweight
	FilesetWithQuota
)