Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 43 for endpointSlice (0.24 sec)

  1. pilot/pkg/serviceregistry/kube/controller/endpointslice.go

    	slices        kclient.Client[*v1.EndpointSlice]
    	c             *Controller
    }
    
    var (
    	endpointSliceRequirement = labelRequirement(mcs.LabelServiceName, selection.DoesNotExist, nil)
    	endpointSliceSelector    = klabels.NewSelector().Add(*endpointSliceRequirement)
    )
    
    func newEndpointSliceController(c *Controller) *endpointSliceController {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  2. 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)
  3. pkg/controller/endpointslice/endpointslice_controller_test.go

    		if endpointSlice.ObjectMeta.GenerateName != "" {
    			endpointSlice.ObjectMeta.Name = fmt.Sprintf("%s-%s", endpointSlice.ObjectMeta.GenerateName, rand.String(8))
    			endpointSlice.ObjectMeta.GenerateName = ""
    		}
    		endpointSlice.Generation = 1
    		esIndexer.Add(endpointSlice)
    
    		return false, endpointSlice, nil
    	}))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 65.5K bytes
    - Viewed (0)
  4. pkg/proxy/iptables/number_generated_rules_test.go

    	services := make([]*v1.Service, nServices)
    	endpointSlices := make([]*discovery.EndpointSlice, nServices)
    
    	// base parameters
    	basePort := 80
    	base := netutils.BigForIP(netutils.ParseIPSloppy("10.0.0.1"))
    
    	// generate a base endpoint slice object
    	baseEp := netutils.BigForIP(netutils.ParseIPSloppy("172.16.0.1"))
    	epPort := 8080
    
    	eps := &discovery.EndpointSlice{
    		ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  5. staging/src/k8s.io/api/discovery/v1/types.go

    // +k8s:prerelease-lifecycle-gen:introduced=1.21
    
    // EndpointSlice represents a subset of the endpoints that implement a service.
    // For a given service there may be multiple EndpointSlice objects, selected by
    // labels, which must be joined to produce the full set of endpoints.
    type EndpointSlice struct {
    	metav1.TypeMeta `json:",inline"`
    
    	// Standard object's metadata.
    	// +optional
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 23 17:42:49 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  6. pkg/proxy/iptables/proxier_test.go

    }
    
    func populateEndpointSlices(proxier *Proxier, allEndpointSlices ...*discovery.EndpointSlice) {
    	for i := range allEndpointSlices {
    		proxier.OnEndpointSliceAdd(allEndpointSlices[i])
    	}
    }
    
    func makeTestEndpointSlice(namespace, name string, sliceNum int, epsFunc func(*discovery.EndpointSlice)) *discovery.EndpointSlice {
    	eps := &discovery.EndpointSlice{
    		ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 249.9K bytes
    - Viewed (1)
  7. go.work

    	./staging/src/k8s.io/controller-manager
    	./staging/src/k8s.io/cri-api
    	./staging/src/k8s.io/cri-client
    	./staging/src/k8s.io/csi-translation-lib
    	./staging/src/k8s.io/dynamic-resource-allocation
    	./staging/src/k8s.io/endpointslice
    	./staging/src/k8s.io/kms
    	./staging/src/k8s.io/kube-aggregator
    	./staging/src/k8s.io/kube-controller-manager
    	./staging/src/k8s.io/kube-proxy
    	./staging/src/k8s.io/kube-scheduler
    	./staging/src/k8s.io/kubectl
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 12:10:09 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/discovery/v1/zz_generated.prerelease-lifecycle.go

    // It is controlled by "k8s:prerelease-lifecycle-gen:introduced" tags in types.go.
    func (in *EndpointSlice) APILifecycleIntroduced() (major, minor int) {
    	return 1, 21
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 23 17:42:49 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  9. staging/README.md

    - [`k8s.io/csi-translation-lib`](https://github.com/kubernetes/csi-translation-lib)
    - [`k8s.io/dynamic-resource-allocation`](https://github.com/kubernetes/dynamic-resource-allocation)
    - [`k8s.io/endpointslice`](https://github.com/kubernetes/endpointslice)
    - [`k8s.io/kms`](https://github.com/kubernetes/kms)
    - [`k8s.io/kube-aggregator`](https://github.com/kubernetes/kube-aggregator)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 11:23:09 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  10. hack/logcheck.conf

    contextual k8s.io/client-go/tools/record/.*
    contextual k8s.io/component-helpers/.*
    contextual k8s.io/cri-api/.*
    contextual k8s.io/cri-client/.*
    contextual k8s.io/dynamic-resource-allocation/.*
    contextual k8s.io/endpointslice/.*
    contextual k8s.io/kms/.*
    contextual k8s.io/kube-controller-manager/.*
    contextual k8s.io/kube-proxy/.*
    contextual k8s.io/kube-scheduler/.*
    contextual k8s.io/sample-apiserver/.*
    contextual k8s.io/sample-cli-plugin/.*
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 12:10:09 UTC 2024
    - 2.3K bytes
    - Viewed (0)
Back to top