Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 17 of 17 for TrafficDirection (0.5 sec)

  1. pilot/pkg/model/sidecar.go

    	} else {
    		sc.configDependencies.InsertAll(dependencies...)
    	}
    }
    
    // DestinationRule returns a destinationrule for a svc.
    func (sc *SidecarScope) DestinationRule(direction TrafficDirection, proxy *Proxy, svc host.Name) *ConsolidatedDestRule {
    	destinationRules := sc.destinationRules[svc]
    	var catchAllDr *ConsolidatedDestRule
    	for _, destRule := range destinationRules {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 20:32:23 UTC 2024
    - 38.4K bytes
    - Viewed (0)
  2. istioctl/pkg/proxyconfig/proxyconfig.go

    			}
    			if err != nil {
    				return err
    			}
    			filter := configdump.ClusterFilter{
    				FQDN:      host.Name(fqdn),
    				Port:      port,
    				Subset:    subset,
    				Direction: model.TrafficDirection(direction),
    			}
    			switch outputFormat {
    			case summaryOutput:
    				return configWriter.PrintClusterSummary(filter)
    			case jsonOutput, yamlOutput:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 16 03:28:36 UTC 2024
    - 48K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/listener_waypoint.go

    			xdsfilters.OriginalDestination,
    			// TODO: This may affect the data path due to the server-first protocols triggering a time-out. Need exception filter.
    			xdsfilters.HTTPInspector,
    		},
    		TrafficDirection: core.TrafficDirection_INBOUND,
    		FilterChains:     chains,
    		FilterChainMatcher: &matcher.Matcher{
    			MatcherType: &matcher.Matcher_MatcherTree_{
    				MatcherTree: &matcher.Matcher_MatcherTree{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 27.6K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/cluster.go

    	// the east-west gateway in a remote cluster will use this value to route
    	// traffic to the appropriate service
    	istioMtlsSni    string
    	clusterMode     ClusterMode
    	direction       model.TrafficDirection
    	meshExternal    bool
    	serviceMTLSMode model.MutualTLSMode
    	// Indicates the service registry of the cluster being built.
    	serviceRegistry provider.ID
    	// Indicates if the destinationRule has a workloadSelector
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/gateway.go

    			}
    
    			// If statPrefix has been set before calling this method, respect that.
    			if len(opt.httpOpts.statPrefix) == 0 {
    				opt.httpOpts.statPrefix = strings.ToLower(ml.Listener.TrafficDirection.String()) + "_" + ml.Listener.Name
    			}
    			opt.httpOpts.port = opts.port
    			httpConnectionManagers[i] = builder.buildHTTPConnectionManager(opt.httpOpts)
    			filter := &listener.Filter{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 46.4K bytes
    - Viewed (0)
  6. pilot/pkg/networking/core/cluster_builder_test.go

    	}
    
    	cases := []struct {
    		name            string
    		clusterName     string
    		discovery       cluster.Cluster_DiscoveryType
    		endpoints       []*endpoint.LocalityLbEndpoints
    		direction       model.TrafficDirection
    		external        bool
    		expectedCluster *cluster.Cluster
    	}{
    		{
    			name:        "default EDS cluster",
    			clusterName: "foo",
    			discovery:   cluster.Cluster_EDS,
    			endpoints:   nil,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 110.4K bytes
    - Viewed (0)
  7. pilot/pkg/networking/core/cluster_test.go

    				t.Fatalf("want %v got %v", tt.want, clusterNames)
    			}
    		})
    	}
    }
    
    func TestTelemetryMetadata(t *testing.T) {
    	cases := []struct {
    		name      string
    		direction model.TrafficDirection
    		cluster   *cluster.Cluster
    		svcInsts  []model.ServiceTarget
    		service   *model.Service
    		want      *core.Metadata
    	}{
    		{
    			name:      "no cluster",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 108.8K bytes
    - Viewed (0)
Back to top