- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for managedByController (0.18 sec)
-
pkg/controller/endpointslicemirroring/utils.go
func managedByChanged(endpointSlice1, endpointSlice2 *discovery.EndpointSlice) bool { return managedByController(endpointSlice1) != managedByController(endpointSlice2) } // managedByController returns true if the controller of the provided // EndpointSlices is the EndpointSlice controller. func managedByController(endpointSlice *discovery.EndpointSlice) bool { managedBy, _ := endpointSlice.Labels[discovery.LabelManagedBy]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 8.8K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
func getFamilyByIP(ip net.IP) v1.IPFamily { if netutils.IsIPv6(ip) { return v1.IPv6Protocol } return v1.IPv4Protocol } // managedByController returns true if the controller of the provided // EndpointSlices is the EndpointSlice controller. func managedByController(ip *networkingv1alpha1.IPAddress) bool { managedBy, ok := ip.Labels[networkingv1alpha1.LabelManagedBy] if !ok { return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
endpointSlice := obj.(*discovery.EndpointSlice) if endpointSlice == nil { utilruntime.HandleError(fmt.Errorf("Invalid EndpointSlice provided to onEndpointSliceAdd()")) return } if c.reconciler.ManagedByController(endpointSlice) && c.endpointSliceTracker.ShouldSync(endpointSlice) { c.queueServiceForEndpointSlice(endpointSlice) } } // onEndpointSliceUpdate queues a sync for the relevant Service for a sync if
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
endpointSlice := obj.(*discovery.EndpointSlice) if endpointSlice == nil { utilruntime.HandleError(fmt.Errorf("onEndpointSliceAdd() expected type discovery.EndpointSlice, got %T", obj)) return } if managedByController(endpointSlice) && c.endpointSliceTracker.ShouldSync(endpointSlice) { c.queueEndpointsForEndpointSlice(endpointSlice) } } // onEndpointSliceUpdate queues a sync for the relevant Endpoints resource for a
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0)