Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for deltas (0.16 sec)

  1. pilot/pkg/networking/core/cluster.go

    		if dir == model.TrafficDirectionInbound {
    			// Append all inbound clusters because in both stow/delta we always build all inbound clusters.
    			// In reality, the delta building is only for outbound clusters. We need to revist here once we support delta for inbound.
    			// So deletedClusters.Difference(builtClusters) would give us the correct deleted inbound clusters.
    			deletedClusters.Insert(cluster)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  2. pilot/pkg/xds/delta.go

    	var logFiltered string
    	if !req.Delta.IsEmpty() && !requiresResourceNamesModification(w.TypeUrl) {
    		// Some types opt out of this and natively handle req.Delta
    		logFiltered = " filtered:" + strconv.Itoa(len(w.ResourceNames)-len(req.Delta.Subscribed))
    		w = &model.WatchedResource{
    			TypeUrl:       w.TypeUrl,
    			ResourceNames: req.Delta.Subscribed.UnsortedList(),
    		}
    	}
    
    	var res model.Resources
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  3. pilot/pkg/xds/deltatest.go

    		// Both SotW and Delta did not respond, nothing to compare
    		return
    	}
    	newByName := slices.GroupUnique(sotwRes, (*discovery.Resource).GetName)
    	curByName := slices.GroupUnique(current, (*discovery.Resource).GetName)
    
    	watched := sets.New(w.ResourceNames...)
    
    	details := fmt.Sprintf("last:%v sotw:%v delta:%v-%v", len(current), len(sotwRes), len(deltaRes), len(deleted))
    	wantDeleted := sets.New[string]()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  4. tensorflow/compiler/mlir/tf2xla/api/v2/legalize_tf_test.cc

      EXPECT_TRUE(result.ok());
      EXPECT_EQ(compilation_status.Delta(kMlirCombinedMlirSuccess), 1);
      EXPECT_EQ(compilation_status.Delta(kMlirCombinedMlirFailure), 0);
      EXPECT_EQ(compilation_status.Delta(kMlirCombinedOldSuccess), 1);
      EXPECT_EQ(compilation_status.Delta(kMlirCombinedOldFailure), 0);
      // Old bridge should never be called at all.
      EXPECT_EQ(compilation_status.Delta(kOldBridgeMlirFilteredFailure), 0);
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Jun 13 23:59:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  5. pilot/pkg/features/pilot.go

    	).Get()
    
    	// EnableUnsafeDeltaTest enables runtime checks to test Delta XDS efficiency. This should never be enabled in
    	// production.
    	EnableUnsafeDeltaTest = env.Register(
    		"UNSAFE_PILOT_ENABLE_DELTA_TEST",
    		false,
    		"If enabled, addition runtime tests for Delta XDS efficiency are added. "+
    			"These checks are extremely expensive, so this should be used only for testing, not production.",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/example.go

    	return
    }
    
    // Delete takes name of the example and deletes it. Returns an error if one occurs.
    func (c *examples) Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error {
    	return c.client.Delete().
    		Namespace(c.ns).
    		Resource("examples").
    		Name(name).
    		Body(&opts).
    		Do(ctx).
    		Error()
    }
    
    // DeleteCollection deletes a collection of objects.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 10:52:54 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1/customresourcedefinition.go

    }
    
    // Delete takes name of the customResourceDefinition and deletes it. Returns an error if one occurs.
    func (c *customResourceDefinitions) Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error {
    	return c.client.Delete().
    		Resource("customresourcedefinitions").
    		Name(name).
    		Body(&opts).
    		Do(ctx).
    		Error()
    }
    
    // DeleteCollection deletes a collection of objects.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 10:52:54 UTC 2024
    - 12K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1beta1/customresourcedefinition.go

    }
    
    // Delete takes name of the customResourceDefinition and deletes it. Returns an error if one occurs.
    func (c *customResourceDefinitions) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
    	return c.client.Delete().
    		Resource("customresourcedefinitions").
    		Name(name).
    		Body(&opts).
    		Do(ctx).
    		Error()
    }
    
    // DeleteCollection deletes a collection of objects.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 10:52:54 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  9. pkg/kubelet/kubelet_test.go

    		creates, deletes := manager.GetCounts(name)
    		switch i {
    		case 2:
    			if creates != 0 || deletes != 0 {
    				t.Errorf("expected 0 creation and 0 deletion of %q, got %d, %d", name, creates, deletes)
    			}
    		default:
    			if creates != 0 || deletes != 1 {
    				t.Errorf("expected 0 creation and one deletion of %q, got %d, %d", name, creates, deletes)
    			}
    		}
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  10. pilot/pkg/networking/core/cluster_test.go

    				proxy.PrevSidecarScope.SetDestinationRulesForTesting(tc.prevConfigs)
    			}
    			clusters, removed, delta := cg.DeltaClusters(proxy, tc.configUpdated,
    				&model.WatchedResource{ResourceNames: tc.watchedResourceNames})
    			if delta != tc.usedDelta {
    				t.Errorf("un expected delta, want %v got %v", tc.usedDelta, delta)
    			}
    			assert.Equal(t, removed, tc.removedClusters)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 108.8K bytes
    - Viewed (0)
Back to top