manager

Documentation

Index

• type ResourceManager
  • func NewResourceManager(podLister corev1listers.PodLister, secretLister corev1listers.SecretLister, ...) (*ResourceManager, error)
  • 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)

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

func (rm *ResourceManager) GetPersistentVolume(name string) (*v1.PersistentVolume, error)

GetPersistentVolume retrieves the specified pv from Kubernetes

func (*ResourceManager) GetPersistentVolumeClaim

func (rm *ResourceManager) GetPersistentVolumeClaim(name, namespace string) (*v1.PersistentVolumeClaim, error)

GetPersistentVolumeClaim retrieves the specified pvc from Kubernetes

func (*ResourceManager) GetPod

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

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.