- Sort Score
- Result 10 results
- Languages All
Results 11 - 12 of 12 for register_handler (0.13 sec)
-
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
out := &endpointSliceController{ c: c, slices: slices, endpointCache: newEndpointSliceCache(), } registerHandlers[*v1.EndpointSlice](c, slices, "EndpointSlice", out.onEvent, nil) return out } func (esc *endpointSliceController) podArrived(name, ns string) error { ep := esc.slices.Get(name, ns) if ep == nil { return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0) -
cmd/kube-proxy/app/server.go
informers.WithTweakListOptions(func(options *metav1.ListOptions) { options.LabelSelector = labelSelector.String() })) // Create configs (i.e. Watches for Services, EndpointSlices and ServiceCIDRs) // Note: RegisterHandler() calls need to happen before creation of Sources because sources // only notify on changes, and the initial update (on process start) may be lost if no handlers // are registered yet.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 46.8K bytes - Viewed (0)