mirror of
https://github.com/weaveworks/scope.git
synced 2026-07-19 05:19:35 +00:00
68 lines
1.9 KiB
Go
68 lines
1.9 KiB
Go
package kubernetes
|
|
|
|
import (
|
|
"github.com/weaveworks/scope/report"
|
|
apiv1 "k8s.io/api/core/v1"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
|
|
"k8s.io/apimachinery/pkg/labels"
|
|
)
|
|
|
|
const (
|
|
// BetaStorageClassAnnotation is the annotation for default storage class
|
|
BetaStorageClassAnnotation = "volume.beta.kubernetes.io/storage-class"
|
|
)
|
|
|
|
// PersistentVolumeClaim represents kubernetes PVC interface
|
|
type PersistentVolumeClaim interface {
|
|
Meta
|
|
Selector() (labels.Selector, error)
|
|
GetNode() report.Node
|
|
GetStorageClass() string
|
|
}
|
|
|
|
// persistentVolumeClaim represents kubernetes Persistent Volume Claims
|
|
type persistentVolumeClaim struct {
|
|
*apiv1.PersistentVolumeClaim
|
|
Meta
|
|
}
|
|
|
|
// NewPersistentVolumeClaim returns new Persistent Volume Claim type
|
|
func NewPersistentVolumeClaim(p *apiv1.PersistentVolumeClaim) PersistentVolumeClaim {
|
|
return &persistentVolumeClaim{PersistentVolumeClaim: p, Meta: meta{p.ObjectMeta}}
|
|
}
|
|
|
|
// GetStorageClass will fetch storage class name from given PVC
|
|
func (p *persistentVolumeClaim) GetStorageClass() string {
|
|
|
|
// Use Beta storage class annotation first
|
|
storageClassName := p.Annotations[BetaStorageClassAnnotation]
|
|
if storageClassName != "" {
|
|
return storageClassName
|
|
}
|
|
if p.Spec.StorageClassName != nil {
|
|
storageClassName = *p.Spec.StorageClassName
|
|
}
|
|
|
|
return storageClassName
|
|
}
|
|
|
|
// GetNode returns Persistent Volume Claim as Node
|
|
func (p *persistentVolumeClaim) GetNode() report.Node {
|
|
return p.MetaNode(report.MakePersistentVolumeClaimNodeID(p.UID())).WithLatests(
|
|
NodeType, "Persistent Volume Claim",
|
|
Status, string(p.Status.Phase),
|
|
VolumeName, p.Spec.VolumeName,
|
|
StorageClassName, p.GetStorageClass(),
|
|
)
|
|
}
|
|
|
|
// Selector returns all Persistent Volume Claim selector
|
|
func (p *persistentVolumeClaim) Selector() (labels.Selector, error) {
|
|
selector, err := metav1.LabelSelectorAsSelector(p.Spec.Selector)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return selector, nil
|
|
}
|