- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for fillDefaults (0.22 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)