Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 124 for endpointSlice (0.3 sec)

  1. staging/src/k8s.io/api/testdata/HEAD/discovery.k8s.io.v1beta1.EndpointSlice.pb

    Daniel Smith <******@****.***> 1651776874 +0000
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 06 21:25:20 UTC 2022
    - 682 bytes
    - Viewed (0)
  2. staging/src/k8s.io/api/testdata/v1.29.0/discovery.k8s.io.v1.EndpointSlice.pb

    SataQiu <******@****.***> 1702613527 +0800
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 04:12:07 UTC 2023
    - 708 bytes
    - Viewed (0)
  3. staging/src/k8s.io/api/testdata/v1.30.0/discovery.k8s.io.v1beta1.EndpointSlice.pb

    SataQiu <******@****.***> 1713430345 +0800
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:52:25 UTC 2024
    - 682 bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/testdata/v1.30.0/discovery.k8s.io.v1.EndpointSlice.pb

    SataQiu <******@****.***> 1713430345 +0800
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:52:25 UTC 2024
    - 708 bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  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/utils_test.go

    	client.PrependReactor("create", "endpointslices", k8stesting.ReactionFunc(func(action k8stesting.Action) (bool, runtime.Object, error) {
    		endpointSlice := action.(k8stesting.CreateAction).GetObject().(*discovery.EndpointSlice)
    
    		if endpointSlice.ObjectMeta.GenerateName != "" {
    			endpointSlice.ObjectMeta.Name = fmt.Sprintf("%s-%s", endpointSlice.ObjectMeta.GenerateName, rand.String(8))
    			endpointSlice.ObjectMeta.GenerateName = ""
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 23 15:40:23 UTC 2022
    - 7.5K bytes
    - Viewed (0)
Back to top