Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for mutable_s (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top