Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,209 for endpointId (0.23 sec)

  1. pkg/kubelet/stats/cri_stats_provider_windows_test.go

    		for _, stat := range c.hcsStats {
    			e, found := uniqueEndpoints[stat.EndpointId]
    			if found {
    				// add the container
    				e.SharedContainers = append(e.SharedContainers, c.container.ID)
    				continue
    			}
    
    			uniqueEndpoints[stat.EndpointId] = &hcsshim.HNSEndpoint{
    				Name:             stat.EndpointId,
    				Id:               stat.EndpointId,
    				SharedContainers: []string{c.container.ID},
    			}
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 17 00:02:10 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  2. pkg/proxy/winkernel/testing/hcnutils_mock.go

    	endpoint.Id, endpoint.Name = hcnObj.generateEndpointGuid()
    	endpoint.HostComputeNetwork = network.Id
    	endpointMap[endpoint.Id] = endpoint
    	endpointMap[endpoint.Name] = endpoint
    	return endpoint, nil
    }
    
    func (hcnObj HcnMock) CreateRemoteEndpoint(network *hcn.HostComputeNetwork, endpoint *hcn.HostComputeEndpoint) (*hcn.HostComputeEndpoint, error) {
    	return hcnObj.CreateEndpoint(network, endpoint)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 18 06:29:01 UTC 2023
    - 6.2K bytes
    - Viewed (0)
  3. pilot/pkg/networking/util/util.go

    func cloneLocalityLbEndpoints(endpoints []*endpoint.LocalityLbEndpoints) []*endpoint.LocalityLbEndpoints {
    	out := make([]*endpoint.LocalityLbEndpoints, 0, len(endpoints))
    	for _, ep := range endpoints {
    		clone := CloneLocalityLbEndpoint(ep)
    		out = append(out, clone)
    	}
    	return out
    }
    
    // return a shallow copy of LocalityLbEndpoints
    func CloneLocalityLbEndpoint(ep *endpoint.LocalityLbEndpoints) *endpoint.LocalityLbEndpoints {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  4. pkg/proxy/winkernel/hcnutils.go

    }
    
    func (hcnObj hcnImpl) CreateRemoteEndpoint(network *hcn.HostComputeNetwork, endpoint *hcn.HostComputeEndpoint) (*hcn.HostComputeEndpoint, error) {
    	return network.CreateRemoteEndpoint(endpoint)
    }
    
    func (hcnObj hcnImpl) DeleteEndpoint(endpoint *hcn.HostComputeEndpoint) error {
    	return endpoint.Delete()
    }
    
    func (hcnObj hcnImpl) ListLoadBalancers() ([]hcn.HostComputeLoadBalancer, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 08 03:08:46 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/envoy/configdump/endpoint.go

    		if epCount != 0 {
    			endpoints = append(endpoints, cla)
    		}
    	}
    	for _, e := range dump.GetStaticEndpointConfigs() {
    		cla, epCount := retrieveEndpoint(e.EndpointConfig, filter)
    		if epCount != 0 {
    			endpoints = append(endpoints, cla)
    		}
    	}
    	sort.Slice(endpoints, func(i, j int) bool {
    		iDirection, iSubset, iName, iPort := safelyParseSubsetKey(endpoints[i].ClusterName)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  6. istioctl/pkg/writer/envoy/clusters/clusters.go

    	clusterEndpoint = retrieveSortedEndpointClusterSlice(clusterEndpoint)
    	fmt.Fprintln(w, "ENDPOINT\tSTATUS\tOUTLIER CHECK\tCLUSTER")
    	for _, ce := range clusterEndpoint {
    		var endpoint string
    		if ce.port != 0 {
    			endpoint = ce.address + ":" + strconv.Itoa(ce.port)
    		} else {
    			endpoint = ce.address
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Nov 03 08:41:32 UTC 2022
    - 5.8K bytes
    - Viewed (0)
  7. pkg/kubelet/stats/cri_stats_provider_windows.go

    			continue
    		}
    
    		// only add the interface for each container if not already in the list
    		for _, cId := range endpoint.SharedContainers {
    			networkStat, found := networkStats[cId]
    			if found && networkStat.Name != endpoint.Name {
    				iStat := hcsStatToInterfaceStat(endpointStats, endpoint.Name)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Feb 18 07:03:11 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  8. pilot/pkg/networking/util/util_test.go

    	xdsutil "istio.io/istio/pkg/wellknown"
    )
    
    var testCla = &endpoint.ClusterLoadAssignment{
    	ClusterName: "cluster",
    	Endpoints: []*endpoint.LocalityLbEndpoints{{
    		Locality: &core.Locality{Region: "foo", Zone: "bar"},
    		LbEndpoints: []*endpoint.LbEndpoint{
    			{
    				HostIdentifier:      &endpoint.LbEndpoint_Endpoint{Endpoint: &endpoint.Endpoint{Hostname: "foo", Address: BuildAddress("1.1.1.1", 80)}},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 01:17:58 UTC 2024
    - 40K bytes
    - Viewed (0)
  9. pkg/controlplane/reconcilers/endpointsadapter_test.go

    			expectedResult: endpoints2,
    			expectUpdate:   []runtime.Object{endpoints2, epSlice2},
    			initialState:   []runtime.Object{endpoints2, epSlice1},
    			namespaceParam: "testing",
    			endpointsParam: endpoints2,
    		},
    		"endpointslice-correct-endpoints-wrong": {
    			expectedError:  nil,
    			expectedResult: endpoints2,
    			expectUpdate:   []runtime.Object{endpoints2},
    			initialState:   []runtime.Object{endpoints1, epSlice2},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:23:16 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  10. pkg/proxy/winkernel/proxier_test.go

    			eps.AddressType = discovery.AddressTypeIPv4
    			eps.Endpoints = []discovery.Endpoint{{
    				Addresses: []string{epIpAddressRemote},
    				NodeName:  ptr.To("testhost2"), // This will make this endpoint as a remote endpoint
    			}}
    			eps.Ports = []discovery.EndpointPort{{
    				Name:     ptr.To(svcPortName.Port),
    				Port:     ptr.To(int32(svcPort)),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 28 14:30:51 UTC 2024
    - 30.2K bytes
    - Viewed (0)
Back to top