Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 206 for endpointSlice (0.29 sec)

  1. pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go

    	endpointSlice := obj.(*discovery.EndpointSlice)
    	prevEndpointSlice := prevObj.(*discovery.EndpointSlice)
    	if endpointSlice == nil || prevEndpointSlice == nil {
    		utilruntime.HandleError(fmt.Errorf("onEndpointSliceUpdated() expected type discovery.EndpointSlice, got %T, %T", prevObj, obj))
    		return
    	}
    	// EndpointSlice generation does not change when labels change. Although the
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 06 23:18:31 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  2. pkg/registry/discovery/endpointslice/strategy.go

    	endpointSlice := obj.(*discovery.EndpointSlice)
    	endpointSlice.Generation = 1
    
    	dropDisabledFieldsOnCreate(endpointSlice)
    	dropTopologyOnV1(ctx, nil, endpointSlice)
    }
    
    // PrepareForUpdate clears fields that are not allowed to be set by end users on update.
    func (endpointSliceStrategy) PrepareForUpdate(ctx context.Context, obj, old runtime.Object) {
    	newEPS := obj.(*discovery.EndpointSlice)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jan 02 10:00:01 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  3. pkg/controller/endpointslicemirroring/endpointslicemirroring_controller_test.go

    				}
    
    				if endpointSlices[0].Name != tc.endpointSlice.Name {
    					t.Fatalf("Expected %s EndpointSlice to be in list, got %s", tc.endpointSlice.Name, endpointSlices[0].Name)
    				}
    			} else {
    				if len(endpointSlices) != 0 {
    					t.Fatalf("Expected no EndpointSlices to be in list, got %d", len(endpointSlices))
    				}
    			}
    		})
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 12:57:29 UTC 2023
    - 13.9K bytes
    - Viewed (0)
  4. pkg/controller/endpointslicemirroring/reconciler.go

    	var errs []error
    	for _, endpointSlice := range endpointSlices {
    		err := r.client.DiscoveryV1().EndpointSlices(namespace).Delete(context.TODO(), endpointSlice.Name, metav1.DeleteOptions{})
    		if err != nil {
    			errs = append(errs, err)
    		}
    	}
    	if len(errs) > 0 {
    		return fmt.Errorf("error(s) deleting %d/%d EndpointSlices for %s/%s Endpoints, including: %s", len(errs), len(endpointSlices), namespace, name, errs[0])
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 11 18:08:12 UTC 2023
    - 13.1K bytes
    - Viewed (0)
  5. pkg/controller/endpointslice/endpointslice_controller.go

    }
    
    func dropEndpointSlicesPendingDeletion(endpointSlices []*discovery.EndpointSlice) []*discovery.EndpointSlice {
    	n := 0
    	for _, endpointSlice := range endpointSlices {
    		if endpointSlice.DeletionTimestamp == nil {
    			endpointSlices[n] = endpointSlice
    			n++
    		}
    	}
    	return endpointSlices[:n]
    }
    
    // getEndpointSliceFromDeleteAction parses an EndpointSlice from a delete action.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  6. pkg/controlplane/reconcilers/endpointsadapter.go

    	return err
    }
    
    // endpointSliceFromEndpoints generates an EndpointSlice from an Endpoints
    // resource.
    func endpointSliceFromEndpoints(endpoints *corev1.Endpoints) *discovery.EndpointSlice {
    	endpointSlice := &discovery.EndpointSlice{}
    	endpointSlice.Name = endpoints.Name
    	endpointSlice.Namespace = endpoints.Namespace
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 27 12:46:23 UTC 2022
    - 7.8K bytes
    - Viewed (0)
  7. pkg/registry/discovery/endpointslice/strategy_test.go

    				t.Logf("actual endpointslice: %v", tc.newEPS)
    				t.Logf("expected endpointslice: %v", tc.expectedEPS)
    				t.Errorf("unexpected EndpointSlice on API topology strategy")
    			}
    		})
    	}
    }
    
    func Test_getDeprecatedTopologyNodeNames(t *testing.T) {
    	testcases := []struct {
    		name              string
    		endpointSlice     *discovery.EndpointSlice
    		expectedNodeNames sets.String
    	}{
    		{
    			name: "2 nodes",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 27.3K bytes
    - Viewed (0)
  8. pkg/proxy/config/config_test.go

    	state   map[types.NamespacedName]*discoveryv1.EndpointSlice
    	synced  bool
    	updated chan []*discoveryv1.EndpointSlice
    	process func([]*discoveryv1.EndpointSlice)
    }
    
    func NewEndpointSliceHandlerMock() *EndpointSliceHandlerMock {
    	ehm := &EndpointSliceHandlerMock{
    		state:   make(map[types.NamespacedName]*discoveryv1.EndpointSlice),
    		updated: make(chan []*discoveryv1.EndpointSlice, 5),
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  9. pkg/proxy/endpointslicecache_test.go

    	original runtime.Object
    	deepCopy runtime.Object
    }
    
    // newCacheMutationCheck initializes a cacheMutationCheck with EndpointSlices.
    func newCacheMutationCheck(endpointSlices []*discovery.EndpointSlice) cacheMutationCheck {
    	cmc := cacheMutationCheck{}
    	for _, endpointSlice := range endpointSlices {
    		cmc.Add(endpointSlice)
    	}
    	return cmc
    }
    
    // Add appends a runtime.Object and a deep copy of that object into the
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:07:21 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  10. pkg/controller/endpointslicemirroring/reconciler_helpers_test.go

    			toCreate: []*discovery.EndpointSlice{simpleEndpointSlice("foo", "10.1.2.3", discovery.AddressTypeIPv4)},
    			toUpdate: []*discovery.EndpointSlice{simpleEndpointSlice("baz", "10.2.3.4", discovery.AddressTypeIPv4)},
    			toDelete: []*discovery.EndpointSlice{simpleEndpointSlice("bar", "10.3.4.5", discovery.AddressTypeIPv4)},
    		},
    		expectedSlices: &slicesByAction{
    			toUpdate: []*discovery.EndpointSlice{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 06 23:58:47 UTC 2021
    - 7K bytes
    - Viewed (0)
Back to top