Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for CallOrFail (0.13 sec)

  1. tests/integration/pilot/gateway_test.go

    	}
    	for _, tc := range testCases {
    		t.NewSubTest(fmt.Sprintf("gateway-connectivity-from-%s", tc.from[0].NamespacedName())).Run(func(t framework.TestContext) {
    			tc.from[0].CallOrFail(t, echo.CallOptions{
    				Port: echo.Port{
    					Protocol:    protocol.HTTP,
    					ServicePort: 80,
    				},
    				Scheme: scheme.HTTP,
    				HTTP: echo.HTTP{
    					Headers: headers.New().WithHost(tc.host).Build(),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 17.7K bytes
    - Viewed (0)
  2. tests/integration/telemetry/api/accesslogs_test.go

    					},
    					Check: check.ResponseHeader(injectedHeader, ""),
    				}
    				count = logCount(t, from, testID)
    				_ = cltInstance.CallOrFail(t, httpOpts)
    			} else {
    				GetClientInstances()[0].CallOrFail(t, echo.CallOptions{
    					To: to,
    					Port: echo.Port{
    						Name: "http",
    					},
    					HTTP: http,
    				})
    				count = logCount(t, to, testID)
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  3. tests/integration/pilot/ingress_test.go

    								t.Fatal(err)
    							}
    							c.call.Retry.Options = []retry.Option{
    								retry.Delay(500 * time.Millisecond),
    								retry.Timeout(time.Minute * 2),
    							}
    							ingr.CallOrFail(t, c.call)
    						})
    					}
    				})
    			}
    
    			defaultIngress := istio.DefaultIngressOrFail(t, t)
    			t.NewSubTest("status").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)
  4. tests/integration/telemetry/api/stats_test.go

    	})
    	if err != nil {
    		return err
    	}
    	return nil
    }
    
    func SendTrafficOrFail(t test.Failer, from echo.Instance) {
    	from.CallOrFail(t, echo.CallOptions{
    		To: GetTarget(),
    		Port: echo.Port{
    			Name: "http",
    		},
    		Check: check.OK(),
    	})
    	from.CallOrFail(t, echo.CallOptions{
    		To: apps.Naked,
    		Port: echo.Port{
    			Name: "http",
    		},
    		Retry: echo.Retry{
    			NoRetry: true,
    		},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  5. tests/integration/security/jwt_test.go

    									To: to,
    									Port: echo.Port{
    										Name: "http",
    									},
    								}
    
    								// Apply any custom options for the test.
    								c.customizeCall(t, from, &opts)
    
    								from.CallOrFail(t, opts)
    							})
    						}
    					})
    				}
    			}
    
    			t.NewSubTest("authn-only").Run(newTest("testdata/requestauthn/authn-only.yaml.tmpl", []testCase{
    				{
    					name: "valid-token-noauthz",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 25.3K bytes
    - Viewed (0)
  6. tests/integration/ambient/waypoint_test.go

    					}
    					for _, host := range apps.Captured.Config().HostnameVariants() {
    						host := host
    						t.NewSubTestf("to %s", host).Run(func(t framework.TestContext) {
    							src.CallOrFail(t, echo.CallOptions{
    								To:      apps.Captured,
    								Address: host,
    								Port:    echo.Port{Name: "http"},
    								Scheme:  scheme.HTTP,
    								Count:   10,
    								Check: check.And(
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  7. tests/integration/pilot/common/traffic.go

    				if opts.Check == nil {
    					opts.Check = check.OK()
    				}
    				return opts
    			}
    			if optsSpecified {
    				from.CallOrFail(t, buildOpts(c.opts))
    			}
    			for _, child := range c.children {
    				t.NewSubTest(child.name).Run(func(t framework.TestContext) {
    					from.CallOrFail(t, buildOpts(child.opts))
    				})
    			}
    		}
    
    		if c.toN > 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jan 03 19:10:01 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  8. tests/integration/telemetry/api/wasmplugin_test.go

    		HTTP: echo.HTTP{
    			Path:   "/path",
    			Method: "GET",
    		},
    		Count: 1,
    		Retry: echo.Retry{
    			Options: append(defaultOptions, options...),
    		},
    		Check: checker,
    	}
    
    	_ = cltInstance.CallOrFail(ctx, httpOpts)
    }
    
    func sendTrafficToHostname(ctx framework.TestContext, checker echo.Checker, hostname string, options ...retry.Option) {
    	ctx.Helper()
    	if len(GetClientInstances()) == 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  9. tests/integration/security/egress_gateway_origination_test.go

    					newTLSGatewayTest(t).
    						Run(func(t framework.TestContext, from echo.Instance, to echo.Target) {
    							callOpt := newTLSGatewayCallOpts(to, host, tc.statusCode, tc.useGateway)
    							from.CallOrFail(t, callOpt)
    						})
    				})
    			}
    		})
    }
    
    // TestMutualTlsOrigination test MUTUAL TLS mode with TLS origination happening at Gateway proxy
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  10. tests/integration/security/pass_through_filter_chain_test.go

    									mtlsString = "plaintext"
    								}
    								testName := fmt.Sprintf("%s/%s(%s)", mtlsString, p.Name, allow)
    								t.NewSubTest(testName).Run(func(t framework.TestContext) {
    									from.CallOrFail(t, opts)
    								})
    							}
    						})
    				})
    			}
    		})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 11.9K bytes
    - Viewed (0)
Back to top