- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for ClusterLocalFQDN (2.73 sec)
-
pkg/test/framework/components/echo/echotest/filters_test.go
// TODO if the destinations would change based on which cluster then add cluster to srCkey fromKey := from.Config().ClusterLocalFQDN() toKey := to.Config().ClusterLocalFQDN() if testTopology[fromKey] == nil { testTopology[fromKey] = map[string]int{} } testTopology[fromKey][toKey]++ }) },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 13.1K bytes - Viewed (0) -
tests/integration/security/egress_sidecar_tls_origination_test.go
matchLabels: app: {{.WorkloadSelector}} exportTo: - . host: "{{ .to.Config.ClusterLocalFQDN }}" trafficPolicy: portLevelSettings: - port: number: 80 tls: mode: {{.Mode}} credentialName: {{.CredentialName}} sni: {{ .to.Config.ClusterLocalFQDN }} ` t.ConfigIstio().Eval(clientNamespace.Name(), args, se, dr).ApplyOrFail(t, apply.NoCleanup) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 10.4K bytes - Viewed (0) -
tests/integration/security/egress_gateway_origination_test.go
- port: number: 443 tls: mode: ISTIO_MUTUAL sni: {{ .to.Config.ClusterLocalFQDN }} ` vs := ` apiVersion: networking.istio.io/v1beta1 kind: VirtualService metadata: name: route-via-egressgateway-sds spec: hosts: - {{ .to.Config.ClusterLocalFQDN }} gateways: - istio-egressgateway-sds - mesh http: - match: - gateways:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 15.4K bytes - Viewed (0) -
pkg/test/framework/components/echo/config.go
NamespacedName() NamespacedName // ServiceAccountName returns the service account string for this service. ServiceAccountName() string // ClusterLocalFQDN returns the fully qualified domain name for cluster-local host. ClusterLocalFQDN() string // ClusterSetLocalFQDN returns the fully qualified domain name for the Kubernetes // Multi-Cluster Services (MCS) Cluster Set host. ClusterSetLocalFQDN() string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 12:26:52 UTC 2024 - 18.2K bytes - Viewed (0) -
pkg/test/framework/components/echo/deployment/builder.go
return err } if existing, ok := services[cfg.ClusterLocalFQDN()]; ok { // we've already run the generation for another echo instance's config, make sure things are the same if existing != svc { return fmt.Errorf("inconsistency in %s Service definition:\n%s", cfg.Service, cmp.Diff(existing, svc)) } } services[cfg.ClusterLocalFQDN()] = svc } // Deploy the services to all clusters.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 12K bytes - Viewed (0) -
tests/integration/pilot/ingress_test.go
} templateParams := map[string]string{ "imagePullSecret": t.Settings().Image.PullSecretNameOrFail(t), "injectLabel": injectLabel, "host": apps.A.Config().ClusterLocalFQDN(), "imagePullPolicy": t.Settings().Image.PullPolicy, } t.NewSubTest("minimal").Run(func(t framework.TestContext) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 19.5K bytes - Viewed (0) -
pkg/test/framework/components/echo/calloptions.go
} // Next, if the Address was manually specified use it as the Host. if len(o.Address) > 0 { return o.Address } // Finally, use the target's FQDN. if o.To != nil { return o.To.Config().ClusterLocalFQDN() } return "" } func (o CallOptions) DeepCopy() CallOptions { clone := o if o.TLS.Alpn != nil { clone.TLS.Alpn = make([]string, len(o.TLS.Alpn)) copy(clone.TLS.Alpn, o.TLS.Alpn)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Oct 08 09:39:20 UTC 2023 - 13K bytes - Viewed (0) -
tests/integration/pilot/mcs/discoverability/discoverability_test.go
t.Helper() var address string if ht == hostTypeClusterSetLocal { // Call the service using the MCS ClusterSet host. address = to.Config().ClusterSetLocalFQDN() } else { address = to.Config().ClusterLocalFQDN() } _, err := from.Call(echo.CallOptions{ Address: address, To: to, Port: echo.Port{ Name: "http", }, Check: checker, Retry: echo.Retry{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 17.9K bytes - Viewed (0) -
tests/integration/pilot/tunneling_test.go
} }) } func testConnectivity(from, to echo.Instance, p protocol.Instance, port echo.Port, testName string) error { res, err := from.Call(echo.CallOptions{ Address: to.ClusterLocalFQDN(), Port: echo.Port{ Protocol: p, ServicePort: port.ServicePort, }, HTTP: echo.HTTP{ Path: "/" + testName, }, }) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/deployment.go
if err = ctx.ConfigKube(cfg.Cluster). YAML(cfg.Namespace.Name(), deploymentYAML). Apply(apply.NoCleanup); err != nil { return nil, fmt.Errorf("failed deploying echo %s to cluster %s: %v", cfg.ClusterLocalFQDN(), cfg.Cluster.Name(), err) } return &deployment{ ctx: ctx, cfg: cfg, shouldCreateWLE: cfg.DeployAsVM && !cfg.AutoRegisterVM, }, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 12:26:52 UTC 2024 - 24.1K bytes - Viewed (0)