- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 33 for batch_func (0.23 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)