- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,405 for Instances (0.36 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)