kubernetes

Documentation

Index

• func CreateKubernetesClientFromConfig(kubeConfigPath string) (clientset.Interface, error)
• func GetNodeVMUUID(k8sclient clientset.Interface, nodeName string) (string, error)
• func NewClient() (clientset.Interface, error)
• type InformerManager
  • func NewInformer(client clientset.Interface) *InformerManager
  • func (im *InformerManager) AddNodeListener(add func(obj interface{}), update func(oldObj, newObj interface{}), ...)
  • func (im *InformerManager) AddPVCListener(add func(obj interface{}), update func(oldObj, newObj interface{}), ...)
  • func (im *InformerManager) AddPVListener(add func(obj interface{}), update func(oldObj, newObj interface{}), ...)
  • func (im *InformerManager) AddPodListener(add func(obj interface{}), update func(oldObj, newObj interface{}), ...)
  • func (im *InformerManager) GetPVCLister() corelisters.PersistentVolumeClaimLister
  • func (im *InformerManager) GetPVLister() corelisters.PersistentVolumeLister
  • func (im *InformerManager) GetVALister() storagelistersv1.VolumeAttachmentLister
  • func (im *InformerManager) Listen() (stopCh <-chan struct{})

Functions

func CreateKubernetesClientFromConfig

func CreateKubernetesClientFromConfig(kubeConfigPath string) (clientset.Interface, error)

CreateKubernetesClientFromConfig creaates a newk8s client from given kubeConfig file

func GetNodeVMUUID

func GetNodeVMUUID(k8sclient clientset.Interface, nodeName string) (string, error)

GetNodeVMUUID returns vSphere VM UUID set by CCM on the Kubernetes Node

func NewClient

func NewClient() (clientset.Interface, error)

NewClient creates a newk8s client based on a service account

Types

type InformerManager

type InformerManager struct {
	// contains filtered or unexported fields
}

InformerManager is a service that notifies subscribers about changes to well-defined information in the Kubernetes API server.

func NewInformer

func NewInformer(client clientset.Interface) *InformerManager

NewInformer creates a new K8S client based on a service account

func (*InformerManager) AddNodeListener

func (im *InformerManager) AddNodeListener(add func(obj interface{}), update func(oldObj, newObj interface{}), remove func(obj interface{}))

AddNodeListener hooks up add, update, delete callbacks

func (*InformerManager) AddPVCListener

func (im *InformerManager) AddPVCListener(add func(obj interface{}), update func(oldObj, newObj interface{}), remove func(obj interface{}))

AddPVCListener hooks up add, update, delete callbacks

func (*InformerManager) AddPVListener

func (im *InformerManager) AddPVListener(add func(obj interface{}), update func(oldObj, newObj interface{}), remove func(obj interface{}))

AddPVListener hooks up add, update, delete callbacks

func (*InformerManager) AddPodListener

func (im *InformerManager) AddPodListener(add func(obj interface{}), update func(oldObj, newObj interface{}), remove func(obj interface{}))

AddPodListener hooks up add, update, delete callbacks

func (*InformerManager) GetPVCLister

func (im *InformerManager) GetPVCLister() corelisters.PersistentVolumeClaimLister

GetPVCLister returns PVC Lister for the calling informer manager

func (*InformerManager) GetPVLister

func (im *InformerManager) GetPVLister() corelisters.PersistentVolumeLister

GetPVLister returns Persistent Volume Lister for the calling informer manager

func (*InformerManager) GetVALister

func (im *InformerManager) GetVALister() storagelistersv1.VolumeAttachmentLister

GetVALister returns VolumeAttachment Lister for the calling informer manager

func (*InformerManager) Listen

func (im *InformerManager) Listen() (stopCh <-chan struct{})

Listen starts the Informers