storageclass

Documentation

Index

• Variables
• func EnsureWatcherStarted(cli client.Client, clusterKey types.NamespacedName)
• func FulfillStorageClassSpec(clusterInstance *hwameistoroperatorv1alpha1.Cluster) *hwameistoroperatorv1alpha1.Cluster
• func SetStorageClassTemplate(clusterInstance *hwameistoroperatorv1alpha1.Cluster)
• func WatchLocalStorageNodes(cli client.Client, clusterKey types.NamespacedName, stopCh <-chan struct{})
• type LocalStorageNodeWatcher
• type StorageClassMaintainer
  • func NewMaintainer(cli client.Client, clusterInstance *hwameistoroperatorv1alpha1.Cluster) *StorageClassMaintainer
  • func (m *StorageClassMaintainer) Ensure() error

Variables

var WatcherMutex sync.Mutex

Functions

func EnsureWatcherStarted

func EnsureWatcherStarted(cli client.Client, clusterKey types.NamespacedName)

func FulfillStorageClassSpec

func FulfillStorageClassSpec(clusterInstance *hwameistoroperatorv1alpha1.Cluster) *hwameistoroperatorv1alpha1.Cluster

func SetStorageClassTemplate

func SetStorageClassTemplate(clusterInstance *hwameistoroperatorv1alpha1.Cluster)

func WatchLocalStorageNodes

func WatchLocalStorageNodes(cli client.Client, clusterKey types.NamespacedName, stopCh <-chan struct{})

Types

type LocalStorageNodeWatcher

type LocalStorageNodeWatcher struct {
	GoroutineStarted bool
}

type StorageClassMaintainer

type StorageClassMaintainer struct {
	Client          client.Client
	ClusterInstance *hwameistoroperatorv1alpha1.Cluster
}

func NewMaintainer

func NewMaintainer(cli client.Client, clusterInstance *hwameistoroperatorv1alpha1.Cluster) *StorageClassMaintainer

func (*StorageClassMaintainer) Ensure

func (m *StorageClassMaintainer) Ensure() error