k8s

Sep 9, 2022

Changes in this version

+ var ConnectFn = func(api *API) error

+ var InClusterConfigFn = func() (*rest.Config, error)

+ var NewConfigFn = func(config *rest.Config) (*kubernetes.Clientset, error)

+ var NewForConfigFn = func(k8sconfig *rest.Config) (*kubernetes.Clientset, error)

+ var NewLeaderElectorFn = func(lec leaderelection.LeaderElectionConfig) (*leaderelection.LeaderElector, error)

+ func Contains(slice []string, value string) bool

+ type API struct

+ Client kubernetes.Interface

+ Lock sync.Mutex

+ func (api *API) GetPersistentVolumes() (*corev1.PersistentVolumeList, error)

+ func (api *API) GetStorageClasses() (*v1.StorageClassList, error)

+ type ClusterName struct

+ DriverNames []string

+ ID string

+ IsDefault bool

+ type LeaderElector struct

+ API LeaderElectorGetter

+ Elector *leaderelection.LeaderElector

+ func (elect *LeaderElector) InitLeaderElection(endpoint string, namespace string) error

+ func (elect *LeaderElector) IsLeader() bool

+ type LeaderElectorGetter interface

+ InitLeaderElection func(string, string) error

+ IsLeader func() bool

+ type StorageClassFinder struct

+ API StorageClassGetter

+ ClusterNames []ClusterName

+ Logger *logrus.Logger

+ func (f *StorageClassFinder) GetStorageClasses(ctx context.Context) ([]v1.StorageClass, error)

+ type StorageClassGetter interface

+ GetStorageClasses func() (*v1.StorageClassList, error)

+ type VolumeFinder struct

+ API VolumeGetter

+ DriverNames []string

+ Logger *logrus.Logger

+ func (f VolumeFinder) GetPersistentVolumes(ctx context.Context) ([]VolumeInfo, error)

+ type VolumeGetter interface

+ GetPersistentVolumes func() (*corev1.PersistentVolumeList, error)

+ type VolumeInfo struct

+ CreatedTime string

+ Driver string

+ IsiPath string

+ Namespace string

+ PersistentVolume string

+ PersistentVolumeClaim string

+ PersistentVolumeStatus string

+ ProvisionedSize string

+ StorageClass string

+ VolumeClaimName string

+ VolumeHandle string