diff --git a/manager/resource.go b/manager/resource.go index a3883a6..0e25fcc 100644 --- a/manager/resource.go +++ b/manager/resource.go @@ -50,6 +50,11 @@ func NewResourceManager(podLister corev1listers.PodLister, return &rm, nil } +// GetPod retrieves the specified pod from Kubernetes. +func (rm *ResourceManager) GetPod(name, namespace string) (*v1.Pod, error) { + return rm.podLister.Pods(namespace).Get(name) +} + // GetPods returns a list of all known pods assigned to this virtual node. func (rm *ResourceManager) GetPods() []*v1.Pod { l, err := rm.podLister.List(labels.Everything())