Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for metalist (2.46 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go

    			}
    			err := store.GetList(ctx, tt.prefix, storageOpts, out)
    			if tt.expectRVTooLarge {
    				if err == nil || !apierrors.IsTimeout(err) || !storage.IsTooLargeResourceVersion(err) {
    					t.Fatalf("expecting resource version too high error, but get: %s", err)
    				}
    				return
    			}
    
    			if err != nil {
    				if !tt.expectError {
    					t.Fatalf("GetList failed: %v", err)
    				}
    				return
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 91.4K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    	backingStorage.injectError(errDummy)
    	err = cacher.GetList(context.TODO(), "pods/ns", storage.ListOptions{
    		ResourceVersion: "0",
    		Predicate:       pred,
    	}, result)
    	if err != nil {
    		t.Errorf("GetList with Limit and RV=0 should be served from cache: %v", err)
    	}
    
    	err = cacher.GetList(context.TODO(), "pods/ns", storage.ListOptions{
    		ResourceVersion: "",
    		Predicate:       pred,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  3. platforms/core-configuration/declarative-dsl-provider/src/testFixtures/groovy/org/gradle/internal/declarativedsl/settings/SoftwareTypeFixture.groovy

                        action.execute(getDependencies());
                    }
    
    
                    public abstract ListProperty<String> getList();
    
                    @Adding
                    public void addToList(String value) {
                        getList().add(value);
                    }
    
                    @Nested
                    public abstract Bar getBar();
    
                    @Configuring
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Jun 03 16:02:26 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go

    		t.Fatalf("Failed to initialize cacher: %v", err)
    	}
    	ctx := context.Background()
    	terminate := func() {
    		cacher.Stop()
    		server.Terminate(t)
    	}
    
    	// Since some tests depend on the fact that GetList shouldn't fail,
    	// we wait until the error from the underlying storage is consumed.
    	if err := wait.PollInfinite(100*time.Millisecond, wrappedStorage.ErrorsConsumed); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 17K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go

    	_, watchErr := store.Watch(ctx, invalidKey, storage.ListOptions{})
    	expectInvalidKey("Watch", watchErr)
    	expectInvalidKey("Get", store.Get(ctx, invalidKey, storage.GetOptions{}, nil))
    	expectInvalidKey("GetList", store.GetList(ctx, invalidKey, storage.ListOptions{}, nil))
    	expectInvalidKey("GuaranteedUpdate", store.GuaranteedUpdate(ctx, invalidKey, nil, true, nil, nil, nil))
    	_, countErr := store.Count(invalidKey)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 26.5K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    }
    
    // GetList implements storage.Interface
    func (c *Cacher) GetList(ctx context.Context, key string, opts storage.ListOptions, listObj runtime.Object) error {
    	recursive := opts.Recursive
    	resourceVersion := opts.ResourceVersion
    	pred := opts.Predicate
    	if shouldDelegateList(opts) {
    		return c.storage.GetList(ctx, key, opts, listObj)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    }
    
    type storageWithCounter struct {
    	storage.Interface
    
    	listCounter int64
    }
    
    func (s *storageWithCounter) GetList(ctx context.Context, key string, opts storage.ListOptions, listObj runtime.Object) error {
    	atomic.AddInt64(&s.listCounter, 1)
    	return s.Interface.GetList(ctx, key, opts, listObj)
    }
    
    func TestStoreDeleteCollection(t *testing.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)
  8. tensorflow/compiler/mlir/lite/flatbuffer_export.cc

      // index in the subgraph list.
      int subgraph_index = 0;
      for (const auto& signature_def_data : signature_defs) {
        auto inputs = GetList(subgraph_index, signature_def_data.inputs);
        auto outputs = GetList(subgraph_index, signature_def_data.outputs);
        auto inputs_buf = builder_.CreateVector(inputs);
        auto outputs_buf = builder_.CreateVector(outputs);
        auto signature_key_buf =
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Jun 12 21:41:49 UTC 2024
    - 164.5K bytes
    - Viewed (2)
  9. CHANGELOG/CHANGELOG-1.28.md

    - `kube-apiserver`: Improved memory use when performing `GetList` on the cache. ([#116327](https://github.com/kubernetes/kubernetes/pull/116327), [@sxllwx](https://github.com/sxllwx))
    - `kube-controller-manager` and `cloud-controller-manager` have changed the
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 23:47:59 UTC 2024
    - 408.3K bytes
    - Viewed (1)
Back to top