gcworker

Documentation

Index

• func WaitForCacheSync(controllerName string, stopCh <-chan struct{}, ...) bool
• type InformerGC
  • func NewInformerGC(kubeClient clientset.Interface, backendStorage types.Storage, gt time.Duration) (*InformerGC, error)
  • func (ig *InformerGC) Run(stopCh <-chan struct{})

Functions

func WaitForCacheSync

func WaitForCacheSync(controllerName string, stopCh <-chan struct{}, cacheSyncs ...cache.InformerSynced) bool

This function was copied from package k8s.io/kubernetes/pkg/controller

Types

type InformerGC

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

func NewInformerGC

func NewInformerGC(kubeClient clientset.Interface, backendStorage types.Storage, gt time.Duration) (*InformerGC, error)

func (*InformerGC) Run

func (ig *InformerGC) Run(stopCh <-chan struct{})