Versions in this module Expand all Collapse all v0 v0.0.2 Nov 10, 2022 v0.0.1 Feb 21, 2020 Changes in this version + func GetFakeInternalName(name string) string + func IsBootstrapError(err error) bool + func IsFoundError(err error) bool + func IsNotFoundError(err error) bool + func IsNotReadyError(err error) bool + type BootstrapError struct + func (e *BootstrapError) Error() string + type FoundError struct + func (e *FoundError) Error() string + type MockOrchestrator struct + func NewMockOrchestrator() *MockOrchestrator + func (m *MockOrchestrator) AddBackend(configJSON string) (*storage.BackendExternal, error) + func (m *MockOrchestrator) AddFakeBackend(backend *storage.Backend) *storage.BackendExternal + func (m *MockOrchestrator) AddFrontend(f frontend.Plugin) + func (m *MockOrchestrator) AddMockFakeNASBackend(name string) *storage.BackendExternal + func (m *MockOrchestrator) AddMockFakeSANBackend(name string) *storage.BackendExternal + func (m *MockOrchestrator) AddMockONTAPNFSBackend(name, lif string) *storage.BackendExternal + func (m *MockOrchestrator) AddMockONTAPSANBackend(name, lif string) *storage.BackendExternal + func (m *MockOrchestrator) AddNode(node *utils.Node) error + func (m *MockOrchestrator) AddStorageClass(scConfig *storageclass.Config) (*storageclass.External, error) + func (m *MockOrchestrator) AddVolume(volumeConfig *storage.VolumeConfig) (*storage.VolumeExternal, error) + func (m *MockOrchestrator) AddVolumeTransaction(volTxn *storage.VolumeTransaction) error + func (m *MockOrchestrator) AttachVolume(volumeName, mountpoint string, publishInfo *utils.VolumePublishInfo) error + func (m *MockOrchestrator) Bootstrap() error + func (m *MockOrchestrator) CloneVolume(volumeConfig *storage.VolumeConfig) (*storage.VolumeExternal, error) + func (m *MockOrchestrator) CreateSnapshot(snapshotConfig *storage.SnapshotConfig) (*storage.SnapshotExternal, error) + func (m *MockOrchestrator) DeleteBackend(backend string) error + func (m *MockOrchestrator) DeleteBackendByBackendUUID(backendName, backendUUID string) error + func (m *MockOrchestrator) DeleteNode(nName string) error + func (m *MockOrchestrator) DeleteSnapshot(volumeName, snapshotName string) error + func (m *MockOrchestrator) DeleteStorageClass(scName string) error + func (m *MockOrchestrator) DeleteVolume(volumeName string) error + func (m *MockOrchestrator) DeleteVolumeTransaction(volTxn *storage.VolumeTransaction) error + func (m *MockOrchestrator) DetachVolume(volumeName, mountpoint string) error + func (m *MockOrchestrator) GetBackend(backendName string) (*storage.BackendExternal, error) + func (m *MockOrchestrator) GetBackendByBackendUUID(backendUUID string) (*storage.BackendExternal, error) + func (m *MockOrchestrator) GetDriverTypeForVolume(vol *storage.VolumeExternal) (string, error) + func (m *MockOrchestrator) GetFrontend(name string) (frontend.Plugin, error) + func (m *MockOrchestrator) GetNode(nName string) (*utils.Node, error) + func (m *MockOrchestrator) GetSnapshot(volumeName, snapshotName string) (*storage.SnapshotExternal, error) + func (m *MockOrchestrator) GetStorageClass(scName string) (*storageclass.External, error) + func (m *MockOrchestrator) GetVersion() (string, error) + func (m *MockOrchestrator) GetVolume(volume string) (*storage.VolumeExternal, error) + func (m *MockOrchestrator) GetVolumeExternal(volumeName string, backendName string) (*storage.VolumeExternal, error) + func (m *MockOrchestrator) GetVolumeTransaction(volTxn *storage.VolumeTransaction) (*storage.VolumeTransaction, error) + func (m *MockOrchestrator) GetVolumeType(vol *storage.VolumeExternal) (config.VolumeType, error) + func (m *MockOrchestrator) ImportVolume(volumeConfig *storage.VolumeConfig) (externalVol *storage.VolumeExternal, err error) + func (m *MockOrchestrator) LegacyImportVolume(volumeConfig *storage.VolumeConfig, backendName string, notManaged bool, ...) (externalVol *storage.VolumeExternal, err error) + func (m *MockOrchestrator) ListBackends() ([]*storage.BackendExternal, error) + func (m *MockOrchestrator) ListNodes() ([]*utils.Node, error) + func (m *MockOrchestrator) ListSnapshots() ([]*storage.SnapshotExternal, error) + func (m *MockOrchestrator) ListSnapshotsByName(snapshotName string) ([]*storage.SnapshotExternal, error) + func (m *MockOrchestrator) ListSnapshotsForVolume(volumeName string) ([]*storage.SnapshotExternal, error) + func (m *MockOrchestrator) ListStorageClasses() ([]*storageclass.External, error) + func (m *MockOrchestrator) ListVolumes() ([]*storage.VolumeExternal, error) + func (m *MockOrchestrator) ListVolumesByPlugin(pluginName string) ([]*storage.VolumeExternal, error) + func (m *MockOrchestrator) PublishVolume(volumeName string, publishInfo *utils.VolumePublishInfo) error + func (m *MockOrchestrator) ReadSnapshotsForVolume(volumeName string) ([]*storage.SnapshotExternal, error) + func (m *MockOrchestrator) ReloadVolumes() error + func (m *MockOrchestrator) ResizeVolume(volumeName, newSize string) error + func (m *MockOrchestrator) SetVolumeState(volumeName string, state storage.VolumeState) error + func (m *MockOrchestrator) UpdateBackend(backendName, configJSON string) (storageBackendExternal *storage.BackendExternal, err error) + func (m *MockOrchestrator) UpdateBackendByBackendUUID(backendName, configJSON, backendUUID string) (storageBackendExternal *storage.BackendExternal, err error) + func (m *MockOrchestrator) UpdateBackendState(backendName, backendState string) (storageBackendExternal *storage.BackendExternal, err error) + func (m *MockOrchestrator) ValidateVolumes(t *testing.T, expectedConfigs []*storage.VolumeConfig) bool + type NotFoundError struct + Message string + func (e *NotFoundError) Error() string + type NotReadyError struct + func (e *NotReadyError) Error() string + type Orchestrator interface + AddBackend func(configJSON string) (*storage.BackendExternal, error) + AddFrontend func(f frontend.Plugin) + AddNode func(node *utils.Node) error + AddStorageClass func(scConfig *storageclass.Config) (*storageclass.External, error) + AddVolume func(volumeConfig *storage.VolumeConfig) (*storage.VolumeExternal, error) + AddVolumeTransaction func(volTxn *storage.VolumeTransaction) error + AttachVolume func(volumeName, mountpoint string, publishInfo *utils.VolumePublishInfo) error + Bootstrap func() error + CloneVolume func(volumeConfig *storage.VolumeConfig) (*storage.VolumeExternal, error) + CreateSnapshot func(snapshotConfig *storage.SnapshotConfig) (*storage.SnapshotExternal, error) + DeleteBackend func(backend string) error + DeleteBackendByBackendUUID func(backendName, backendUUID string) error + DeleteNode func(nName string) error + DeleteSnapshot func(volumeName, snapshotName string) error + DeleteStorageClass func(scName string) error + DeleteVolume func(volume string) error + DeleteVolumeTransaction func(volTxn *storage.VolumeTransaction) error + DetachVolume func(volumeName, mountpoint string) error + GetBackend func(backend string) (*storage.BackendExternal, error) + GetBackendByBackendUUID func(backendUUID string) (*storage.BackendExternal, error) + GetDriverTypeForVolume func(vol *storage.VolumeExternal) (string, error) + GetFrontend func(name string) (frontend.Plugin, error) + GetNode func(nName string) (*utils.Node, error) + GetSnapshot func(volumeName, snapshotName string) (*storage.SnapshotExternal, error) + GetStorageClass func(scName string) (*storageclass.External, error) + GetVersion func() (string, error) + GetVolume func(volume string) (*storage.VolumeExternal, error) + GetVolumeExternal func(volumeName string, backendName string) (*storage.VolumeExternal, error) + GetVolumeTransaction func(volTxn *storage.VolumeTransaction) (*storage.VolumeTransaction, error) + GetVolumeType func(vol *storage.VolumeExternal) (config.VolumeType, error) + ImportVolume func(volumeConfig *storage.VolumeConfig) (*storage.VolumeExternal, error) + LegacyImportVolume func(volumeConfig *storage.VolumeConfig, backendName string, notManaged bool, ...) (*storage.VolumeExternal, error) + ListBackends func() ([]*storage.BackendExternal, error) + ListNodes func() ([]*utils.Node, error) + ListSnapshots func() ([]*storage.SnapshotExternal, error) + ListSnapshotsByName func(snapshotName string) ([]*storage.SnapshotExternal, error) + ListSnapshotsForVolume func(volumeName string) ([]*storage.SnapshotExternal, error) + ListStorageClasses func() ([]*storageclass.External, error) + ListVolumes func() ([]*storage.VolumeExternal, error) + ListVolumesByPlugin func(pluginName string) ([]*storage.VolumeExternal, error) + PublishVolume func(volumeName string, publishInfo *utils.VolumePublishInfo) error + ReadSnapshotsForVolume func(volumeName string) ([]*storage.SnapshotExternal, error) + ReloadVolumes func() error + ResizeVolume func(volumeName, newSize string) error + SetVolumeState func(volumeName string, state storage.VolumeState) error + UpdateBackend func(backendName, configJSON string) (storageBackendExternal *storage.BackendExternal, err error) + UpdateBackendByBackendUUID func(backendName, configJSON, backendUUID string) (storageBackendExternal *storage.BackendExternal, err error) + UpdateBackendState func(backendName, backendState string) (storageBackendExternal *storage.BackendExternal, err error) + type TridentOrchestrator struct + func NewTridentOrchestrator(client persistentstore.Client) *TridentOrchestrator + func (o *TridentOrchestrator) AddBackend(configJSON string) (*storage.BackendExternal, error) + func (o *TridentOrchestrator) AddFrontend(f frontend.Plugin) + func (o *TridentOrchestrator) AddNode(node *utils.Node) error + func (o *TridentOrchestrator) AddStorageClass(scConfig *storageclass.Config) (*storageclass.External, error) + func (o *TridentOrchestrator) AddVolume(volumeConfig *storage.VolumeConfig) (externalVol *storage.VolumeExternal, err error) + func (o *TridentOrchestrator) AddVolumeTransaction(volTxn *storage.VolumeTransaction) error + func (o *TridentOrchestrator) AttachVolume(volumeName, mountpoint string, publishInfo *utils.VolumePublishInfo) error + func (o *TridentOrchestrator) Bootstrap() error + func (o *TridentOrchestrator) CloneVolume(volumeConfig *storage.VolumeConfig) (externalVol *storage.VolumeExternal, err error) + func (o *TridentOrchestrator) CreateSnapshot(snapshotConfig *storage.SnapshotConfig) (externalSnapshot *storage.SnapshotExternal, err error) + func (o *TridentOrchestrator) DeleteBackend(backendName string) error + func (o *TridentOrchestrator) DeleteBackendByBackendUUID(backendName, backendUUID string) error + func (o *TridentOrchestrator) DeleteNode(nName string) error + func (o *TridentOrchestrator) DeleteSnapshot(volumeName, snapshotName string) (err error) + func (o *TridentOrchestrator) DeleteStorageClass(scName string) error + func (o *TridentOrchestrator) DeleteVolume(volumeName string) (err error) + func (o *TridentOrchestrator) DeleteVolumeTransaction(volTxn *storage.VolumeTransaction) error + func (o *TridentOrchestrator) DetachVolume(volumeName, mountpoint string) error + func (o *TridentOrchestrator) GetBackend(backendName string) (*storage.BackendExternal, error) + func (o *TridentOrchestrator) GetBackendByBackendUUID(backendUUID string) (*storage.BackendExternal, error) + func (o *TridentOrchestrator) GetDriverTypeForVolume(vol *storage.VolumeExternal) (string, error) + func (o *TridentOrchestrator) GetFrontend(name string) (frontend.Plugin, error) + func (o *TridentOrchestrator) GetNode(nName string) (*utils.Node, error) + func (o *TridentOrchestrator) GetSnapshot(volumeName, snapshotName string) (*storage.SnapshotExternal, error) + func (o *TridentOrchestrator) GetStorageClass(scName string) (*storageclass.External, error) + func (o *TridentOrchestrator) GetVersion() (string, error) + func (o *TridentOrchestrator) GetVolume(volume string) (*storage.VolumeExternal, error) + func (o *TridentOrchestrator) GetVolumeExternal(volumeName string, backendName string) (*storage.VolumeExternal, error) + func (o *TridentOrchestrator) GetVolumeTransaction(volTxn *storage.VolumeTransaction) (*storage.VolumeTransaction, error) + func (o *TridentOrchestrator) GetVolumeType(vol *storage.VolumeExternal) (volumeType config.VolumeType, err error) + func (o *TridentOrchestrator) ImportVolume(volumeConfig *storage.VolumeConfig) (externalVol *storage.VolumeExternal, err error) + func (o *TridentOrchestrator) LegacyImportVolume(volumeConfig *storage.VolumeConfig, backendName string, notManaged bool, ...) (externalVol *storage.VolumeExternal, err error) + func (o *TridentOrchestrator) ListBackends() ([]*storage.BackendExternal, error) + func (o *TridentOrchestrator) ListNodes() ([]*utils.Node, error) + func (o *TridentOrchestrator) ListSnapshots() ([]*storage.SnapshotExternal, error) + func (o *TridentOrchestrator) ListSnapshotsByName(snapshotName string) ([]*storage.SnapshotExternal, error) + func (o *TridentOrchestrator) ListSnapshotsForVolume(volumeName string) ([]*storage.SnapshotExternal, error) + func (o *TridentOrchestrator) ListStorageClasses() ([]*storageclass.External, error) + func (o *TridentOrchestrator) ListVolumes() ([]*storage.VolumeExternal, error) + func (o *TridentOrchestrator) ListVolumesByPlugin(pluginName string) ([]*storage.VolumeExternal, error) + func (o *TridentOrchestrator) PublishVolume(volumeName string, publishInfo *utils.VolumePublishInfo) error + func (o *TridentOrchestrator) ReadSnapshotsForVolume(volumeName string) ([]*storage.SnapshotExternal, error) + func (o *TridentOrchestrator) ReloadVolumes() error + func (o *TridentOrchestrator) ResizeVolume(volumeName, newSize string) (err error) + func (o *TridentOrchestrator) SetVolumeState(volumeName string, state storage.VolumeState) error + func (o *TridentOrchestrator) UpdateBackend(backendName, configJSON string) (backendExternal *storage.BackendExternal, err error) + func (o *TridentOrchestrator) UpdateBackendByBackendUUID(backendName, configJSON, backendUUID string) (backendExternal *storage.BackendExternal, err error) + func (o *TridentOrchestrator) UpdateBackendState(backendName, backendState string) (backendExternal *storage.BackendExternal, err error) + type UnsupportedError struct + func (e *UnsupportedError) Error() string + type VolumeCallback func(*storage.VolumeExternal, string) error + type VolumeDeletingError struct + func (e *VolumeDeletingError) Error() string
Go to main page