manager

package

Go to main page

Versions in this module

v0

v0.6.2

Oct 8, 2019

v0.6.2-rc1

Oct 8, 2019

v0.6.1

Sep 23, 2019

v0.6.0

Sep 21, 2019

Changes in this version

+ const BackupStatusQueryInterval

type VolumeManager

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

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

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

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

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

v0.6.0-rc2

Sep 19, 2019

v0.6.0-rc1

Sep 17, 2019

v0.5.0

May 18, 2019

Changes in this version

+ const BundleErrorMkdirFailed

+ const BundleErrorOpenFailed

+ const BundleErrorStatFailed

+ const BundleErrorZipFailed

+ const BundleProgressPercentageLogs

+ const BundleProgressPercentageTotal

+ const BundleProgressPercentageYaml

+ const BundleStateError

+ const BundleStateInProgress

+ const BundleStateReadyForDownload

+ const KubeStatusPollConut

+ const KubeStatusPollInterval

+ var ConflictRetryCount = 5

+ func GenerateBackupTarget(ds *datastore.DataStore) (*engineapi.BackupTarget, error)

+ func GetBackupCredentialConfig(ds *datastore.DataStore) (map[string]string, error)

+ func NewPVCManifest(v *longhorn.Volume, pvName, ns, pvcName, storageClassName string) *apiv1.PersistentVolumeClaim

+ func NewPVManifest(v *longhorn.Volume, pvName, storageClassName string) *apiv1.PersistentVolume

+ func SyncVolumeLastBackupWithBackupVolume(volumeName string, backupVolume *engineapi.BackupVolume, ...) (err error)

+ func SyncVolumesLastBackupWithBackupVolumes(backupVolumes map[string]*engineapi.BackupVolume, ...)

+ func UpdateVolumeLastBackup(volumeName string, backupTarget *engineapi.BackupTarget, ...) (err error)

+ type BundleError string

type BundleMeta

+ IssueDescription string

+ IssueURL string

+ type BundleState string

+ type SupportBundle struct

+ Error BundleError

+ Filename string

+ Name string

+ ProgressPercentage int

+ Size int64

+ State BundleState

type VolumeManager

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

+ func (m *VolumeManager) DeleteSupportBundle()

+ func (m *VolumeManager) GetBundleFileHandler() (io.ReadCloser, error)

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

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

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

+ func (m *VolumeManager) PVCreate(name, pvName string) (v *longhorn.Volume, err error)

v0.5.0-rc3

May 18, 2019

v0.5.0-rc2

May 16, 2019

v0.5.0-rc1

May 14, 2019

v0.4.1

Mar 23, 2019

v0.4.1-rc1

Mar 22, 2019

v0.4.0

Feb 22, 2019

Changes in this version

+ var VERSION = "v0.3.0"

+ type BundleMeta struct

+ BundleCreatedAt string

+ KubernetesVersion string

+ LonghornNamespaceUUID string

+ LonghornVersion string

+ type GetObjectMapFunc func() (interface{}, error)

+ type GetRuntimeObjectListFunc func() (runtime.Object, error)

type VolumeManager

+ func (m *VolumeManager) GenerateSupportBundle() (io.ReadCloser, string, int64, error)

+ func (m *VolumeManager) GetLonghornEventList() (*v1.EventList, error)

v0.4.0-rc2

Feb 21, 2019

v0.4.0-rc1

Feb 20, 2019

v0.3.3

Jan 15, 2019

Changes in this version

type VolumeManager

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

v0.3.3-rc1

Jan 12, 2019

v0.3.2

Nov 9, 2018

v0.3.2-rc2

Nov 9, 2018

v0.3.2-rc1

Nov 8, 2018

v0.3.1

Sep 18, 2018

Changes in this version

type VolumeManager

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

v0.3.1-rc1

Sep 13, 2018

v0.3.0

Aug 23, 2018

Changes in this version

+ var WaitForEngineImageCount = 20

+ var WaitForEngineImageInterval = 6 * time.Second

+ type VolumeManager struct

+ func NewVolumeManager(currentNodeID string, ds *datastore.DataStore) *VolumeManager

+ func (m *VolumeManager) Attach(name, nodeID string) (v *longhorn.Volume, err error)

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

+ func (m *VolumeManager) CheckEngineImageReadiness(image string) error

+ func (m *VolumeManager) Create(name string, spec *types.VolumeSpec) (v *longhorn.Volume, err error)

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

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

+ func (m *VolumeManager) CreateSnapshot(snapshotName string, labels map[string]string, volumeName string) (*engineapi.Snapshot, error)

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

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

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

+ func (m *VolumeManager) DeleteReplica(replicaName string) error

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

+ func (m *VolumeManager) DeployAndWaitForEngineImage(image string) error

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

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

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

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

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

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

+ func (m *VolumeManager) GetCurrentNodeID() string

+ func (m *VolumeManager) GetEngineClient(volumeName string) (client engineapi.EngineClient, err error)

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

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

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

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

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

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

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

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

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

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

+ func (m *VolumeManager) GetSnapshot(snapshotName, volumeName string) (*engineapi.Snapshot, error)

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

+ func (m *VolumeManager) ListBackupVolumes() ([]*engineapi.BackupVolume, error)

+ func (m *VolumeManager) ListBackupsForVolume(volumeName string) ([]*engineapi.Backup, error)

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

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

+ func (m *VolumeManager) ListEvent() ([]*v1.Event, error)

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

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

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

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

+ func (m *VolumeManager) ListSnapshots(volumeName string) (map[string]*engineapi.Snapshot, error)

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

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

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

+ func (m *VolumeManager) MigrationStart(name, nodeID string) (v *longhorn.Volume, err error)

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

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

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

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

+ func (m *VolumeManager) SettingValidation(name, value string) error

+ func (m *VolumeManager) UpdateNode(name string, allowScheduling bool) (*longhorn.Node, error)

+ func (m *VolumeManager) UpdateRecurringJobs(volumeName string, jobs []types.RecurringJob) (v *longhorn.Volume, err error)

+ func (m *VolumeManager) WaitForEngineImage(image string) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL