manager

Documentation

Index

• type ResourceManager
  • func NewResourceManager(podLister corev1listers.PodLister, secretLister corev1listers.SecretLister, ...) (*ResourceManager, error)
  • func (rm *ResourceManager) CreatePod(ctx context.Context, pod *v1.Pod) error
  • func (rm *ResourceManager) DeletePod(ctx context.Context, pod *v1.Pod) error
  • func (rm *ResourceManager) GetPod(nm types.NamespacedName) *v1.Pod
  • func (rm *ResourceManager) GetPodStatus(nm types.NamespacedName) *v1.PodStatus
  • func (rm *ResourceManager) GetPods() []*v1.Pod

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) (*ResourceManager, error)

NewResourceManager returns a ResourceManager with the internal maps initialized.

func (*ResourceManager) CreatePod

func (rm *ResourceManager) CreatePod(ctx context.Context, pod *v1.Pod) error

func (*ResourceManager) DeletePod

func (rm *ResourceManager) DeletePod(ctx context.Context, pod *v1.Pod) error

func (*ResourceManager) GetPod

func (rm *ResourceManager) GetPod(nm types.NamespacedName) *v1.Pod

func (*ResourceManager) GetPodStatus

func (rm *ResourceManager) GetPodStatus(nm types.NamespacedName) *v1.PodStatus

func (*ResourceManager) GetPods

func (rm *ResourceManager) GetPods() []*v1.Pod