Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for PortForName (0.15 sec)

  1. pkg/test/framework/components/echo/config.go

    	// ClusterSetLocalFQDN returns the fully qualified domain name for the Kubernetes
    	// Multi-Cluster Services (MCS) Cluster Set host.
    	ClusterSetLocalFQDN() string
    
    	// PortForName is a short form for Config().Ports.MustForName().
    	PortForName(name string) Port
    }
    
    type VMDistro = string
    
    const (
    	UbuntuBionic VMDistro = "UbuntuBionic"
    	UbuntuNoble  VMDistro = "UbuntuNoble"
    	Debian12     VMDistro = "Debian12"
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 09 12:26:52 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  2. pkg/test/framework/components/echo/kube/instance.go

    }
    
    func (c *instance) Close() (err error) {
    	return c.workloadMgr.Close()
    }
    
    func (c *instance) NamespacedName() echo.NamespacedName {
    	return c.cfg.NamespacedName()
    }
    
    func (c *instance) PortForName(name string) echo.Port {
    	return c.cfg.Ports.MustForName(name)
    }
    
    func (c *instance) ServiceName() string {
    	return c.cfg.Service
    }
    
    func (c *instance) NamespaceName() string {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 16 18:55:23 UTC 2023
    - 9K bytes
    - Viewed (0)
  3. pkg/test/framework/components/echo/echotest/filters_test.go

    }
    
    func (f fakeInstance) ID() resource.ID {
    	panic("implement me")
    }
    
    func (f fakeInstance) NamespacedName() echo.NamespacedName {
    	return f.Config().NamespacedName()
    }
    
    func (f fakeInstance) PortForName(name string) echo.Port {
    	return f.Config().Ports.MustForName(name)
    }
    
    func (f fakeInstance) Config() echo.Config {
    	cfg := echo.Config(f)
    	_ = cfg.FillDefaults(nil)
    	return cfg
    }
    
    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. tests/integration/ambient/waypoint_test.go

    			t.ConfigKube().
    				New().
    				Eval(
    					apps.Namespace.Name(),
    					map[string]any{
    						"Service":   Captured,
    						"Namespace": apps.Namespace.Name(),
    						"Port":      apps.Captured.PortForName("http").ServicePort,
    					},
    					config).
    				ApplyOrFail(t, apply.CleanupConditionally)
    
    			retry.UntilSuccessOrFail(t, func() error {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  5. tests/integration/ambient/baseline_test.go

    								// TODO validate L7 processing/some headers indicating we reach the svc we wanted
    								from.CallOrFail(t, echo.CallOptions{
    									Address: "111.111.222.222",
    									Port:    to.PortForName("http"),
    									// If request is sent before service is processed it will hit 10s timeout, so fail faster
    									Timeout: time.Millisecond * 500,
    								})
    							})
    					})
    				}
    			}
    		})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 00:07:28 UTC 2024
    - 78.4K bytes
    - Viewed (0)
  6. tests/integration/pilot/common/routing.go

    			"GatewayProtocol":    string(protocol),
    			"Gateway":            "gateway",
    			"VirtualServiceHost": dest.Config().ClusterLocalFQDN(),
    			"Port":               dest.PortForName(port).ServicePort,
    			"Credential":         cred,
    			"Ciphers":            ciphers,
    			"TLSMode":            "SIMPLE",
    			"GatewayIstioLabel":  t.Istio.Settings().IngressGatewayIstioLabel,
    		}
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 21:52:51 UTC 2024
    - 135.9K bytes
    - Viewed (0)
Back to top