controller

Documentation

Index

• func NewPodController(name string, kubeClient *kubernetes.Clientset, ...) *slavePodController
• type Metadata
• type MetadataCache
  • func (cache *MetadataCache) Delete(key client.ObjectKey)
  • func (cache *MetadataCache) Done(key client.ObjectKey, metadata Metadata)
  • func (cache *MetadataCache) Get(key client.ObjectKey) (Metadata, bool)
  • func (cache *MetadataCache) Set(key client.ObjectKey, metadata Metadata)

Functions

func NewPodController

func NewPodController(name string, kubeClient *kubernetes.Clientset, podInformer cache.SharedIndexInformer) *slavePodController

Types

type Metadata

type Metadata struct {
	Labels          map[string]string       `json:"labels,omitempty"`
	Annotations     map[string]string       `json:"annotations,omitempty"`
	OwnerReferences []metav1.OwnerReference `json:"ownerReferences,omitempty"`
}

type MetadataCache

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

func (*MetadataCache) Delete

func (cache *MetadataCache) Delete(key client.ObjectKey)

func (*MetadataCache) Done

func (cache *MetadataCache) Done(key client.ObjectKey, metadata Metadata)

func (*MetadataCache) Get

func (cache *MetadataCache) Get(key client.ObjectKey) (Metadata, bool)

func (*MetadataCache) Set

func (cache *MetadataCache) Set(key client.ObjectKey, metadata Metadata)