Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 33 for batch_func (0.23 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/apiextensions/v1/customresourcedefinition.go

    				if tweakListOptions != nil {
    					tweakListOptions(&options)
    				}
    				return client.ApiextensionsV1().CustomResourceDefinitions().List(context.TODO(), options)
    			},
    			WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) {
    				if tweakListOptions != nil {
    					tweakListOptions(&options)
    				}
    				return client.ApiextensionsV1().CustomResourceDefinitions().Watch(context.TODO(), options)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 02:16:47 UTC 2020
    - 3.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/apiextensions/v1beta1/customresourcedefinition.go

    				if tweakListOptions != nil {
    					tweakListOptions(&options)
    				}
    				return client.ApiextensionsV1beta1().CustomResourceDefinitions().List(context.TODO(), options)
    			},
    			WatchFunc: func(options v1.ListOptions) (watch.Interface, error) {
    				if tweakListOptions != nil {
    					tweakListOptions(&options)
    				}
    				return client.ApiextensionsV1beta1().CustomResourceDefinitions().Watch(context.TODO(), options)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 02:16:47 UTC 2020
    - 3.9K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/cr/v1/example.go

    				if tweakListOptions != nil {
    					tweakListOptions(&options)
    				}
    				return client.CrV1().Examples(namespace).List(context.TODO(), options)
    			},
    			WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) {
    				if tweakListOptions != nil {
    					tweakListOptions(&options)
    				}
    				return client.CrV1().Examples(namespace).Watch(context.TODO(), options)
    			},
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 02:16:47 UTC 2020
    - 3.5K bytes
    - Viewed (0)
  4. pilot/pkg/config/memory/controller.go

    		c.monitor.ScheduleProcessEvent(ConfigEvent{
    			old:    *oldconfig,
    			config: config,
    			event:  model.EventUpdate,
    		})
    	}
    	return
    }
    
    func (c *Controller) Patch(orig config.Config, patchFn config.PatchFunc) (newRevision string, err error) {
    	cfg, typ := patchFn(orig.DeepCopy())
    	switch typ {
    	case types.MergePatchType:
    	case types.JSONPatchType:
    	default:
    		return "", fmt.Errorf("unsupported merge type: %s", typ)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 26 13:54:32 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/quota/v1/generic/evaluator.go

    func Matches(
    	resourceQuota *corev1.ResourceQuota, item runtime.Object,
    	matchFunc MatchingResourceNamesFunc, scopeFunc MatchesScopeFunc) (bool, error) {
    	if resourceQuota == nil {
    		return false, fmt.Errorf("expected non-nil quota")
    	}
    	// verify the quota matches on at least one resource
    	matchResource := len(matchFunc(quota.ResourceNames(resourceQuota.Status.Hard))) > 0
    	// by default, no scopes matches all
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 05 00:02:47 UTC 2023
    - 11.7K bytes
    - Viewed (0)
  6. 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)
  7. pilot/pkg/config/aggregate/config.go

    	if cr.writer == nil {
    		return "", errorUnsupported
    	}
    	return cr.writer.UpdateStatus(c)
    }
    
    func (cr *store) Patch(orig config.Config, patchFn config.PatchFunc) (string, error) {
    	if cr.writer == nil {
    		return "", errorUnsupported
    	}
    	return cr.writer.Patch(orig, patchFn)
    }
    
    type storeCache struct {
    	model.ConfigStore
    	caches []model.ConfigStoreController
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 26 01:14:27 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top