util

Documentation

Index

• Constants
• func CheckUpgradePathSupported(namespace string, lhClient lhclientset.Interface) error
• func CreateAndUpdateBackingImageInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (*longhorn.BackingImageDataSource, error)
• func CreateAndUpdateRecurringJobInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (*longhorn.RecurringJob, error)
• func CreateOrUpdateLonghornVersionSetting(namespace string, lhClient *lhclientset.Clientset) error
• func DeleteRemovedSettings(namespace string, lhClient *lhclientset.Clientset) error
• func GetCurrentLonghornVersion(namespace string, lhClient lhclientset.Interface) (string, error)
• func ListAndUpdateBackingImageDataSourcesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*longhorn.BackingImageDataSource, error)
• func ListAndUpdateBackingImagesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*longhorn.BackingImage, error)
• func ListAndUpdateBackupsInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*longhorn.Backup, error)
• func ListAndUpdateEngineImagesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*longhorn.EngineImage, error)
• func ListAndUpdateEnginesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*longhorn.Engine, error)
• func ListAndUpdateInstanceManagersInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*longhorn.InstanceManager, error)
• func ListAndUpdateNodesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*longhorn.Node, error)
• func ListAndUpdateOrphansInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*longhorn.Orphan, error)
• func ListAndUpdateRecurringJobsInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*longhorn.RecurringJob, error)
• func ListAndUpdateReplicasInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*longhorn.Replica, error)
• func ListAndUpdateSettingsInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*longhorn.Setting, error)
• func ListAndUpdateShareManagersInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*longhorn.ShareManager, error)
• func ListAndUpdateSnapshotsInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*longhorn.Snapshot, error)
• func ListAndUpdateVolumeAttachmentsInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*longhorn.VolumeAttachment, error)
• func ListAndUpdateVolumesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, ...) (map[string]*longhorn.Volume, error)
• func ListIMPods(namespace string, kubeClient *clientset.Clientset) ([]corev1.Pod, error)
• func ListManagerPods(namespace string, kubeClient *clientset.Clientset) ([]corev1.Pod, error)
• func ListShareManagerPods(namespace string, kubeClient *clientset.Clientset) ([]corev1.Pod, error)
• func MergeStringMaps(baseMap, overwriteMap map[string]string) map[string]string
• func UpdateResources(namespace string, lhClient *lhclientset.Clientset, ...) error
• func UpdateResourcesStatus(namespace string, lhClient *lhclientset.Clientset, ...) error
• type ProgressMonitor
  • 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)

Constants

const (
	// LonghornV1ToV2MinorVersionNum v1 minimal minor version when the upgrade path is from v1.x to v2.0
	// TODO: decide the v1 minimum version that could be upgraded to v2.0
	LonghornV1ToV2MinorVersionNum = 30
)

Functions

func CheckUpgradePathSupported

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

CheckUpgradePathSupported returns if the upgrade path from lhCurrentVersion to meta.Version is supported.

For example: upgrade path is from x.y.z to a.b.c,
0 <= a-x <= 1 is supported, and y should be after a specific version if a-x == 1
0 <= b-y <= 1 is supported when a-x == 0
all downgrade is not supported

func CreateAndUpdateBackingImageInProvidedCache

func CreateAndUpdateBackingImageInProvidedCache(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}, bid *longhorn.BackingImageDataSource) (*longhorn.BackingImageDataSource, error)

CreateAndUpdateBackingImageInProvidedCache creates a backingImage and saves it into the provided cached `resourceMap`. This method is not thread-safe.

func CreateAndUpdateRecurringJobInProvidedCache

func CreateAndUpdateRecurringJobInProvidedCache(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}, job *longhorn.RecurringJob) (*longhorn.RecurringJob, error)

CreateAndUpdateRecurringJobInProvidedCache creates a recurringJob and saves it into the provided cached `resourceMap`. This method is not thread-safe.

func CreateOrUpdateLonghornVersionSetting

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

func DeleteRemovedSettings

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

func GetCurrentLonghornVersion

func GetCurrentLonghornVersion(namespace string, lhClient lhclientset.Interface) (string, error)

func ListAndUpdateBackingImageDataSourcesInProvidedCache

func ListAndUpdateBackingImageDataSourcesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}) (map[string]*longhorn.BackingImageDataSource, error)

ListAndUpdateBackingImageDataSourcesInProvidedCache list all backingImageDataSources and save them into the provided cached `resourceMap`. This method is not thread-safe.

func ListAndUpdateBackingImagesInProvidedCache

func ListAndUpdateBackingImagesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}) (map[string]*longhorn.BackingImage, error)

ListAndUpdateBackingImagesInProvidedCache list all backingImages and save them into the provided cached `resourceMap`. This method is not thread-safe.

func ListAndUpdateBackupsInProvidedCache

func ListAndUpdateBackupsInProvidedCache(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}) (map[string]*longhorn.Backup, error)

ListAndUpdateBackupsInProvidedCache list all backups and save them into the provided cached `resourceMap`. This method is not thread-safe.

func ListAndUpdateEngineImagesInProvidedCache

func ListAndUpdateEngineImagesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}) (map[string]*longhorn.EngineImage, error)

ListAndUpdateEngineImagesInProvidedCache list all engineImages and save them into the provided cached `resourceMap`. This method is not thread-safe.

func ListAndUpdateEnginesInProvidedCache

func ListAndUpdateEnginesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}) (map[string]*longhorn.Engine, error)

ListAndUpdateEnginesInProvidedCache list all engines and save them into the provided cached `resourceMap`. This method is not thread-safe.

func ListAndUpdateInstanceManagersInProvidedCache

func ListAndUpdateInstanceManagersInProvidedCache(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}) (map[string]*longhorn.InstanceManager, error)

ListAndUpdateInstanceManagersInProvidedCache list all instanceManagers and save them into the provided cached `resourceMap`. This method is not thread-safe.

func ListAndUpdateNodesInProvidedCache

func ListAndUpdateNodesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}) (map[string]*longhorn.Node, error)

ListAndUpdateNodesInProvidedCache list all nodes and save them into the provided cached `resourceMap`. This method is not thread-safe.

func ListAndUpdateOrphansInProvidedCache

func ListAndUpdateOrphansInProvidedCache(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}) (map[string]*longhorn.Orphan, error)

ListAndUpdateOrphansInProvidedCache list all orphans and save them into the provided cached `resourceMap`. This method is not thread-safe.

func ListAndUpdateRecurringJobsInProvidedCache

func ListAndUpdateRecurringJobsInProvidedCache(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}) (map[string]*longhorn.RecurringJob, error)

ListAndUpdateRecurringJobsInProvidedCache list all recurringJobs and save them into the provided cached `resourceMap`. This method is not thread-safe.

func ListAndUpdateReplicasInProvidedCache

func ListAndUpdateReplicasInProvidedCache(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}) (map[string]*longhorn.Replica, error)

ListAndUpdateReplicasInProvidedCache list all replicas and save them into the provided cached `resourceMap`. This method is not thread-safe.

func ListAndUpdateSettingsInProvidedCache

func ListAndUpdateSettingsInProvidedCache(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}) (map[string]*longhorn.Setting, error)

ListAndUpdateSettingsInProvidedCache list all settings and save them into the provided cached `resourceMap`. This method is not thread-safe.

func ListAndUpdateShareManagersInProvidedCache

func ListAndUpdateShareManagersInProvidedCache(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}) (map[string]*longhorn.ShareManager, error)

ListAndUpdateShareManagersInProvidedCache list all shareManagers and save them into the provided cached `resourceMap`. This method is not thread-safe.

func ListAndUpdateSnapshotsInProvidedCache

func ListAndUpdateSnapshotsInProvidedCache(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}) (map[string]*longhorn.Snapshot, error)

ListAndUpdateSnapshotsInProvidedCache list all snapshots and save them into the provided cached `resourceMap`. This method is not thread-safe.

func ListAndUpdateVolumeAttachmentsInProvidedCache

func ListAndUpdateVolumeAttachmentsInProvidedCache(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}) (map[string]*longhorn.VolumeAttachment, error)

ListAndUpdateVolumeAttachmentsInProvidedCache list all volumeAttachments and save them into the provided cached `resourceMap`. This method is not thread-safe.

func ListAndUpdateVolumesInProvidedCache

func ListAndUpdateVolumesInProvidedCache(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}) (map[string]*longhorn.Volume, error)

ListAndUpdateVolumesInProvidedCache list all volumes and save them into the provided cached `resourceMap`. This method is not thread-safe.

func ListIMPods

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

func ListManagerPods

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

func ListShareManagerPods

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

func MergeStringMaps

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

func UpdateResources

func UpdateResources(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}) error

UpdateResources persists all the resources' spec changes in provided cached `resourceMap`. This method is not thread-safe.

func UpdateResourcesStatus

func UpdateResourcesStatus(namespace string, lhClient *lhclientset.Clientset, resourceMaps map[string]interface{}) error

UpdateResourcesStatus persists all the resources' status changes in provided cached `resourceMap`. This method is not thread-safe.

Types

type ProgressMonitor

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

func NewProgressMonitor

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

func (*ProgressMonitor) GetCurrentProgress

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

func (*ProgressMonitor) Inc

func (pm *ProgressMonitor) Inc() int

func (*ProgressMonitor) SetCurrentValue

func (pm *ProgressMonitor) SetCurrentValue(newValue int)