- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for ServiceName (0.49 sec)
-
pilot/pkg/model/endpointshards.go
func (e *EndpointIndex) deleteServiceInner(shard ShardKey, serviceName, namespace string, preserveKeys bool) { if e.shardsBySvc[serviceName] == nil || e.shardsBySvc[serviceName][namespace] == nil { return } epShards := e.shardsBySvc[serviceName][namespace] epShards.Lock() delete(epShards.Shards, shard) // Clear the cache here to avoid race in cache writes. e.clearCacheForService(serviceName, namespace) if !preserveKeys {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
tests/integration/ambient/testdata/gateway-api.yaml
kind: Gateway metadata: name: {{ .To.ServiceName }}-gateway spec: gatewayClassName: istio listeners: - name: http port: 80 protocol: HTTP hostname: "*.{{ .To.ServiceName }}.com" --- apiVersion: gateway.networking.k8s.io/v1beta1 kind: HTTPRoute metadata: name: {{ .To.ServiceName }} spec: parentRefs: - name: {{ .To.ServiceName }}-gateway hostnames:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 21:02:05 UTC 2024 - 574 bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
client, esController := newController(t, []string{"node-1"}, time.Duration(0)) ns := metav1.NamespaceDefault serviceName := "testing-1" service := createService(t, esController, ns, serviceName) logger, _ := ktesting.NewTestContext(t) err := esController.syncService(logger, fmt.Sprintf("%s/%s", ns, serviceName)) assert.Nil(t, err, "Expected no error syncing service") gvk := schema.GroupVersionKind{Version: "v1", Kind: "Service"}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
tests/integration/ambient/main_test.go
// All does not include external echos = match.Not(match.ServiceName(echo.NamespacedName{Name: cdeployment.ExternalSvc, Namespace: apps.ExternalNamespace})).GetMatches(echos) apps.All = echos apps.WorkloadAddressedWaypoint = match.ServiceName(echo.NamespacedName{Name: WorkloadAddressedWaypoint, Namespace: apps.Namespace}).GetMatches(echos)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 00:07:28 UTC 2024 - 10.8K bytes - Viewed (0) -
tests/integration/ambient/wasm_test.go
name: "gateway-wasm-test", testHostname: fmt.Sprintf("%s-gateway-istio.%s.svc.cluster.local", GetTarget().ServiceName(), apps.Namespace.Name()), targetType: "gateway", targetName: fmt.Sprintf("%s-gateway", GetTarget().(echo.Instances).ServiceName()), }, { desc: "Configure WebAssembly filter for waypoint", name: "waypoint-wasm-test",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 21:02:05 UTC 2024 - 7.2K bytes - Viewed (0) -
tests/integration/ambient/cnirepair/main_test.go
} apps.All = echos apps.Uncaptured = match.ServiceName(echo.NamespacedName{Name: Uncaptured, Namespace: apps.Namespace}).GetMatches(echos) apps.Captured = match.ServiceName(echo.NamespacedName{Name: Captured, Namespace: apps.Namespace}).GetMatches(echos) apps.Sidecar = match.ServiceName(echo.NamespacedName{Name: Sidecar, Namespace: apps.Namespace}).GetMatches(echos) return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Jun 09 09:12:45 UTC 2024 - 5.6K bytes - Viewed (0) -
pkg/test/framework/components/prometheus/kube.go
"istio.io/istio/pkg/test/framework/resource" "istio.io/istio/pkg/test/framework/resource/config/apply" testKube "istio.io/istio/pkg/test/kube" "istio.io/istio/pkg/test/scopes" ) const ( serviceName = "prometheus" appName = "prometheus" ) var ( _ Instance = &kubeComponent{} _ io.Closer = &kubeComponent{} ) type kubeComponent struct { id resource.ID
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 6.3K bytes - Viewed (0) -
tests/integration/ambient/waypoint_test.go
for _, src := range apps.All { src := src if !hboneClient(src) { // TODO if we hairpinning, don't skip here continue } t.NewSubTestf("from %s", src.ServiceName()).Run(func(t framework.TestContext) { if src.Config().HasSidecar() { t.Skip("TODO: sidecars don't properly handle use-waypoint") } for _, host := range apps.Captured.Config().HostnameVariants() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 11.4K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheBuildServiceIntegrationTest.groovy
outputDoesNotContain onFinishMessage } def "build service is restored"(String serviceName, boolean finalize, boolean finalizeOnRead) { given: def legacy = serviceName == null def propertyAnnotations = legacy ? """@$Internal.name""" : """@$ServiceReference.name("$serviceName")""" withCountingServicePlugin(true, propertyAnnotations)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 11:47:23 UTC 2024 - 29.1K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder_test.go
} if ec.GetType() == cluster.Cluster_EDS && ec.EdsClusterConfig.ServiceName != gc.EdsClusterConfig.ServiceName { t.Errorf("Unexpected service name in EDS config want %v, got %v", ec.EdsClusterConfig.ServiceName, gc.EdsClusterConfig.ServiceName) } if ec.CircuitBreakers != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 110.4K bytes - Viewed (0)