Documentation
¶
Index ¶
- type ResourceManager
- func (rm *ResourceManager) GetConfigMap(name, namespace string) (*v1.ConfigMap, error)
- func (rm *ResourceManager) GetPersistentVolume(name string) (*v1.PersistentVolume, error)
- func (rm *ResourceManager) GetPersistentVolumeClaim(name, namespace string) (*v1.PersistentVolumeClaim, error)
- func (rm *ResourceManager) GetPod(name, namespace string) (*v1.Pod, error)
- func (rm *ResourceManager) GetPods() []*v1.Pod
- func (rm *ResourceManager) GetSecret(name, namespace string) (*v1.Secret, error)
- func (rm *ResourceManager) GetSecrets(namespace string) ([]*v1.Secret, error)
- func (rm *ResourceManager) ListServices() ([]*v1.Service, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ResourceManager ¶
type ResourceManager struct {
// contains filtered or unexported fields
}
ResourceManager acts as a passthrough to a cache (lister) for pods assigned to the current node. It is also a passthrough to a cache (lister) for Kubernetes secrets and config maps.
func NewResourceManager ¶
func NewResourceManager(podLister corev1listers.PodLister, secretLister corev1listers.SecretLister, configMapLister corev1listers.ConfigMapLister, serviceLister corev1listers.ServiceLister, pvcLister corev1listers.PersistentVolumeClaimLister, pvLister corev1listers.PersistentVolumeLister) (*ResourceManager, error)
NewResourceManager returns a ResourceManager with the internal maps initialized.
func (*ResourceManager) GetConfigMap ¶
func (rm *ResourceManager) GetConfigMap(name, namespace string) (*v1.ConfigMap, error)
GetConfigMap retrieves the specified config map from the cache.
func (*ResourceManager) GetPersistentVolume ¶ added in v0.6.0
func (rm *ResourceManager) GetPersistentVolume(name string) (*v1.PersistentVolume, error)
GetPersistentVolume retrieves the specified pv from Kubernetes
func (*ResourceManager) GetPersistentVolumeClaim ¶ added in v0.6.0
func (rm *ResourceManager) GetPersistentVolumeClaim(name, namespace string) (*v1.PersistentVolumeClaim, error)
GetPersistentVolumeClaim retrieves the specified pvc from Kubernetes
func (*ResourceManager) GetPod ¶ added in v0.8.0
func (rm *ResourceManager) GetPod(name, namespace string) (*v1.Pod, error)
GetPod retrieves the specified pod from Kubernetes.
func (*ResourceManager) GetPods ¶
func (rm *ResourceManager) GetPods() []*v1.Pod
GetPods returns a list of all known pods assigned to this virtual node.
func (*ResourceManager) GetSecret ¶
func (rm *ResourceManager) GetSecret(name, namespace string) (*v1.Secret, error)
GetSecret retrieves the specified secret from Kubernetes.
func (*ResourceManager) GetSecrets ¶ added in v0.6.1
func (rm *ResourceManager) GetSecrets(namespace string) ([]*v1.Secret, error)
GetSecrets retrieves the all secrets of a namespace from Kubernetes.
func (*ResourceManager) ListServices ¶
func (rm *ResourceManager) ListServices() ([]*v1.Service, error)
ListServices retrieves the list of services from Kubernetes.
Source Files