- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for pcds (0.04 sec)
-
pkg/kubelet/kubelet_test.go
pods[2].Spec.ActiveDeadlineSeconds = &exceededActiveDeadlineSeconds kubelet.podManager.SetPods(pods) kubelet.workQueue.Enqueue(pods[2].UID, 0) kubelet.workQueue.Enqueue(pods[3].UID, 30*time.Second) kubelet.workQueue.Enqueue(pods[4].UID, 2*time.Minute) clock.Step(1 * time.Minute) expected := []*v1.Pod{pods[2], pods[3], pods[0]} podsToSync := kubelet.getPodsToSync()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
} // Get a list of pods that have data directories. func (kl *Kubelet) listPodsFromDisk() ([]types.UID, error) { podInfos, err := os.ReadDir(kl.getPodsDir()) if err != nil { return nil, err } pods := []types.UID{} for i := range podInfos { if podInfos[i].IsDir() { pods = append(pods, types.UID(podInfos[i].Name())) } } return pods, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
handler.HandlePodUpdates(u.Pods) case kubetypes.REMOVE: klog.V(2).InfoS("SyncLoop REMOVE", "source", u.Source, "pods", klog.KObjSlice(u.Pods)) handler.HandlePodRemoves(u.Pods) case kubetypes.RECONCILE: klog.V(4).InfoS("SyncLoop RECONCILE", "source", u.Source, "pods", klog.KObjSlice(u.Pods)) handler.HandlePodReconcile(u.Pods) case kubetypes.DELETE:
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/xds/delta.go
} err := s.pushDeltaXds(con, con.proxy.GetWatchedResource(req.TypeUrl), request) if err != nil { return err } // Anytime we get a CDS request on reconnect, we should always push EDS as well. // It is always the server's responsibility to send EDS after CDS, regardless if // Envoy asks for it or not (See https://github.com/envoyproxy/envoy/issues/33607 for more details).
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
// current list, a full push will be forced, to trigger a secure naming update. // Due to the larger time, it is still possible that connection errors will occur while // CDS is updated. ServiceAccounts sets.String } // Keys gives a sorted list of keys for EndpointShards.Shards. // Calls to Keys should be guarded with a lock on the EndpointShards. func (es *EndpointShards) Keys() []ShardKey {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 96K bytes - Viewed (0) -
pilot/pkg/model/gateway.go
if g != nil { return g.ContainsAutoPassthroughGateways } return false } // PrevMergedGateway describes previous state of the gateway. // Currently, it only contains information relevant for CDS. type PrevMergedGateway struct { ContainsAutoPassthroughGateways bool AutoPassthroughSNIHosts sets.Set[string] } func (g *PrevMergedGateway) HasAutoPassthroughGateway() bool { if g != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 26K bytes - Viewed (0) -
pkg/config/analysis/analyzers/analyzers_test.go
}, analyzer: &deployment.ApplicationUIDAnalyzer{}, expected: []message{ {msg.InvalidApplicationUID, "Deployment deploy-con-sec-uid"}, }, }, { name: "Detect `image: auto` in non-injected pods", inputFiles: []string{ "testdata/image-auto.yaml", }, analyzer: &injection.ImageAutoAnalyzer{}, expected: []message{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 07:22:31 UTC 2024 - 42.6K bytes - Viewed (0)