Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 206 for endpointSlice (0.33 sec)

  1. pkg/proxy/winkernel/proxier_test.go

    		}
    	}
    }
    
    func TestNoopEndpointSlice(t *testing.T) {
    	p := Proxier{}
    	p.OnEndpointSliceAdd(&discovery.EndpointSlice{})
    	p.OnEndpointSliceUpdate(&discovery.EndpointSlice{}, &discovery.EndpointSlice{})
    	p.OnEndpointSliceDelete(&discovery.EndpointSlice{})
    	p.OnEndpointSlicesSynced()
    }
    
    func TestFindRemoteSubnetProviderAddress(t *testing.T) {
    	syncPeriod := 30 * time.Second
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 28 14:30:51 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/api/discovery/v1/zz_generated.deepcopy.go

    func (in *EndpointSlice) DeepCopy() *EndpointSlice {
    	if in == nil {
    		return nil
    	}
    	out := new(EndpointSlice)
    	in.DeepCopyInto(out)
    	return out
    }
    
    // DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
    func (in *EndpointSlice) DeepCopyObject() runtime.Object {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 6.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/api/discovery/v1beta1/zz_generated.deepcopy.go

    func (in *EndpointSlice) DeepCopy() *EndpointSlice {
    	if in == nil {
    		return nil
    	}
    	out := new(EndpointSlice)
    	in.DeepCopyInto(out)
    	return out
    }
    
    // DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
    func (in *EndpointSlice) DeepCopyObject() runtime.Object {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 6.5K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/discovery/v1beta1/zz_generated.prerelease-lifecycle.go

    func (in *EndpointSlice) APILifecycleDeprecated() (major, minor int) {
    	return 1, 21
    }
    
    // APILifecycleReplacement is an autogenerated function, returning the group, version, and kind that should be used instead of this deprecated type.
    // It is controlled by "k8s:prerelease-lifecycle-gen:replacement=<group>,<version>,<kind>" tags in types.go.
    func (in *EndpointSlice) APILifecycleReplacement() schema.GroupVersionKind {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 3.8K bytes
    - Viewed (0)
  5. pkg/apis/discovery/zz_generated.deepcopy.go

    func (in *EndpointSlice) DeepCopy() *EndpointSlice {
    	if in == nil {
    		return nil
    	}
    	out := new(EndpointSlice)
    	in.DeepCopyInto(out)
    	return out
    }
    
    // DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
    func (in *EndpointSlice) DeepCopyObject() runtime.Object {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 6.6K bytes
    - Viewed (0)
  6. pkg/proxy/ipvs/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: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
  7. cmd/kube-controller-manager/app/options/endpointslicemirroringcontroller.go

    	fs.DurationVar(&o.MirroringEndpointUpdatesBatchPeriod.Duration, "mirroring-endpointslice-updates-batch-period", o.MirroringEndpointUpdatesBatchPeriod.Duration, fmt.Sprintf("The length of EndpointSlice updates batching period for %s. Processing of EndpointSlice changes...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 19 13:01:01 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/discovery/v1/types_swagger_doc_generated.go

    	return map_EndpointHints
    }
    
    var map_EndpointPort = map[string]string{
    	"":            "EndpointPort represents a Port used by an EndpointSlice",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 18 15:36:48 UTC 2023
    - 8.1K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/discovery/v1beta1/types.go

    // +k8s:prerelease-lifecycle-gen:replacement=discovery.k8s.io,v1,EndpointSlice
    
    // 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: Sun Sep 17 09:26:19 UTC 2023
    - 9.5K bytes
    - Viewed (0)
  10. pkg/apis/discovery/v1/zz_generated.defaults.go

    	scheme.AddTypeDefaultingFunc(&v1.EndpointSlice{}, func(obj interface{}) { SetObjectDefaults_EndpointSlice(obj.(*v1.EndpointSlice)) })
    	scheme.AddTypeDefaultingFunc(&v1.EndpointSliceList{}, func(obj interface{}) { SetObjectDefaults_EndpointSliceList(obj.(*v1.EndpointSliceList)) })
    	return nil
    }
    
    func SetObjectDefaults_EndpointSlice(in *v1.EndpointSlice) {
    	for i := range in.Ports {
    		a := &in.Ports[i]
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 1.6K bytes
    - Viewed (0)
Back to top