Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 150 for newFunc (0.18 sec)

  1. staging/src/k8s.io/apiserver/pkg/registry/generic/storage_decorator.go

    	resourcePrefix string,
    	keyFunc func(obj runtime.Object) (string, error),
    	newFunc func() runtime.Object,
    	newListFunc func() runtime.Object,
    	getAttrsFunc storage.AttrFunc,
    	trigger storage.IndexerFuncs,
    	indexers *cache.Indexers) (storage.Interface, factory.DestroyFunc, error) {
    	return NewRawStorage(config, newFunc, newListFunc, resourcePrefix)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  2. test/closure.go

    	memstats := new(runtime.MemStats)
    	runtime.ReadMemStats(memstats)
    	n0 := memstats.Mallocs
    
    	x, y := newfunc(), newfunc()
    	if x(1) != 1 || y(2) != 2 {
    		println("newfunc returned broken funcs")
    		fail = true
    	}
    
    	runtime.ReadMemStats(memstats)
    	if n0 != memstats.Mallocs {
    		println("newfunc allocated unexpectedly")
    		fail = true
    	}
    
    	ff(1)
    
    	if fail {
    		panic("fail")
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Jul 01 17:59:50 UTC 2012
    - 1.7K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/storage_factory.go

    			klogV.InfoS("Storage caching is enabled", objectTypeToArgs(newFunc())...)
    		}
    
    		cacherConfig := cacherstorage.Config{
    			Storage:        s,
    			Versioner:      storage.APIObjectVersioner{},
    			GroupResource:  storageConfig.GroupResource,
    			ResourcePrefix: resourcePrefix,
    			KeyFunc:        keyFunc,
    			NewFunc:        newFunc,
    			NewListFunc:    newListFunc,
    			GetAttrsFunc:   getAttrsFunc,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  4. src/cmd/compile/internal/typecheck/export.go

    	"cmd/compile/internal/ir"
    	"cmd/compile/internal/types"
    	"cmd/internal/src"
    )
    
    // importfunc declares symbol s as an imported function with type t.
    func importfunc(s *types.Sym, t *types.Type) {
    	fn := ir.NewFunc(src.NoXPos, src.NoXPos, s, t)
    	importsym(fn.Nname)
    }
    
    // importvar declares symbol s as an imported variable with type t.
    func importvar(s *types.Sym, t *types.Type) {
    	n := ir.NewNameAt(src.NoXPos, s, t)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Aug 17 19:36:28 UTC 2023
    - 838 bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease_test.go

    	t.Cleanup(func() { server.Terminate(t) })
    
    	newFunc := func() runtime.Object { return &corev1.Endpoints{} }
    	newListFunc := func() runtime.Object { return &corev1.EndpointsList{} }
    	sc.Codec = apitesting.TestStorageCodec(codecs, corev1.SchemeGroupVersion)
    
    	s, dFunc, err := factory.Create(*sc.ForResource(schema.GroupResource{Resource: "endpoints"}), newFunc, newListFunc, "")
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  6. pkg/kube/informerfactory/factory.go

    	Start(stopCh <-chan struct{})
    
    	// InformerFor returns the SharedIndexInformer the provided type.
    	InformerFor(resource schema.GroupVersionResource, opts kubetypes.InformerOptions, newFunc NewInformerFunc) StartableInformer
    
    	// WaitForCacheSync blocks until all started informers' caches were synced
    	// or the stop channel gets closed.
    	WaitForCacheSync(stopCh <-chan struct{}) bool
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/factory.go

    func Create(c storagebackend.ConfigForResource, newFunc, newListFunc func() runtime.Object, resourcePrefix string) (storage.Interface, DestroyFunc, error) {
    	switch c.Type {
    	case storagebackend.StorageTypeETCD2:
    		return nil, nil, fmt.Errorf("%s is no longer a supported storage backend", c.Type)
    	case storagebackend.StorageTypeUnset, storagebackend.StorageTypeETCD3:
    		return newETCD3Storage(c, newFunc, newListFunc, resourcePrefix)
    	default:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/internalinterfaces/factory_interfaces.go

    // SharedInformerFactory a small interface to allow for adding an informer without an import cycle
    type SharedInformerFactory interface {
    	Start(stopCh <-chan struct{})
    	InformerFor(obj runtime.Object, newFunc NewInformerFunc) cache.SharedIndexInformer
    }
    
    // TweakListOptionsFunc is a function that transforms a v1.ListOptions.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 16 22:25:28 UTC 2018
    - 1.4K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/internalinterfaces/factory_interfaces.go

    // SharedInformerFactory a small interface to allow for adding an informer without an import cycle
    type SharedInformerFactory interface {
    	Start(stopCh <-chan struct{})
    	InformerFor(obj runtime.Object, newFunc NewInformerFunc) cache.SharedIndexInformer
    }
    
    // TweakListOptionsFunc is a function that transforms a v1.ListOptions.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 16 22:25:28 UTC 2018
    - 1.4K bytes
    - Viewed (0)
  10. pkg/registry/rbac/role/storage/storage.go

    	*genericregistry.Store
    }
    
    // NewREST returns a RESTStorage object that will work against Role objects.
    func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, error) {
    	store := &genericregistry.Store{
    		NewFunc:                   func() runtime.Object { return &rbac.Role{} },
    		NewListFunc:               func() runtime.Object { return &rbac.RoleList{} },
    		DefaultQualifiedResource:  rbac.Resource("roles"),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 18 09:21:13 UTC 2022
    - 1.8K bytes
    - Viewed (0)
Back to top