util

Jan 30, 2024

Changes in this version

+ func CheckUpgradePath(namespace string, lhClient lhclientset.Interface, ...) error

+ func GetCurrentReferredLonghornEngineImageVersions(namespace string, lhClient lhclientset.Interface) (map[string]emeta.VersionOutput, error)

Nov 2, 2023

Changes in this version

+ func ListAndUpdateVolumeAttachmentsInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*longhorn.VolumeAttachment, error)

Jun 28, 2023

Changes in this version

+ const LonghornV1ToV2MinorVersionNum

+ func CheckUpgradePathSupported(namespace string, lhClient lhclientset.Interface) error

+ func CreateAndUpdateBackingImageInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (*v1beta2.BackingImageDataSource, error)

+ func CreateAndUpdateRecurringJobInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (*v1beta2.RecurringJob, error)

+ func DeleteRemovedSettings(namespace string, lhClient *lhclientset.Clientset) error

+ func ListAndUpdateBackingImageDataSourcesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*v1beta2.BackingImageDataSource, error)

+ func ListAndUpdateBackingImagesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*v1beta2.BackingImage, error)

+ func ListAndUpdateBackupsInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*v1beta2.Backup, error)

+ func ListAndUpdateEngineImagesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*v1beta2.EngineImage, error)

+ func ListAndUpdateEnginesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*v1beta2.Engine, error)

+ func ListAndUpdateInstanceManagersInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*v1beta2.InstanceManager, error)

+ func ListAndUpdateNodesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*v1beta2.Node, error)

+ func ListAndUpdateOrphansInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*v1beta2.Orphan, error)

+ func ListAndUpdateRecurringJobsInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*v1beta2.RecurringJob, error)

+ func ListAndUpdateReplicasInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*v1beta2.Replica, error)

+ func ListAndUpdateSettingsInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*v1beta2.Setting, error)

+ func ListAndUpdateShareManagersInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*v1beta2.ShareManager, error)

+ func ListAndUpdateSnapshotsInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*v1beta2.Snapshot, error)

+ func ListAndUpdateVolumesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*v1beta2.Volume, error)

+ func UpdateResources(namespace string, lhClient *lhclientset.Clientset, ...) error

+ func UpdateResourcesStatus(namespace string, lhClient *lhclientset.Clientset, ...) error

Oct 26, 2023

Changes in this version

+ func ListManagerPods(namespace string, kubeClient *clientset.Clientset) ([]corev1.Pod, error)

Sep 1, 2022

Changes in this version

+ type ProgressMonitor struct

+ func NewProgressMonitor(description string, currentValue, targetValue int) *ProgressMonitor

+ func (pm *ProgressMonitor) GetCurrentProgress() (int, int, float64)

+ func (pm *ProgressMonitor) Inc() int

+ func (pm *ProgressMonitor) SetCurrentValue(newValue int)

Mar 17, 2022

Changes in this version

+ func CreateOrUpdateLonghornVersionSetting(namespace string, lhClient *lhclientset.Clientset) error

+ func GetCurrentLonghornVersion(namespace string, lhClient *lhclientset.Clientset) (string, error)

Apr 23, 2021

Changes in this version

+ func ListIMPods(namespace string, kubeClient *clientset.Clientset) ([]v1.Pod, error)

+ func ListShareManagerPods(namespace string, kubeClient *clientset.Clientset) ([]v1.Pod, error)

+ func MergeStringMaps(baseMap, overwriteMap map[string]string) map[string]string