- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for mutable_s (0.12 sec)
-
pilot/pkg/networking/core/cluster_builder.go
var lbEndpoints []*endpoint.LocalityLbEndpoints isPassthrough := subset.GetTrafficPolicy().GetLoadBalancer().GetSimple() == networking.LoadBalancerSettings_PASSTHROUGH clusterType := opts.mutable.cluster.GetType() if isPassthrough { clusterType = cluster.Cluster_ORIGINAL_DST } if !(isPassthrough || clusterType == cluster.Cluster_EDS) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 31.6K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder_test.go
opts := buildClusterOpts{ mesh: cb.req.Push.Mesh, mutable: mc, } cb.applyConnectionPool(opts.mesh, opts.mutable, tt.connectionPool) // assert httpProtocolOptions assert.Equal(t, opts.mutable.httpProtocolOptions.CommonHttpProtocolOptions.IdleTimeout, tt.expectedHTTPPOpt.CommonHttpProtocolOptions.IdleTimeout) assert.Equal(t, opts.mutable.httpProtocolOptions.CommonHttpProtocolOptions.MaxRequestsPerConnection,
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/networking/core/cluster_test.go
opt := buildClusterOpts{ mutable: newClusterWrapper(tt.cluster), port: &model.Port{Port: 80}, } addTelemetryMetadata(tt.cluster, opt.port, tt.service, tt.direction, tt.svcInsts) if opt.mutable.cluster != nil && !reflect.DeepEqual(opt.mutable.cluster.Metadata, tt.want) { t.Errorf("cluster metadata does not match expectation want %+v, got %+v", tt.want, opt.mutable.cluster.Metadata) } }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 108.8K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
util.ByteCount(ResourceSize(res)), info, debug) } return nil } // requiresResourceNamesModification checks if a generator needs mutable access to w.ResourceNames. // This is used when resources are spontaneously pushed during Delta XDS func requiresResourceNamesModification(url string) bool { return url == v3.AddressType || url == v3.WorkloadType }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
// DefaultClusterMode indicates usual cluster with mTLS et al DefaultClusterMode ClusterMode = "outbound" ) type buildClusterOpts struct { mesh *meshconfig.MeshConfig mutable *clusterWrapper policy *networking.TrafficPolicy port *model.Port serviceAccounts []string serviceTargets []model.ServiceTarget // Used for traffic across multiple network clusters
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0)