Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 40 for sidecarProxy (0.23 sec)

  1. pilot/cmd/pilot-agent/status/server.go

    	// want to expose istio-agent metrics we may want to revisit this.
    	if cfg, f := PrometheusScrapingConfig.Lookup(); config.NodeType == model.SidecarProxy && f {
    		var prom PrometheusScrapeConfiguration
    		if err := json.Unmarshal([]byte(cfg), &prom); err != nil {
    			return nil, fmt.Errorf("failed to unmarshal %s: %v", PrometheusScrapingConfig.Name, err)
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 15:07:03 UTC 2024
    - 31.1K bytes
    - Viewed (1)
  2. pilot/pkg/networking/core/httproute.go

    	routeNames []string,
    ) ([]*discovery.Resource, model.XdsLogDetails) {
    	var routeConfigurations model.Resources
    
    	efw := req.Push.EnvoyFilters(node)
    	hit, miss := 0, 0
    	switch node.Type {
    	case model.SidecarProxy, model.Waypoint:
    		vHostCache := make(map[int][]*route.VirtualHost)
    		// dependent envoyfilters' key, calculate in front once to prevent calc for each route.
    		envoyfilterKeys := efw.KeysApplyingTo(
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 32.7K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/cluster.go

    	envoyFilterPatches := req.Push.EnvoyFilters(proxy)
    	cb := NewClusterBuilder(proxy, req, configgen.Cache)
    	instances := proxy.ServiceTargets
    	cacheStats := cacheStats{}
    	switch proxy.Type {
    	case model.SidecarProxy:
    		// Setup outbound clusters
    		outboundPatcher := clusterPatcher{efw: envoyFilterPatches, pctx: networking.EnvoyFilter_SIDECAR_OUTBOUND}
    		ob, cs := configgen.buildOutboundClusters(cb, proxy, outboundPatcher, services)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  4. pkg/adsc/adsc.go

    func setDefaultConfig(config *Config) Config {
    	if config == nil {
    		config = &Config{}
    	}
    	if config.Namespace == "" {
    		config.Namespace = "default"
    	}
    	if config.NodeType == "" {
    		config.NodeType = model.SidecarProxy
    	}
    	if config.IP == "" {
    		ips, ok := network.GetPrivateIPsIfAvailable()
    		if ok && len(ips) > 0 {
    			config.IP = ips[0]
    		}
    	}
    	if config.Workload == "" {
    		config.Workload = "test-1"
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Feb 05 22:18:49 UTC 2024
    - 35K bytes
    - Viewed (0)
  5. pilot/pkg/model/sidecar.go

    // services. The list of services seen by every sidecar scope (namespace
    // wide or per workload) depends on the imports, the listeners, and other
    // settings.
    //
    // Every proxy workload of SidecarProxy type will always map to a
    // SidecarScope object. If the proxy's namespace does not have a user
    // specified Sidecar CRD, we will construct one that has a catch all egress
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 20:32:23 UTC 2024
    - 38.4K bytes
    - Viewed (0)
  6. pilot/pkg/networking/core/cluster_tls_test.go

    					t.Fatalf("expected alpn list %v; got %v", util.ALPNInMeshH2WithMxc, got)
    				}
    			},
    		},
    	}
    
    	proxy := &model.Proxy{
    		Type:         model.SidecarProxy,
    		Metadata:     &model.NodeMetadata{},
    		IstioVersion: &model.IstioVersion{Major: 1, Minor: 5},
    	}
    	push := model.NewPushContext()
    	for _, test := range tests {
    		t.Run(test.name, func(t *testing.T) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 03:53:05 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  7. pilot/pkg/networking/core/listener.go

    func (configgen *ConfigGeneratorImpl) BuildListeners(node *model.Proxy,
    	push *model.PushContext,
    ) []*listener.Listener {
    	builder := NewListenerBuilder(node, push)
    
    	switch node.Type {
    	case model.SidecarProxy:
    		builder = configgen.buildSidecarListeners(builder)
    	case model.Waypoint:
    		builder = configgen.buildWaypointListeners(builder)
    	case model.Router:
    		builder = configgen.buildGatewayListeners(builder)
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  8. pilot/pkg/networking/core/route/route_test.go

    					Port:     8080,
    					Protocol: protocol.HTTP,
    				},
    			},
    		},
    	}
    
    	node := func(cg *core.ConfigGenTest) *model.Proxy {
    		return cg.SetupProxy(&model.Proxy{
    			Type:        model.SidecarProxy,
    			IPAddresses: []string{"1.1.1.1"},
    			ID:          "someID",
    			DNSDomain:   "foo.com",
    			IstioVersion: &model.IstioVersion{
    				Major: 1,
    				Minor: 20,
    			},
    		})
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 88.1K bytes
    - Viewed (0)
  9. pilot/pkg/networking/core/cluster_builder_test.go

    	mc := newClusterWrapper(&cluster.Cluster{
    		Name: "test-cluster",
    	})
    	cb.setUseDownstreamProtocol(mc)
    	return mc
    }
    
    func newSidecarProxy() *model.Proxy {
    	return &model.Proxy{Type: model.SidecarProxy, Metadata: &model.NodeMetadata{}}
    }
    
    func newGatewayProxy() *model.Proxy {
    	return &model.Proxy{Type: model.Router, Metadata: &model.NodeMetadata{}}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 110.4K bytes
    - Viewed (0)
  10. pilot/pkg/model/push_context.go

    		// We need to compute this namespace
    		computed := DefaultSidecarScopeForGateway(ps, proxy.ConfigNamespace)
    		ps.sidecarIndex.sidecarsForGatewayByNamespace[proxy.ConfigNamespace] = computed
    		return computed
    	case SidecarProxy:
    		if hasSidecar {
    			for _, wrapper := range sidecars {
    				if wrapper.Sidecar != nil {
    					sidecar := wrapper.Sidecar
    					// if there is no workload selector, the config applies to all workloads
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 09:02:11 UTC 2024
    - 91.8K bytes
    - Viewed (0)
Back to top