- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for evenly (0.28 sec)
-
pkg/kubelet/kubelet.go
if isSyncPodWorthy(e) { // PLEG event for a pod; sync it. if pod, ok := kl.podManager.GetPodByUID(e.ID); ok { klog.V(2).InfoS("SyncLoop (PLEG): event for pod", "pod", klog.KObj(pod), "event", e) handler.HandlePodSyncs([]*v1.Pod{pod}) } else { // If the pod no longer exists, ignore the event. klog.V(4).InfoS("SyncLoop (PLEG): pod does not exist, ignore irrelevant event", "event", e) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
return false } return config.LabelsInRevision(object.GetLabels(), cl.revision) } func (cl *Client) onEvent(resourceGVK config.GroupVersionKind, old controllers.Object, curr controllers.Object, event model.Event) { currItem := controllers.ExtractObject(curr) if currItem == nil { return } currConfig := TranslateObject(currItem, resourceGVK, cl.domainSuffix) var oldConfig config.Config
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
default: // this collapses any unknown state to container waiting. If any container is waiting, then the pod status moves to pending even if it is running. // if I'm reading this correctly, then any failure to read status on any container results in the entire pod going pending even if the containers // are actually running.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
cmd/bucket-handlers.go
return } // Notify object created events. sendEvent(eventArgsList[i]) if eventArgsList[i].Object.NumVersions > int(scannerExcessObjectVersions.Load()) { // Send events for excessive versions. sendEvent(eventArgs{ EventName: event.ObjectManyVersions, BucketName: eventArgsList[i].Object.Bucket,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 61.2K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
} // Send pushes to all generators // Each Generator is responsible for determining if the push event requires a push wrl := con.watchedResourcesByOrder() for _, w := range wrl { if err := s.pushDeltaXds(con, w, pushRequest); err != nil { return err } } if pushRequest.Full { // Report all events for unwatched resources. Watched resources will be reported in pushXds or on ack.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
docs/en/docs/release-notes.md
return {"result": result} ``` **Note**: This is the recommended way going forward, instead of using `startup` and `shutdown` events. Read more about it in the new docs: [Advanced User Guide: Lifespan Events](https://fastapi.tiangolo.com/advanced/events/). ### Docs
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Fri Jun 14 15:07:37 UTC 2024 - 395.4K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/conversion.go
// Over-matching is fine because this only controls the set of namespace // label change events to watch and the actual binding enforcement happens // by checking the intersection of the generated VirtualService.spec.hosts // and Istio Gateway.spec.servers.hosts arrays - we just can't miss // potentially relevant namespace label events here. res = append(res, "*") } res = append(res, me.Key) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 84.7K bytes - Viewed (0)