Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for addressType (0.61 sec)

  1. pkg/apis/discovery/validation/validation_test.go

    				ObjectMeta:  standardMeta,
    				AddressType: discovery.AddressType("IP"),
    			},
    			newEndpointSlice: &discovery.EndpointSlice{
    				ObjectMeta:  standardMeta,
    				AddressType: discovery.AddressType("IP"),
    			},
    		},
    		"valid and identical slices with different address types": {
    			oldEndpointSlice: &discovery.EndpointSlice{
    				ObjectMeta:  standardMeta,
    				AddressType: discovery.AddressType("other"),
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 05 10:48:05 UTC 2023
    - 23.9K bytes
    - Viewed (0)
  2. pkg/apis/discovery/v1beta1/zz_generated.conversion.go

    }
    
    func autoConvert_v1beta1_EndpointSlice_To_discovery_EndpointSlice(in *v1beta1.EndpointSlice, out *discovery.EndpointSlice, s conversion.Scope) error {
    	out.ObjectMeta = in.ObjectMeta
    	out.AddressType = discovery.AddressType(in.AddressType)
    	if in.Endpoints != nil {
    		in, out := &in.Endpoints, &out.Endpoints
    		*out = make([]discovery.Endpoint, len(*in))
    		for i := range *in {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 15.3K bytes
    - Viewed (0)
  3. pkg/proxy/config/config_test.go

    	go sharedInformers.Start(stopCh)
    	go config.Run(stopCh)
    
    	endpoints1 := &discoveryv1.EndpointSlice{
    		ObjectMeta:  metav1.ObjectMeta{Namespace: "testnamespace", Name: "foo"},
    		AddressType: discoveryv1.AddressTypeIPv4,
    		Endpoints: []discoveryv1.Endpoint{{
    			Addresses: []string{"1.1.1.1"},
    		}, {
    			Addresses: []string{"2.2.2.2"},
    		}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  4. pkg/proxy/winkernel/proxier_test.go

    				NodePort: int32(svcNodePort),
    			}}
    		}),
    	)
    	populateEndpointSlices(proxier,
    		makeTestEndpointSlice(svcPortName.Namespace, svcPortName.Name, 1, func(eps *discovery.EndpointSlice) {
    			eps.AddressType = discovery.AddressTypeIPv4
    			eps.Endpoints = []discovery.Endpoint{{
    				Addresses: []string{epIpAddressRemote},
    			}}
    			eps.Ports = []discovery.EndpointPort{{
    				Name:     ptr.To(svcPortName.Port),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 28 14:30:51 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  5. pkg/registry/discovery/endpointslice/strategy_test.go

    	tests := []struct {
    		name        string
    		addressType discovery.AddressType
    		wantWarning bool
    	}{
    		{
    			name:        "AddressType = FQDN",
    			addressType: discovery.AddressTypeFQDN,
    			wantWarning: true,
    		},
    		{
    			name:        "AddressType = IPV4",
    			addressType: discovery.AddressTypeIPv4,
    			wantWarning: false,
    		},
    		{
    			name:        "AddressType = IPV6",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 27.3K bytes
    - Viewed (0)
  6. pkg/apis/discovery/v1/zz_generated.conversion.go

    }
    
    func autoConvert_v1_EndpointSlice_To_discovery_EndpointSlice(in *v1.EndpointSlice, out *discovery.EndpointSlice, s conversion.Scope) error {
    	out.ObjectMeta = in.ObjectMeta
    	out.AddressType = discovery.AddressType(in.AddressType)
    	out.Endpoints = *(*[]discovery.Endpoint)(unsafe.Pointer(&in.Endpoints))
    	out.Ports = *(*[]discovery.EndpointPort)(unsafe.Pointer(&in.Ports))
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 14.4K bytes
    - Viewed (0)
  7. pkg/controller/endpointslicemirroring/reconciler.go

    func (r *reconciler) reconcileByPortMapping(
    	endpoints *corev1.Endpoints,
    	existingSlices []*discovery.EndpointSlice,
    	desiredSet endpointsliceutil.EndpointSet,
    	endpointPorts []discovery.EndpointPort,
    	addressType discovery.AddressType,
    ) (slicesByAction, totalsByAction) {
    	slices := slicesByAction{}
    	totals := totalsByAction{}
    
    	// If no endpoints are desired, mark existing slices for deletion and
    	// return.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 11 18:08:12 UTC 2023
    - 13.1K bytes
    - Viewed (0)
  8. pilot/pkg/xds/workload_test.go

    		expect := buildExpect(t)
    		s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{
    			KubernetesObjects: []runtime.Object{mkPod("pod", "sa", "127.0.0.1", "not-node")},
    		})
    		ads := s.ConnectDeltaADS().WithType(v3.AddressType).WithMetadata(model.NodeMetadata{NodeName: "node"})
    		ads.Request(&discovery.DeltaDiscoveryRequest{
    			ResourceNamesSubscribe:   []string{"*"},
    			ResourceNamesUnsubscribe: []string{"*"},
    		})
    		ads.ExpectEmptyResponse()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 18 19:09:43 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  9. pkg/controlplane/reconcilers/endpointsadapter_test.go

    	_, epSlice4IP := generateEndpointsAndSlice("foo", "testing", []int{80}, []string{"10.1.2.7", "10.1.2.8"})
    	// "IP" is a deprecated address type, ensuring that it is handled properly.
    	epSlice4IP.AddressType = discovery.AddressType("IP")
    	_, epSlice4IPv4 := generateEndpointsAndSlice("foo", "testing", []int{80}, []string{"10.1.2.7", "10.1.2.8"})
    
    	testCases := map[string]struct {
    		expectedError  error
    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/endpointschangetracker.go

    func (ect *EndpointsChangeTracker) EndpointSliceUpdate(endpointSlice *discovery.EndpointSlice, removeSlice bool) bool {
    	if !supportedEndpointSliceAddressTypes.Has(endpointSlice.AddressType) {
    		klog.V(4).InfoS("EndpointSlice address type not supported by kube-proxy", "addressType", endpointSlice.AddressType)
    		return false
    	}
    
    	// This should never happen
    	if endpointSlice == nil {
    		klog.ErrorS(nil, "Nil endpointSlice passed to EndpointSliceUpdate")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 21 14:44:08 UTC 2023
    - 13.2K bytes
    - Viewed (0)
Back to top