Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for TrafficDirection (0.78 sec)

  1. pilot/pkg/model/service.go

    type PortList []*Port
    
    // TrafficDirection defines whether traffic exists a service instance or enters a service instance
    type TrafficDirection string
    
    const (
    	// TrafficDirectionInbound indicates inbound traffic
    	TrafficDirectionInbound TrafficDirection = "inbound"
    	// TrafficDirectionInboundVIP indicates inbound traffic for vip
    	TrafficDirectionInboundVIP TrafficDirection = "inbound-vip"
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/listener_inbound.go

    	l := &listener.Listener{
    		Name:                             MainInternalName,
    		ListenerSpecifier:                &listener.Listener_InternalListener{InternalListener: &listener.Listener_InternalListenerConfig{}},
    		TrafficDirection:                 core.TrafficDirection_INBOUND,
    		ContinueOnListenerFiltersTimeout: true,
    	}
    
    	// Flush authz cache since we need filter state for the principal.
    	oldBuilder := lb.authzBuilder
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/cluster_builder.go

    // It is used for building both inbound and outbound cluster.
    func (cb *ClusterBuilder) buildCluster(name string, discoveryType cluster.Cluster_DiscoveryType,
    	localityLbEndpoints []*endpoint.LocalityLbEndpoints, direction model.TrafficDirection,
    	port *model.Port, service *model.Service, inboundServices []model.ServiceTarget,
    	subset string,
    ) *clusterWrapper {
    	c := &cluster.Cluster{
    		Name:                 name,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 31.6K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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