Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for ForResource (0.22 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. pkg/controller/garbagecollector/graph_builder.go

    			}
    			event := &event{
    				eventType: deleteEvent,
    				obj:       obj,
    				gvk:       kind,
    			}
    			gb.graphChanges.Add(event)
    		},
    	}
    
    	shared, err := gb.sharedInformers.ForResource(resource)
    	if err != nil {
    		logger.V(4).Error(err, "unable to use a shared informer", "resource", resource, "kind", kind)
    		return nil, nil, err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  6. 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)
  7. 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)
Back to top