garbagecollector

Sep 28, 2017

Changes in this version

+ func GetDeletableResources(discoveryClient discovery.DiscoveryInterface) (map[schema.GroupVersionResource]struct{}, error)

type GarbageCollector

+ func (gc *GarbageCollector) IsSynced() bool

+ func (gc *GarbageCollector) Sync(discoveryClient discovery.DiscoveryInterface, period time.Duration, ...)

type GraphBuilder

+ func (gb *GraphBuilder) IsSynced() bool

Jun 29, 2017

Changes in this version

+ func DefaultIgnoredResources() map[schema.GroupResource]struct

Mar 28, 2017

Changes in this version

type GarbageCollector

+ func (gc *GarbageCollector) HasSynced() bool

+ type GraphBuilder struct

+ func (gb *GraphBuilder) HasSynced() bool

+ func (gb *GraphBuilder) Run(stopCh <-chan struct{})

Sep 26, 2016

Changes in this version

+ const DirtyProcessingLatencyKey

+ const EventProcessingLatencyKey

+ const GarbageCollectSubsystem

+ const OrphanProcessingLatencyKey

+ var DirtyProcessingLatency = prometheus.NewSummary(prometheus.SummaryOpts{ ... })

+ var EventProcessingLatency = prometheus.NewSummary(prometheus.SummaryOpts{ ... })

+ var OrphanProcessingLatency = prometheus.NewSummary(prometheus.SummaryOpts{ ... })

+ func Register()

+ type RegisteredRateLimiter struct

+ func NewRegisteredRateLimiter(resources []unversioned.GroupVersionResource) *RegisteredRateLimiter

+ type UIDCache struct

+ func NewUIDCache(maxCacheEntries int) *UIDCache

+ func (c *UIDCache) Add(uid types.UID)

+ func (c *UIDCache) Has(uid types.UID) bool

Jul 1, 2016

Changes in this version

+ const ResourceResyncTime

+ type GarbageCollector struct

+ func NewGarbageCollector(clientPool dynamic.ClientPool, resources []unversioned.GroupVersionResource) (*GarbageCollector, error)

+ func (gc *GarbageCollector) GraphHasUID(UIDs []types.UID) bool

+ func (gc *GarbageCollector) QueuesDrained() bool

+ func (gc *GarbageCollector) Run(workers int, stopCh <-chan struct{})

+ type Propagator struct