Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for batch_func (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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