- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for getController (0.15 sec)
-
platforms/core-execution/build-cache/src/test/groovy/org/gradle/caching/internal/controller/DefaultBuildCacheControllerTest.groovy
@Rule final TestNameTestDirectoryProvider tmpDir = new TestNameTestDirectoryProvider(getClass()) interface Local extends BuildCacheService, LocalBuildCacheService {} BuildCacheController getController(boolean disableRemoteOnError = true) { new DefaultBuildCacheController( new BuildCacheServicesConfiguration( Path.ROOT.path, local, localPush,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 05 22:18:26 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_monitor.go
if err == nil { logger.V(4).Info("QuotaMonitor using a shared informer", "resource", resource.String()) shared.Informer().AddEventHandlerWithResyncPeriod(handlers, qm.resyncPeriod()) return shared.Informer().GetController(), nil } logger.V(4).Error(err, "QuotaMonitor unable to use a shared informer", "resource", resource.String()) // TODO: if we can share storage with garbage collector, it may make sense to support other resources
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/controller/garbagecollector/graph_builder.go
// need to clone because it's from a shared cache shared.Informer().AddEventHandlerWithResyncPeriod(handlers, ResourceResyncTime) return shared.Informer().GetController(), shared.Informer().GetStore(), nil } // syncMonitors rebuilds the monitor set according to the supplied resources, // creating or deleting monitors as necessary. It will return any error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
pilot/pkg/status/distribution/reporter.go
r.mu.Lock() defer r.mu.Unlock() for xdsType := range types { key := GenStatusReporterMapKey(conID, xdsType) r.deleteKeyFromReverseMap(key) delete(r.status, key) } } func (r *Reporter) SetController(controller *Controller) { r.controller = controller
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 11.5K bytes - Viewed (0) -
pilot/pkg/bootstrap/configcontroller.go
// avoid concurrently calling of informer Run() for controller in controller.Start controller := distribution.NewController(s.kubeClient.RESTConfig(), args.Namespace, s.RWConfigStore, s.statusManager) s.statusReporter.SetController(controller) controller.Start(leaderStop) }).Run(stop) return nil }) } } func (s *Server) makeKubeConfigController(args *PilotArgs) *crdclient.Client { opts := crdclient.Option{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 14.1K bytes - Viewed (0)