manager

package
v1.6.1 Latest Latest
Warning

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

 Go to latest Published: Mar 28, 2024 License: Apache-2.0 Imports: 20 Imported by: 3

Documentation

Index

Constants

View Source 
const (
	DataSourceTypeExportFromVolumeParameterExportType      = "export-type"
	DataSourceTypeExportFromVolumeParameterExportTypeRAW   = "raw"
	DataSourceTypeExportFromVolumeParameterExportTypeQCOW2 = "qcow2"
)
View Source 
const (
	BackupStatusQueryInterval = 2 * time.Second
)

Variables

View Source 
var (
	WaitForEngineImageCount    = 20
	WaitForEngineImageInterval = 6 * time.Second
)

Functions

This section is empty.

Types

type SupportBundle added in v0.5.0 

type SupportBundle struct {
	Name  string
	State longhorn.SupportBundleState

	Filename           string
	ProgressPercentage int
	Size               int64

	Error string
}

type VolumeManager 

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

func NewVolumeManager 

func NewVolumeManager(currentNodeID string, ds *datastore.DataStore, proxyConnCounter util.Counter) *VolumeManager

func (*VolumeManager) Activate added in v0.5.0 

func (m *VolumeManager) Activate(volumeName string, frontend string) (v *longhorn.Volume, err error)

func (*VolumeManager) AddVolumeRecurringJob added in v1.2.0 

func (m *VolumeManager) AddVolumeRecurringJob(volumeName string, name string, isGroup bool) (volumeRecurringJob map[string]*longhorn.VolumeRecurringJob, err error)

func (*VolumeManager) Attach 

func (m *VolumeManager) Attach(name, nodeID string, disableFrontend bool, attachedBy, attacherType, attachmentID string) (v *longhorn.Volume, err error)

func (*VolumeManager) BackupSnapshot 

func (m *VolumeManager) BackupSnapshot(backupName, volumeName, snapshotName string, labels map[string]string) error

func (*VolumeManager) CancelExpansion added in v0.8.1 

func (m *VolumeManager) CancelExpansion(volumeName string) (v *longhorn.Volume, err error)

func (*VolumeManager) CleanUpBackingImageDiskFiles added in v1.2.0 

func (m *VolumeManager) CleanUpBackingImageDiskFiles(name string, diskFileList []string) (bi *longhorn.BackingImage, err error)

func (*VolumeManager) Create 

func (m *VolumeManager) Create(name string, spec *longhorn.VolumeSpec, recurringJobSelector []longhorn.VolumeRecurringJob) (v *longhorn.Volume, err error)

func (*VolumeManager) CreateBackingImage added in v1.1.1 

func (m *VolumeManager) CreateBackingImage(name, checksum, sourceType string, parameters map[string]string) (bi *longhorn.BackingImage, err error)

func (*VolumeManager) CreateEngineImage 

func (m *VolumeManager) CreateEngineImage(image string) (*longhorn.EngineImage, error)

func (*VolumeManager) CreateOrUpdateSetting 

func (m *VolumeManager) CreateOrUpdateSetting(s *longhorn.Setting) (*longhorn.Setting, error)

func (*VolumeManager) CreateRecurringJob added in v1.2.0 

func (m *VolumeManager) CreateRecurringJob(spec *longhorn.RecurringJobSpec) (*longhorn.RecurringJob, error)

func (*VolumeManager) CreateSnapshot 

func (m *VolumeManager) CreateSnapshot(snapshotName string, labels map[string]string, volumeName string) (*longhorn.SnapshotInfo, error)

func (*VolumeManager) CreateSnapshotCR added in v1.5.0 

func (m *VolumeManager) CreateSnapshotCR(snapshotName string, labels map[string]string, volumeName string) (*longhorn.Snapshot, error)

func (*VolumeManager) CreateSupportBundle added in v1.4.0 

func (m *VolumeManager) CreateSupportBundle(issueURL string, description string) (*SupportBundle, error)

CreateSupportBundle creates a SupportBundle custom resource that triggers creation of support bundle manager deployment. The support bundle manager then creates a bundle zip file that is available in https://<cluster-ip>:8080/bundle

func (*VolumeManager) CreateSystemBackup added in v1.4.0 

func (m *VolumeManager) CreateSystemBackup(obj *longhorn.SystemBackup) (*longhorn.SystemBackup, error)

func (*VolumeManager) CreateSystemRestore added in v1.4.0 

func (m *VolumeManager) CreateSystemRestore(name, systemBackup string) (*longhorn.SystemRestore, error)

func (*VolumeManager) Delete 

func (m *VolumeManager) Delete(name string) error

func (*VolumeManager) DeleteBackingImage added in v1.1.1 

func (m *VolumeManager) DeleteBackingImage(name string) error

func (*VolumeManager) DeleteBackup 

func (m *VolumeManager) DeleteBackup(backupName, volumeName string) error

func (*VolumeManager) DeleteBackupVolume added in v0.6.0 

func (m *VolumeManager) DeleteBackupVolume(volumeName string) error

func (*VolumeManager) DeleteEngineImageByName 

func (m *VolumeManager) DeleteEngineImageByName(name string) error

func (*VolumeManager) DeleteNode added in v0.3.1 

func (m *VolumeManager) DeleteNode(name string) error

func (*VolumeManager) DeleteOrphan added in v1.3.0 

func (m *VolumeManager) DeleteOrphan(name string) error

func (*VolumeManager) DeleteRecurringJob added in v1.2.0 

func (m *VolumeManager) DeleteRecurringJob(name string) error

func (*VolumeManager) DeleteReplica 

func (m *VolumeManager) DeleteReplica(volumeName, replicaName string) error

func (*VolumeManager) DeleteSnapshot 

func (m *VolumeManager) DeleteSnapshot(snapshotName, volumeName string) error

func (*VolumeManager) DeleteSnapshotCR added in v1.5.0 

func (m *VolumeManager) DeleteSnapshotCR(snapName string) error

func (*VolumeManager) DeleteSupportBundle added in v0.5.0 

func (m *VolumeManager) DeleteSupportBundle(name string) error

func (*VolumeManager) DeleteSystemBackup added in v1.4.0 

func (m *VolumeManager) DeleteSystemBackup(name string) error

func (*VolumeManager) DeleteSystemRestore added in v1.4.0 

func (m *VolumeManager) DeleteSystemRestore(name string) error

func (*VolumeManager) DeleteVolumeRecurringJob added in v1.2.0 

func (m *VolumeManager) DeleteVolumeRecurringJob(volumeName string, name string, isGroup bool) (v *longhorn.Volume, err error)

func (*VolumeManager) DeployEngineImage added in v1.1.1 

func (m *VolumeManager) DeployEngineImage(image string) error

func (*VolumeManager) Detach 

func (m *VolumeManager) Detach(name, attachmentID, hostID string, forceDetach bool) (v *longhorn.Volume, err error)

Detach will handle regular detachment as well as cleaning up attachment Ticket created by upgrade path

func (*VolumeManager) DiskUpdate 

func (m *VolumeManager) DiskUpdate(name string, updateDisks map[string]longhorn.DiskSpec) (*longhorn.Node, error)

func (*VolumeManager) EngineUpgrade 

func (m *VolumeManager) EngineUpgrade(volumeName, image string) (v *longhorn.Volume, err error)

func (*VolumeManager) Expand added in v0.8.0 

func (m *VolumeManager) Expand(volumeName string, size int64) (v *longhorn.Volume, err error)

func (*VolumeManager) Get 

func (m *VolumeManager) Get(vName string) (*longhorn.Volume, error)

func (*VolumeManager) GetBackingImage added in v1.1.1 

func (m *VolumeManager) GetBackingImage(name string) (*longhorn.BackingImage, error)

func (*VolumeManager) GetBackingImageDataSource added in v1.2.0 

func (m *VolumeManager) GetBackingImageDataSource(name string) (*longhorn.BackingImageDataSource, error)

func (*VolumeManager) GetBackingImageDataSourcePod added in v1.2.0 

func (m *VolumeManager) GetBackingImageDataSourcePod(name string) (*v1.Pod, error)

func (*VolumeManager) GetBackup 

func (m *VolumeManager) GetBackup(backupName, volumeName string) (*longhorn.Backup, error)

func (*VolumeManager) GetBackupVolume 

func (m *VolumeManager) GetBackupVolume(volumeName string) (*longhorn.BackupVolume, error)

func (*VolumeManager) GetCurrentNodeID 

func (m *VolumeManager) GetCurrentNodeID() string

func (*VolumeManager) GetDaemonSetRO added in v1.1.0 

func (m *VolumeManager) GetDaemonSetRO(name string) (*appsv1.DaemonSet, error)

func (*VolumeManager) GetDefaultBackingImageManagersByDiskUUID added in v1.3.0 

func (m *VolumeManager) GetDefaultBackingImageManagersByDiskUUID(diskUUID string) (*longhorn.BackingImageManager, error)

GetDefaultBackingImageManagersByDiskUUID returns a default backing image manager resource object searched by the disk UUID

func (*VolumeManager) GetDiskTags added in v0.6.0 

func (m *VolumeManager) GetDiskTags() ([]string, error)

func (*VolumeManager) GetEngineImageByImage added in v1.1.1 

func (m *VolumeManager) GetEngineImageByImage(image string) (*longhorn.EngineImage, error)

func (*VolumeManager) GetEngineImageByName 

func (m *VolumeManager) GetEngineImageByName(name string) (*longhorn.EngineImage, error)

func (*VolumeManager) GetEngines 

func (m *VolumeManager) GetEngines(vName string) (map[string]*longhorn.Engine, error)

func (*VolumeManager) GetEnginesSorted 

func (m *VolumeManager) GetEnginesSorted(vName string) ([]*longhorn.Engine, error)

func (*VolumeManager) GetInstanceManager added in v0.6.0 

func (m *VolumeManager) GetInstanceManager(name string) (*longhorn.InstanceManager, error)

func (*VolumeManager) GetLonghornEventList added in v0.4.0 

func (m *VolumeManager) GetLonghornEventList() (*corev1.EventList, error)

func (*VolumeManager) GetManagerNodeIPMap 

func (m *VolumeManager) GetManagerNodeIPMap() (map[string]string, error)

func (*VolumeManager) GetNode 

func (m *VolumeManager) GetNode(name string) (*longhorn.Node, error)

func (*VolumeManager) GetNodeTags added in v0.6.0 

func (m *VolumeManager) GetNodeTags() ([]string, error)

func (*VolumeManager) GetOrphan added in v1.3.0 

func (m *VolumeManager) GetOrphan(name string) (*longhorn.Orphan, error)

func (*VolumeManager) GetRecurringJob added in v1.2.0 

func (m *VolumeManager) GetRecurringJob(name string) (*longhorn.RecurringJob, error)

func (*VolumeManager) GetReplicas 

func (m *VolumeManager) GetReplicas(vName string) (map[string]*longhorn.Replica, error)

func (*VolumeManager) GetReplicasSorted 

func (m *VolumeManager) GetReplicasSorted(vName string) ([]*longhorn.Replica, error)

func (*VolumeManager) GetRunningEngineByVolume added in v1.3.0 

func (m *VolumeManager) GetRunningEngineByVolume(name string) (e *longhorn.Engine, err error)

func (*VolumeManager) GetSetting 

func (m *VolumeManager) GetSetting(sName types.SettingName) (*longhorn.Setting, error)

func (*VolumeManager) GetSettingValueExisted 

func (m *VolumeManager) GetSettingValueExisted(sName types.SettingName) (string, error)

func (*VolumeManager) GetSnapshotCR added in v1.5.0 

func (m *VolumeManager) GetSnapshotCR(snapName string) (*longhorn.Snapshot, error)

func (*VolumeManager) GetSnapshotInfo added in v1.4.0 

func (m *VolumeManager) GetSnapshotInfo(snapshotName, volumeName string) (*longhorn.SnapshotInfo, error)

func (*VolumeManager) GetSupportBundle added in v0.5.0 

func (m *VolumeManager) GetSupportBundle(name string) (*SupportBundle, string, error)

func (*VolumeManager) GetSystemBackup added in v1.4.0 

func (m *VolumeManager) GetSystemBackup(name string) (*longhorn.SystemBackup, error)

func (*VolumeManager) GetSystemRestore added in v1.4.0 

func (m *VolumeManager) GetSystemRestore(name string) (*longhorn.SystemRestore, error)

func (*VolumeManager) GetVolumeAttachment added in v1.5.0 

func (m *VolumeManager) GetVolumeAttachment(volumeName string) (*longhorn.VolumeAttachment, error)

func (*VolumeManager) List 

func (m *VolumeManager) List() (map[string]*longhorn.Volume, error)

func (*VolumeManager) ListAllBackupsSorted added in v1.2.0 

func (m *VolumeManager) ListAllBackupsSorted() ([]*longhorn.Backup, error)

func (*VolumeManager) ListBackingImageDataSources added in v1.2.0 

func (m *VolumeManager) ListBackingImageDataSources() (map[string]*longhorn.BackingImageDataSource, error)

func (*VolumeManager) ListBackingImages added in v1.1.1 

func (m *VolumeManager) ListBackingImages() (map[string]*longhorn.BackingImage, error)

func (*VolumeManager) ListBackingImagesSorted added in v1.1.2 

func (m *VolumeManager) ListBackingImagesSorted() ([]*longhorn.BackingImage, error)

func (*VolumeManager) ListBackupTargetsSorted added in v1.2.0 

func (m *VolumeManager) ListBackupTargetsSorted() ([]*longhorn.BackupTarget, error)

func (*VolumeManager) ListBackupVolumes 

func (m *VolumeManager) ListBackupVolumes() (map[string]*longhorn.BackupVolume, error)

func (*VolumeManager) ListBackupVolumesSorted added in v1.2.0 

func (m *VolumeManager) ListBackupVolumesSorted() ([]*longhorn.BackupVolume, error)

func (*VolumeManager) ListBackupsForVolume 

func (m *VolumeManager) ListBackupsForVolume(volumeName string) (map[string]*longhorn.Backup, error)

func (*VolumeManager) ListBackupsForVolumeSorted added in v1.2.0 

func (m *VolumeManager) ListBackupsForVolumeSorted(volumeName string) ([]*longhorn.Backup, error)

func (*VolumeManager) ListEngineImagesByName 

func (m *VolumeManager) ListEngineImagesByName() (map[string]*longhorn.EngineImage, error)

func (*VolumeManager) ListEngineImagesSorted 

func (m *VolumeManager) ListEngineImagesSorted() ([]*longhorn.EngineImage, error)

func (*VolumeManager) ListInstanceManagers added in v0.6.0 

func (m *VolumeManager) ListInstanceManagers() (map[string]*longhorn.InstanceManager, error)

func (*VolumeManager) ListNodes 

func (m *VolumeManager) ListNodes() (map[string]*longhorn.Node, error)

func (*VolumeManager) ListNodesSorted 

func (m *VolumeManager) ListNodesSorted() ([]*longhorn.Node, error)

func (*VolumeManager) ListOrphans added in v1.3.0 

func (m *VolumeManager) ListOrphans() (map[string]*longhorn.Orphan, error)

func (*VolumeManager) ListReadyNodesContainingEngineImageRO added in v1.5.4 

func (m *VolumeManager) ListReadyNodesContainingEngineImageRO(image string) (map[string]*longhorn.Node, error)

func (*VolumeManager) ListRecurringJobsSorted added in v1.2.0 

func (m *VolumeManager) ListRecurringJobsSorted() ([]*longhorn.RecurringJob, error)

func (*VolumeManager) ListSettings 

func (m *VolumeManager) ListSettings() (map[types.SettingName]*longhorn.Setting, error)

func (*VolumeManager) ListSettingsSorted 

func (m *VolumeManager) ListSettingsSorted() ([]*longhorn.Setting, error)

func (*VolumeManager) ListSnapshotInfos added in v1.4.0 

func (m *VolumeManager) ListSnapshotInfos(volumeName string) (map[string]*longhorn.SnapshotInfo, error)

func (*VolumeManager) ListSnapshotsCR added in v1.5.0 

func (m *VolumeManager) ListSnapshotsCR(volumeName string) (map[string]*longhorn.Snapshot, error)

func (*VolumeManager) ListSorted 

func (m *VolumeManager) ListSorted() ([]*longhorn.Volume, error)

func (*VolumeManager) ListSupportBundlesSorted added in v1.4.0 

func (m *VolumeManager) ListSupportBundlesSorted() ([]*longhorn.SupportBundle, error)

func (*VolumeManager) ListSystemBackupsSorted added in v1.4.0 

func (m *VolumeManager) ListSystemBackupsSorted() ([]*longhorn.SystemBackup, error)

func (*VolumeManager) ListSystemRestoresSorted added in v1.4.0 

func (m *VolumeManager) ListSystemRestoresSorted() ([]*longhorn.SystemRestore, error)

func (*VolumeManager) ListVolumeRecurringJob added in v1.2.0 

func (m *VolumeManager) ListVolumeRecurringJob(volumeName string) (map[string]*longhorn.VolumeRecurringJob, error)

func (*VolumeManager) Node2APIAddress 

func (m *VolumeManager) Node2APIAddress(nodeID string) (string, error)

func (*VolumeManager) PVCCreate added in v0.5.0 

func (m *VolumeManager) PVCCreate(name, namespace, pvcName string) (v *longhorn.Volume, err error)

func (*VolumeManager) PVCreate added in v0.5.0 

func (m *VolumeManager) PVCreate(name, pvName, fsType, secretNamespace, secretName, storageClassName string) (v *longhorn.Volume, err error)

func (*VolumeManager) PurgeSnapshot 

func (m *VolumeManager) PurgeSnapshot(volumeName string) error

func (*VolumeManager) RevertSnapshot 

func (m *VolumeManager) RevertSnapshot(snapshotName, volumeName string) error

func (*VolumeManager) Salvage 

func (m *VolumeManager) Salvage(volumeName string, replicaNames []string) (v *longhorn.Volume, err error)

func (*VolumeManager) TrimFilesystem added in v1.4.0 

func (m *VolumeManager) TrimFilesystem(name string) (v *longhorn.Volume, err error)

func (*VolumeManager) UpdateAccessMode added in v1.1.0 

func (m *VolumeManager) UpdateAccessMode(name string, accessMode longhorn.AccessMode) (v *longhorn.Volume, err error)

func (*VolumeManager) UpdateBackupCompressionMethod added in v1.5.0 

func (m *VolumeManager) UpdateBackupCompressionMethod(name string, value string) (v *longhorn.Volume, err error)

func (*VolumeManager) UpdateDataLocality added in v1.1.0 

func (m *VolumeManager) UpdateDataLocality(name string, dataLocality longhorn.DataLocality) (v *longhorn.Volume, err error)

func (*VolumeManager) UpdateNode 

func (m *VolumeManager) UpdateNode(n *longhorn.Node) (*longhorn.Node, error)

func (*VolumeManager) UpdateOfflineReplicaRebuilding added in v1.5.0 

func (m *VolumeManager) UpdateOfflineReplicaRebuilding(name string, value string) (v *longhorn.Volume, err error)

func (*VolumeManager) UpdateRecurringJob added in v1.2.0 

func (m *VolumeManager) UpdateRecurringJob(spec longhorn.RecurringJobSpec) (*longhorn.RecurringJob, error)

func (*VolumeManager) UpdateReplicaAutoBalance added in v1.2.0 

func (m *VolumeManager) UpdateReplicaAutoBalance(name string, inputSpec longhorn.ReplicaAutoBalance) (v *longhorn.Volume, err error)

func (*VolumeManager) UpdateReplicaCount added in v0.3.3 

func (m *VolumeManager) UpdateReplicaCount(name string, count int) (v *longhorn.Volume, err error)

func (*VolumeManager) UpdateReplicaDiskSoftAntiAffinity added in v1.6.0 

func (m *VolumeManager) UpdateReplicaDiskSoftAntiAffinity(name string, replicaDiskSoftAntiAffinity longhorn.ReplicaDiskSoftAntiAffinity) (v *longhorn.Volume, err error)

func (*VolumeManager) UpdateReplicaSoftAntiAffinity added in v1.5.0 

func (m *VolumeManager) UpdateReplicaSoftAntiAffinity(name string, replicaSoftAntiAffinity longhorn.ReplicaSoftAntiAffinity) (v *longhorn.Volume, err error)

func (*VolumeManager) UpdateReplicaZoneSoftAntiAffinity added in v1.5.0 

func (m *VolumeManager) UpdateReplicaZoneSoftAntiAffinity(name string, replicaZoneSoftAntiAffinity longhorn.ReplicaZoneSoftAntiAffinity) (v *longhorn.Volume, err error)

func (*VolumeManager) UpdateSnapshotDataIntegrity added in v1.4.0 

func (m *VolumeManager) UpdateSnapshotDataIntegrity(name string, value string) (v *longhorn.Volume, err error)

func (*VolumeManager) UpdateSnapshotMaxCount added in v1.6.0 

func (m *VolumeManager) UpdateSnapshotMaxCount(name string, snapshotMaxCount int) (v *longhorn.Volume, err error)

func (*VolumeManager) UpdateSnapshotMaxSize added in v1.6.0 

func (m *VolumeManager) UpdateSnapshotMaxSize(name string, snapshotMaxSize int64) (v *longhorn.Volume, err error)

func (*VolumeManager) UpdateUnmapMarkSnapChainRemoved added in v1.4.0 

func (m *VolumeManager) UpdateUnmapMarkSnapChainRemoved(name string, unmapMarkSnapChainRemoved longhorn.UnmapMarkSnapChainRemoved) (v *longhorn.Volume, err error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.