Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for GetEndpointHost (0.37 sec)

  1. pilot/test/xdstest/endpoints.go

    		return fmt.Errorf("unexpected number of filtered endpoints for %s: got %v, want %v", cluster, len(got), len(want))
    	}
    
    	sort.Slice(got, func(i, j int) bool {
    		addrI := util.GetEndpointHost(got[i].LbEndpoints[0])
    		addrJ := util.GetEndpointHost(got[j].LbEndpoints[0])
    		return addrI < addrJ
    	})
    
    	for i, ep := range got {
    		if len(ep.LbEndpoints) != len(want[i].LbEps) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 01:17:58 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  2. pilot/pkg/xds/endpoints/ep_filters.go

    			if b.proxy.InNetwork(epNetwork) || len(gateways) == 0 {
    				// The endpoint is directly reachable - just add it.
    				// If there is no gateway, the address must not be empty
    				if util.GetEndpointHost(lbEp) != "" {
    					lbEndpoints.append(ep.istioEndpoints[i], lbEp)
    				}
    
    				continue
    			}
    			// Cross-network traffic relies on mTLS to be enabled for SNI routing
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 01:17:58 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  3. pilot/pkg/networking/util/util_test.go

    						},
    					},
    				},
    			},
    			want: "fd00:10:96::7fc7",
    		},
    	}
    
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			if got := GetEndpointHost(tt.endpoint); got != tt.want {
    				t.Errorf("GetEndpointHost got %v, want %v", got, tt.want)
    			}
    		})
    	}
    }
    
    func TestCidrRangeSliceEqual(t *testing.T) {
    	tests := []struct {
    		name   string
    		first  []*core.CidrRange
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 01:17:58 UTC 2024
    - 40K bytes
    - Viewed (0)
  4. pilot/pkg/networking/util/util.go

    				AddressNameSpecifier: &core.EnvoyInternalAddress_ServerListenerName{
    					ServerListenerName: name,
    				},
    				EndpointId: identifier,
    			},
    		},
    	}
    }
    
    func GetEndpointHost(e *endpoint.LbEndpoint) string {
    	addr := e.GetEndpoint().GetAddress()
    	if host := addr.GetSocketAddress().GetAddress(); host != "" {
    		return host
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 28.5K bytes
    - Viewed (0)
Back to top