Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 31 for ForResource (0.36 sec)

  1. 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)
  2. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler_test.go

    	etcdOptions := options.NewEtcdOptions(storageConfig)
    	etcdOptions.StorageConfig.Codec = unstructured.UnstructuredJSONScheme
    	restOptionsGetter := generic.RESTOptions{
    		StorageConfig:           etcdOptions.StorageConfig.ForResource(schema.GroupResource{Group: crd.Spec.Group, Resource: crd.Spec.Names.Plural}),
    		Decorator:               generic.UndecoratedStorage,
    		EnableGarbageCollection: true,
    		DeleteCollectionWorkers: 1,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 13 15:27:39 UTC 2023
    - 34.6K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    	newListFunc := func() runtime.Object { return &example.PodList{} }
    
    	sc.Codec = apitesting.TestStorageCodec(codecs, examplev1.SchemeGroupVersion)
    	s, dFunc, err := factory.Create(*sc.ForResource(schema.GroupResource{Resource: "pods"}), newFunc, newListFunc, "/pods")
    	if err != nil {
    		t.Fatalf("Error creating storage: %v", err)
    	}
    	destroyFunc := func() {
    		dFunc()
    		server.Terminate(t)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  6. 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)
  7. src/internal/trace/traceviewer/emitter.go

    	e.OptionalEvent(&format.Event{
    		Name:  a.Name,
    		Phase: "t",
    		TID:   a.ToResource,
    		PID:   sectionID,
    		ID:    e.arrowSeq,
    		Time:  viewerTime(a.End),
    	})
    }
    
    type ArrowEvent struct {
    	Name         string
    	Start        time.Duration
    	End          time.Duration
    	FromResource uint64
    	FromStack    int
    	ToResource   uint64
    }
    
    func (e *Emitter) Event(ev *format.Event) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 21 21:29:58 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  8. pkg/auth/authorizer/abac/abac_test.go

    		 {"apiVersion":"abac.authorization.kubernetes.io/v1beta1","kind":"Policy","spec":{"user":"noresource",                                                                         "nonResourcePath": "*"}}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Sep 24 15:14:54 UTC 2019
    - 40K bytes
    - Viewed (0)
  9. pkg/registry/core/service/storage/storage_test.go

    	etcdStorage, server := registrytest.NewEtcdStorage(t, "")
    	restOptions := generic.RESTOptions{
    		StorageConfig:           etcdStorage.ForResource(schema.GroupResource{Resource: "services"}),
    		Decorator:               generic.UndecoratedStorage,
    		DeleteCollectionWorkers: 1,
    		ResourcePrefix:          "services",
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 440.2K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java

                                .numOfFragments(numOfFragments).boundaryChars(boundaryChars).boundaryMaxScan(boundaryMaxScan)
                                .boundaryScannerType(boundaryScannerType).forceSource(forceSource).fragmenter(fragmenter)
                                .fragmentOffset(fragmentOffset).noMatchSize(noMatchSize).order(order).phraseLimit(phraseLimit))
                        .encoder(encoder)));
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 84.1K bytes
    - Viewed (0)
Back to top