- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for ForResource (0.22 sec)
-
pkg/controller/resourcequota/resource_quota_monitor.go
} event := &event{ eventType: deleteEvent, obj: obj, gvr: resource, } qm.resourceChanges.Add(event) }, } shared, err := qm.informerFactory.ForResource(resource) if err == nil { logger.V(4).Info("QuotaMonitor using a shared informer", "resource", resource.String()) shared.Informer().AddEventHandlerWithResyncPeriod(handlers, qm.resyncPeriod())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler_test.go
utilruntime.Must(scheme.SetVersionPriority(corev1.SchemeGroupVersion)) codecs := serializer.NewCodecFactory(scheme) sc.Codec = apitesting.TestStorageCodec(codecs, corev1.SchemeGroupVersion) config := *sc.ForResource(schema.GroupResource{Resource: "endpoints"}) baseKey := "/" + uuid.New().String() + "/peer-testleases/" leaseTime := 1 * time.Minute reconciler, err := reconcilers.NewPeerEndpointLeaseReconciler(&config, baseKey, leaseTime)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 10.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/etcd.go
type SimpleStorageFactory struct { StorageConfig storagebackend.Config } func (s *SimpleStorageFactory) NewConfig(resource schema.GroupResource) (*storagebackend.ConfigForResource, error) { return s.StorageConfig.ForResource(resource), nil } func (s *SimpleStorageFactory) ResourcePrefix(resource schema.GroupResource) string { return resource.Group + "/" + resource.Resource }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 15:02:16 UTC 2024 - 20K bytes - Viewed (0) -
cmd/kube-controller-manager/app/core.go
discoveryFunc := resourceQuotaControllerDiscoveryClient.ServerPreferredNamespacedResources listerFuncForResource := generic.ListerFuncForResourceFunc(controllerContext.InformerFactory.ForResource) quotaConfiguration := quotainstall.NewQuotaConfigurationForControllers(listerFuncForResource) resourceQuotaControllerOptions := &resourcequotacontroller.ControllerOptions{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 39K bytes - Viewed (0) -
pkg/controller/garbagecollector/graph_builder.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
src/cmd/trace/gstate.go
"strings" ) // resource is a generic constraint interface for resource IDs. type resource interface { trace.GoID | trace.ProcID | trace.ThreadID } // noResource indicates the lack of a resource. const noResource = -1 // gState represents the trace viewer state of a goroutine in a trace. // // The type parameter on this type is the resource which is used to construct
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 11.9K bytes - Viewed (0) -
src/cmd/trace/gen.go
ctx.TaskArrow(traceviewer.ArrowEvent{ Name: "newTask", Start: ctx.elapsed(task.Start.Time()), End: ctx.elapsed(task.Start.Time()), FromResource: uint64(task.Parent.ID), ToResource: uint64(task.ID), FromStack: ctx.Stack(viewerFrames(task.Start.Stack())), }) } } // emitRegion emits goroutine-based slice events to the UI. The caller
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 11.5K bytes - Viewed (0)