Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for fillDefaults (0.42 sec)

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

    	clone := o
    	if o.TLS.Alpn != nil {
    		clone.TLS.Alpn = make([]string, len(o.TLS.Alpn))
    		copy(clone.TLS.Alpn, o.TLS.Alpn)
    	}
    	return clone
    }
    
    // FillDefaults fills out any defaults that haven't been explicitly specified.
    func (o *CallOptions) FillDefaults() error {
    	// Fill in the address if not set.
    	if err := o.fillAddress(); err != nil {
    		return err
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Oct 08 09:39:20 UTC 2023
    - 13K bytes
    - Viewed (0)
  2. pkg/test/framework/components/echo/common/call.go

    		f: forwarder.New(),
    	}
    }
    
    func (c *Caller) Close() error {
    	return c.f.Close()
    }
    
    func (c *Caller) CallEcho(from echo.Caller, opts echo.CallOptions) (echo.CallResult, error) {
    	if err := opts.FillDefaults(); err != nil {
    		return echo.CallResult{}, err
    	}
    
    	send := func(req *proto.ForwardEchoRequest) (echoclient.Responses, error) {
    		ctx, cancel := context.WithTimeout(context.Background(), opts.Timeout)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Oct 08 09:39:20 UTC 2023
    - 6.7K bytes
    - Viewed (0)
  3. pkg/test/echo/server/forwarder/instance.go

    		protocols:   protocols,
    	}
    }
    
    // ForwardEcho sends the requests and collect the responses.
    func (i *Instance) ForwardEcho(ctx context.Context, cfg *Config) (*proto.ForwardEchoResponse, error) {
    	if err := cfg.fillDefaults(); err != nil {
    		return nil, err
    	}
    
    	// Lookup the protocol.
    	p := i.protocolMap[cfg.scheme]
    	if p == nil {
    		return nil, fmt.Errorf("no protocol handler found for scheme %s", cfg.scheme)
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Oct 13 17:19:22 UTC 2022
    - 2.3K bytes
    - Viewed (0)
  4. pkg/test/framework/components/echo/common/deployment/echos.go

    	}
    	c.Configs = func() []echo.Config {
    		var out []echo.Config
    		if existing != nil {
    			out = append(out, existing()...)
    		}
    		return append(out, configs...)
    	}
    	return c
    }
    
    func (c *Config) fillDefaults(ctx resource.Context) error {
    	// Create the namespaces concurrently.
    	g, _ := errgroup.WithContext(context.TODO())
    
    	if c.Echos == nil {
    		c.Echos = &Echos{}
    	}
    
    	if c.Configs == nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 20 16:01:31 UTC 2024
    - 16K bytes
    - Viewed (0)
  5. pkg/test/framework/components/echo/match/matchers_test.go

    }
    
    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
    }
    
    func (f fakeInstance) ServiceName() string {
    	return f.Config().Service
    }
    
    func (f fakeInstance) NamespaceName() string {
    	return f.Config().NamespaceName()
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  6. pilot/pkg/simulation/traffic.go

    	Sni string
    
    	// CallMode describes the type of call to make.
    	CallMode CallMode
    
    	CustomListenerValidations []CustomFilterChainValidation
    
    	MtlsSecretConfigName string
    }
    
    func (c Call) FillDefaults() Call {
    	if c.Headers == nil {
    		c.Headers = http.Header{}
    	}
    	if c.HostHeader != "" {
    		c.Headers["Host"] = []string{c.HostHeader}
    	}
    	// For simplicity, set SNI automatically for TLS traffic.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  7. pkg/test/echo/server/forwarder/config.go

    	hboneClientConfig    func(info *tls.CertificateRequestInfo) (*tls.Certificate, error)
    	hboneHeaders         http.Header
    	proxyProtocolVersion int
    	previousResponse     *http.Response
    }
    
    func (c *Config) fillDefaults() error {
    	c.checkRedirect = checkRedirectFunc(c.Request)
    	c.timeout = common.GetTimeout(c.Request)
    	c.count = common.GetCount(c.Request)
    	c.headers = common.GetHeaders(c.Request)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Oct 08 09:39:20 UTC 2023
    - 9.8K bytes
    - Viewed (0)
  8. pkg/test/framework/components/istio/config.go

    	if iopYaml != "" {
    		data = Indent(iopYaml, "  ")
    	}
    
    	return fmt.Sprintf(`
    apiVersion: install.istio.io/v1alpha1
    kind: IstioOperator
    spec:
    %s
    `, data)
    }
    
    func (c *Config) fillDefaults(ctx resource.Context) {
    	if ctx.AllClusters().IsExternalControlPlane() {
    		c.PrimaryClusterIOPFile = IntegrationTestExternalIstiodPrimaryDefaultsIOP
    		c.ConfigClusterIOPFile = IntegrationTestExternalIstiodConfigDefaultsIOP
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 10 20:33:28 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  9. pkg/test/framework/components/echo/echotest/filters_test.go

    }
    
    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
    }
    
    func (f fakeInstance) ServiceName() string {
    	return f.Config().Service
    }
    
    func (f fakeInstance) NamespaceName() string {
    	return f.Config().NamespaceName()
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  10. pkg/test/framework/components/echo/deployment/builder.go

    func (b *builder) With(i *echo.Instance, cfg echo.Config) Builder {
    	if b.ctx.Settings().SkipWorkloadClassesAsSet().Contains(cfg.WorkloadClass()) {
    		return b
    	}
    
    	cfg = cfg.DeepCopy()
    	if err := cfg.FillDefaults(b.ctx); err != nil {
    		b.errs = multierror.Append(b.errs, err)
    		return b
    	}
    
    	shouldSkip := b.ctx.Settings().Skip(cfg.WorkloadClass())
    	if shouldSkip {
    		return b
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 12K bytes
    - Viewed (0)
Back to top