- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 40 for sidecarProxy (0.23 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)