Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for IsAllowAnyOutbound (0.17 sec)

  1. pilot/pkg/networking/util/util.go

    			Fields: map[string]*structpb.Value{},
    		}
    	}
    
    	metadata.FilterMetadata[IstioMetadataKey].Fields[key] = val
    }
    
    // IsAllowAnyOutbound checks if allow_any is enabled for outbound traffic
    func IsAllowAnyOutbound(node *model.Proxy) bool {
    	return node.SidecarScope != nil &&
    		node.SidecarScope.OutboundTrafficPolicy != nil &&
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/httproute.go

    			DNSDomain:               node.DNSDomain,
    			DNSCapture:              bool(node.Metadata.DNSCapture),
    			DNSAutoAllocate:         bool(node.Metadata.DNSAutoAllocate),
    			AllowAny:                util.IsAllowAnyOutbound(node),
    			ListenerPort:            listenerPort,
    			Services:                services,
    			VirtualServices:         virtualServices,
    			DelegateVirtualServices: push.DelegateVirtualServices(virtualServices),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 32.7K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/listener_builder.go

    		nHTTPProxy,
    		nVirtual,
    	)
    	return listeners
    }
    
    func buildOutboundCatchAllNetworkFiltersOnly(push *model.PushContext, node *model.Proxy) []*listener.Filter {
    	var egressCluster string
    
    	if util.IsAllowAnyOutbound(node) {
    		// We need a passthrough filter to fill in the filter stack for orig_dst listener
    		egressCluster = util.PassthroughCluster
    
    		// no need to check for nil value as the previous if check has checked
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  4. pilot/pkg/networking/util/util_test.go

    						Mode: networking.OutboundTrafficPolicy_ALLOW_ANY,
    					},
    				},
    			},
    			result: true,
    		},
    	}
    	for i := range tests {
    		t.Run(tests[i].name, func(t *testing.T) {
    			out := IsAllowAnyOutbound(tests[i].node)
    			if out != tests[i].result {
    				t.Errorf("Expected %t but got %t for test case: %v\n", tests[i].result, out, tests[i].node)
    			}
    		})
    	}
    }
    
    func TestBuildAddress(t *testing.T) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 01:17:58 UTC 2024
    - 40K bytes
    - Viewed (0)
Back to top