Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for NewListFunc (0.11 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    	versioner storage.Versioner
    
    	// newFunc is a function that creates new empty object storing a object of type Type.
    	newFunc func() runtime.Object
    
    	// newListFunc is a function that creates new empty list for storing objects of type Type.
    	newListFunc func() runtime.Object
    
    	// indexedTrigger is used for optimizing amount of watchers that needs to process
    	// an incoming event.
    	indexedTrigger *indexedTriggerFunc
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go

    	return atomic.SwapUint64(&r.reads, 0)
    }
    
    type setupOptions struct {
    	client         func(testing.TB) *clientv3.Client
    	codec          runtime.Codec
    	newFunc        func() runtime.Object
    	newListFunc    func() runtime.Object
    	prefix         string
    	resourcePrefix string
    	groupResource  schema.GroupResource
    	transformer    value.Transformer
    	leaseConfig    LeaseManagerConfig
    
    	recorderEnabled bool
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 26.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go

    		GroupResource:  schema.GroupResource{Resource: "pods"},
    		ResourcePrefix: setupOpts.resourcePrefix,
    		KeyFunc:        setupOpts.keyFunc,
    		GetAttrsFunc:   GetPodAttrs,
    		NewFunc:        newPod,
    		NewListFunc:    newPodList,
    		IndexerFuncs:   setupOpts.indexerFuncs,
    		Codec:          codecs.LegacyCodec(examplev1.SchemeGroupVersion),
    		Clock:          setupOpts.clock,
    	}
    	cacher, err := NewCacherFromConfig(config)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 17K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    	newFunc := func() runtime.Object { return &example.Pod{} }
    	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)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    			if err != nil {
    				return nil, nil, err
    			}
    			fieldsSet["spec.nodeName"] = pod.Spec.NodeName
    			return labelsSet, fieldsSet, nil
    		},
    		NewFunc:     func() runtime.Object { return &example.Pod{} },
    		NewListFunc: func() runtime.Object { return &example.PodList{} },
    		Codec:       codecs.LegacyCodec(examplev1.SchemeGroupVersion),
    		Clock:       clock.RealClock{},
    	}
    	cacher, err := NewCacherFromConfig(config)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
Back to top