Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for batch_func (0.35 sec)

  1. tensorflow/compiler/mlir/tensorflow/tests/freeze_variables.mlir

      // Make sure that `operandSegmentSizes` attribute is also updated.
      // CHECK-NEXT: %[[BATCH_FUNC:.*]]:2 = "tf.BatchFunction"(%[[ARG_1]]) <{{{.*operandSegmentSizes = array<i32: 1, 0>.*}}}> : (tensor<1xf32>) -> (tensor<*xf32>, tensor<*xf32>)
      // CHECK: return %[[BATCH_FUNC]]#0, %[[BATCH_FUNC]]#1 : tensor<*xf32>, tensor<*xf32>
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Mon Oct 30 06:52:55 UTC 2023
    - 23.6K 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. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top