Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,405 for Instances (0.36 sec)

  1. pkg/scheduler/framework/plugins/dynamicresources/structuredparameters_test.go

    								{
    									Instance: &resourceapi.NamedResourcesInstance{Name: "X"},
    								},
    								{
    									Instance: &resourceapi.NamedResourcesInstance{Name: "Y"},
    								},
    							},
    						},
    					},
    					"driver-b": {
    						NamedResources: namedresourcesmodel.Model{
    							Instances: []namedresourcesmodel.InstanceAllocation{
    								{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 27 09:27:01 UTC 2024
    - 34.8K bytes
    - Viewed (0)
  2. pkg/test/framework/components/echo/deployment/builder.go

    }
    
    func assignRefs(refs []*echo.Instance, instances echo.Instances) error {
    	if len(refs) != len(instances) {
    		return fmt.Errorf("cannot set %d references, only %d instances were built", len(refs), len(instances))
    	}
    	for i, ref := range refs {
    		if ref != nil {
    			*ref = instances[i]
    		}
    	}
    	return nil
    }
    
    func (b *builder) BuildOrFail(t test.Failer) echo.Instances {
    	t.Helper()
    	out, err := b.Build()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 12K bytes
    - Viewed (0)
  3. pkg/test/framework/components/echo/echotest/filters_test.go

    			filter: func(instances echo.Instances) echo.Instances {
    				return echotest.ReachableDestinations(naked1, instances)
    			},
    			expect: echo.Instances{
    				// only same network/cluster, no VMs
    				a1, a1Ns2, b1, c1, headless1, naked1, external1,
    			},
    		},
    		"ReachableDestinations from vm": {
    			filter: func(instances echo.Instances) echo.Instances {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  4. pkg/test/framework/components/echo/echotest/run.go

    // destination instance. This is for ingress gateway testing when source instance
    // destination instances. This can be used when we're not using echo workloads
    // as the source of traffic, such as from the ingress gateway. For example:
    //
    //	RunFromClusters(func(t framework.TestContext, src cluster.Cluster, dst echo.Instances)) {
    //	  ingr := ist.IngressFor(src)
    //	  ingr.CallWithRetryOrFail(...)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Sep 27 22:08:42 UTC 2023
    - 13K bytes
    - Viewed (0)
  5. subprojects/core/src/test/groovy/org/gradle/api/services/internal/DefaultBuildServicesRegistryTest.groovy

        static abstract class ServiceImpl implements BuildService<Params> {
            static List<ServiceImpl> instances = []
    
            String getProp() {
                return getParameters().prop
            }
    
            static void reset() {
                instances.clear()
            }
    
            ServiceImpl() {
                instances.add(this)
            }
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Jun 06 19:15:46 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/aggregate/controller_test.go

    		}
    	}
    
    	// Get Instances from mockAdapter2
    	instances = aggregateCtl.GetProxyServiceTargets(&model.Proxy{IPAddresses: []string{mock.MakeIP(mock.WorldService, 1)}})
    	if len(instances) != 6 {
    		t.Fatalf("Returned GetProxyServiceTargets' amount %d is not correct", len(instances))
    	}
    	for _, inst := range instances {
    		if inst.Service.Hostname != mock.WorldService.Hostname {
    			t.Fatal("Returned Instance is incorrect")
    		}
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 06:28:11 UTC 2024
    - 14.5K bytes
    - Viewed (0)
  7. pilot/pkg/serviceregistry/serviceentry/controller.go

    // got at t1 can accidentally override that got at t2 if multiple threads are
    // running this function. Queueing ensures latest updated wins.
    func (s *Controller) edsUpdate(instances []*model.ServiceInstance) {
    	// Find all keys we need to lookup
    	keys := sets.NewWithLength[instancesKey](len(instances))
    	for _, i := range instances {
    		keys.Insert(makeInstanceKey(i))
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  8. tests/integration/ambient/main_test.go

    	// Sidecar echo services with sidecar
    	Sidecar echo.Instances
    
    	// All echo services
    	All echo.Instances
    	// Echo services that are in the mesh
    	Mesh echo.Instances
    	// Echo services that are not in mesh
    	MeshExternal echo.Instances
    
    	MockExternal echo.Instances
    
    	// WaypointProxies by
    	WaypointProxies map[string]ambient.WaypointProxy
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 00:07:28 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  9. pkg/apis/resource/structured/namedresources/validation/validation_test.go

    	"k8s.io/apimachinery/pkg/util/validation/field"
    	resourceapi "k8s.io/kubernetes/pkg/apis/resource"
    	"k8s.io/utils/ptr"
    )
    
    func testResources(instances []resourceapi.NamedResourcesInstance) *resourceapi.NamedResourcesResources {
    	resources := &resourceapi.NamedResourcesResources{
    		Instances: instances,
    	}
    	return resources
    }
    
    func TestValidateResources(t *testing.T) {
    	goodName := "foo"
    	badName := "!@#$%^"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:13 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  10. tests/integration/security/sds_ingress/ingress_test.go

    			var (
    				credName = "testsingletlsgateway-secretrotation"
    				host     = "testsingletlsgateway-secretrotation.example.com"
    			)
    			allInstances := []echo.Instances{ingressutil.A, ingressutil.VM}
    			for _, instances := range allInstances {
    				echotest.New(t, instances).
    					SetupForDestination(func(t framework.TestContext, to echo.Target) error {
    						ingressutil.SetupConfig(t, echo1NS, ingressutil.TestConfig{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 32.7K bytes
    - Viewed (0)
Back to top