manager

package
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 14, 2022 License: Apache-2.0 Imports: 4 Imported by: 8

Documentation

Index

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

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL