Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for fillDefaults (0.44 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. pkg/test/framework/components/echo/config.go

    }
    
    const (
    	defaultService   = "echo"
    	defaultVersion   = "v1"
    	defaultNamespace = "echo"
    	defaultDomain    = constants.DefaultClusterLocalDomain
    )
    
    func (c *Config) FillDefaults(ctx resource.Context) (err error) {
    	if c.Service == "" {
    		c.Service = defaultService
    	}
    
    	if c.Version == "" {
    		c.Version = defaultVersion
    	}
    
    	if c.Domain == "" {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 09 12:26:52 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  8. pkg/test/framework/components/istio/kube.go

    	return i.values, nil
    }
    
    func (i *istioImpl) ValuesOrFail(test.Failer) OperatorValues {
    	return i.values
    }
    
    func newKube(ctx resource.Context, cfg Config) (Instance, error) {
    	cfg.fillDefaults(ctx)
    
    	scopes.Framework.Infof("=== Istio Component Config ===")
    	scopes.Framework.Infof("\n%s", cfg.String())
    	scopes.Framework.Infof("================================")
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  9. pilot/pkg/networking/core/cluster_test.go

    }
    
    func (c clusterTest) fillDefaults() clusterTest {
    	if c.proxyIps == nil {
    		c.proxyIps = []string{"6.6.6.6", "::1"}
    	}
    	if c.istioVersion == nil {
    		c.istioVersion = model.MaxIstioVersion
    	}
    	if c.meta == nil {
    		c.meta = &model.NodeMetadata{}
    	}
    	return c
    }
    
    func buildTestClusters(c clusterTest) []*cluster.Cluster {
    	c = c.fillDefaults()
    
    	servicePort := model.PortList{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 108.8K bytes
    - Viewed (0)
  10. tests/integration/security/authz_test.go

    }
    
    func (b *authzTest) Allow(allow allowValue) *authzTest {
    	b.allow = allow
    	return b
    }
    
    func (b *authzTest) Build(t framework.TestContext) *authzTest {
    	t.Helper()
    	// Set check now, as FillDefaults requires it
    	b.opts.Check = check.OK()
    	// Fill in the defaults; we need this to get the dest protocol
    	b.opts.FillDefaultsOrFail(t)
    	if b.allow {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 23:36:51 UTC 2024
    - 50.1K bytes
    - Viewed (0)
Back to top