Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for batch_func (0.17 sec)

  1. pkg/config/schema/kubeclient/common.go

    					options.FieldSelector = opts.FieldSelector
    					options.LabelSelector = opts.LabelSelector
    					return c.Dynamic().Resource(g).Namespace(opts.Namespace).List(context.Background(), options)
    				},
    				WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) {
    					options.FieldSelector = opts.FieldSelector
    					options.LabelSelector = opts.LabelSelector
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 16:38:40 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  2. pkg/kubelet/util/manager/watch_based_manager.go

    		return c.listObject(namespace, options)
    	}
    	watchFunc := func(options metav1.ListOptions) (watch.Interface, error) {
    		options.FieldSelector = fieldSelector
    		return c.watchObject(namespace, options)
    	}
    	store := c.newStore()
    	reflector := cache.NewReflectorWithOptions(
    		&cache.ListWatch{ListFunc: listFunc, WatchFunc: watchFunc},
    		c.newObject(),
    		store,
    		cache.ReflectorOptions{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  3. tensorflow/compiler/mlir/lite/transforms/lower_static_tensor_list.cc

                                ConversionPatternRewriter *rewriter) const {
        auto guard = OpBuilder::InsertionGuard(*rewriter);
        auto inputs = branch_func.getFunctionType().getInputs();
        Block *block = rewriter->createBlock(
            &branch_func.getBody(), branch_func.begin(), inputs,
            SmallVector<Location>(inputs.size(), branch_func.getLoc()));
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Jun 11 20:00:43 UTC 2024
    - 70.7K bytes
    - Viewed (0)
  4. pkg/config/schema/codegen/templates/clients.go.tmpl

    				ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
    					options.FieldSelector = opts.FieldSelector
    					options.LabelSelector = opts.LabelSelector
    					return l(options)
    				},
    				WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) {
    					options.FieldSelector = opts.FieldSelector
    					options.LabelSelector = opts.LabelSelector
    					return w(options)
    				},
    			},
    			gvrToObject(g),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 13:57:51 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  5. tensorflow/compiler/jit/extract_outside_compilation_pass.cc

               std::vector<string>{"then_branch", "else_branch"}) {
            NameAttrList branch_func;
            TF_RETURN_IF_ERROR(GetNodeAttr(n->attrs(), attr_name, &branch_func));
            (*branch_func.mutable_attr())["_device_ordinal"] = device_ordinal_value;
            n->ClearAttr(attr_name);
            n->AddAttr(attr_name, branch_func);
          }
        } else if (n->IsWhileNode()) {
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Mar 12 06:33:33 UTC 2024
    - 104.7K bytes
    - Viewed (0)
  6. pilot/pkg/config/kube/crdclient/client.go

    	}
    	return meta.GetResourceVersion(), nil
    }
    
    // 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.
    func (cl *Client) Patch(orig config.Config, patchFn config.PatchFunc) (string, error) {
    	modified, patchType := patchFn(orig.DeepCopy())
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 00:12:28 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  7. pkg/config/model.go

    func (g GroupVersionKind) CanonicalGroup() string {
    	return CanonicalGroup(g.Group)
    }
    
    // PatchFunc provides the cached config as a base for modification. Only diff the between the cfg
    // parameter and the returned Config will be applied.
    type PatchFunc func(cfg Config) (Config, kubetypes.PatchType)
    
    type Namer interface {
    	GetName() string
    	GetNamespace() string
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/admission_test.go

    		}
    		f.DefinitionMatchFuncs[key] = matchFunc
    	}
    }
    
    func (f *fakeMatcher) RegisterBinding(binding *admissionregistrationv1.ValidatingAdmissionPolicyBinding, matchFunc func(generic.BindingAccessor, admission.Attributes) bool) {
    	namespace, name := binding.Namespace, binding.Name
    	key := types.NamespacedName{
    		Name:      name,
    		Namespace: namespace,
    	}
    
    	if matchFunc != nil {
    		if f.BindingMatchFuncs == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 25 01:39:01 UTC 2024
    - 63.8K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top