Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 33 for batch_func (0.23 sec)

  1. pilot/pkg/model/config.go

    	UpdateStatus(config config.Config) (newRevision string, err error)
    
    	// Patch applies only the modifications made in the PatchFunc rather than doing a full replace. Useful to avoid
    	// read-modify-write conflicts when there are many concurrent-writers to the same resource.
    	Patch(orig config.Config, patchFn config.PatchFunc) (string, error)
    
    	// Delete removes an object from the store by key
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 08:51:03 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  2. pilot/pkg/config/memory/store.go

    	return cfg.ResourceVersion, nil
    }
    
    func (cr *store) UpdateStatus(cfg config.Config) (string, error) {
    	return cr.Update(cfg)
    }
    
    func (cr *store) Patch(orig config.Config, patchFn config.PatchFunc) (string, error) {
    	cr.mutex.Lock()
    	defer cr.mutex.Unlock()
    
    	gvk := orig.GroupVersionKind
    	s, ok := cr.schemas.FindByGroupVersionKind(gvk)
    	if !ok {
    		return "", fmt.Errorf("unknown type %v", gvk)
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 26 01:14:27 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go

    		&cache.ListWatch{
    			ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
    				return policiesAndBindingsTracker.List(fakePolicyGVR, fakePolicyGVK, "")
    			},
    			WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) {
    				return policiesAndBindingsTracker.Watch(fakePolicyGVR, "")
    			},
    		},
    		Pexample,
    		30*time.Second,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 19K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_test.go

    	ListFunc  func(options metav1.ListOptions) (runtime.Object, error)
    	WatchFunc func(options metav1.ListOptions) (watch.Interface, error)
    }
    
    func (t *testLW) List(options metav1.ListOptions) (runtime.Object, error) {
    	return t.ListFunc(options)
    }
    func (t *testLW) Watch(options metav1.ListOptions) (watch.Interface, error) {
    	return t.WatchFunc(options)
    }
    
    func TestReflectorForWatchCache(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  5. pilot/pkg/model/authorization_test.go

    	return "not implemented", nil
    }
    
    func (fs *authzFakeStore) UpdateStatus(config.Config) (string, error) {
    	return "not implemented", nil
    }
    
    func (fs *authzFakeStore) Patch(orig config.Config, patchFn config.PatchFunc) (string, error) {
    	return "not implemented", nil
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  6. pilot/pkg/config/kube/ingress/controller.go

    	return "", errUnsupportedOp
    }
    
    func (c *controller) UpdateStatus(config.Config) (string, error) {
    	return "", errUnsupportedOp
    }
    
    func (c *controller) Patch(_ config.Config, _ config.PatchFunc) (string, error) {
    	return "", errUnsupportedOp
    }
    
    func (c *controller) Delete(_ config.GroupVersionKind, _, _ string, _ *string) error {
    	return errUnsupportedOp
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 03:53:05 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  7. tensorflow/compiler/mlir/tensorflow/analysis/side_effect_analysis.cc

        } else if (auto case_op = dyn_cast<CaseOp>(op)) {
          llvm::SmallVector<func::FuncOp, 4> branch_funcs;
          case_op.get_branch_functions(branch_funcs);
          for (auto branch_func : branch_funcs) {
            AddRegionSideEffectsForOp(branch_func.getBody(), op);
          }
        } else if (isa<tf_device::LaunchOp, tf_device::ClusterOp,
                       tf_executor::IslandOp, tf_executor::GraphOp, IfRegionOp,
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed May 15 09:04:13 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go

    	informer = &testInformer{SharedIndexInformer: cache.NewSharedIndexInformer(&cache.ListWatch{
    		ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
    			return tracker.List(fakeGVR, fakeGVK, "")
    		},
    		WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) {
    			return tracker.Watch(fakeGVR, "")
    		},
    	}, &unstructured.Unstructured{}, 30*time.Second, nil)}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 12 18:58:24 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  9. pilot/pkg/config/kube/gateway/controller.go

    }
    
    func (c *Controller) UpdateStatus(config config.Config) (newRevision string, err error) {
    	return "", errUnsupportedOp
    }
    
    func (c *Controller) Patch(orig config.Config, patchFn config.PatchFunc) (string, error) {
    	return "", errUnsupportedOp
    }
    
    func (c *Controller) Delete(typ config.GroupVersionKind, name, namespace string, _ *string) error {
    	return errUnsupportedOp
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Mar 30 05:26:03 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  10. cmd/kube-proxy/app/server_linux.go

    	lw := &cache.ListWatch{
    		ListFunc: func(options metav1.ListOptions) (object runtime.Object, e error) {
    			options.FieldSelector = fieldSelector
    			return client.CoreV1().Nodes().List(ctx, options)
    		},
    		WatchFunc: func(options metav1.ListOptions) (i watch.Interface, e error) {
    			options.FieldSelector = fieldSelector
    			return client.CoreV1().Nodes().Watch(ctx, options)
    		},
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 18.1K bytes
    - Viewed (0)
Back to top