- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 68 for syncPod (0.11 sec)
-
pkg/kubelet/container/sync_result.go
func (r *SyncResult) Fail(err error, msg string) { r.Error, r.Message = err, msg } // PodSyncResult is the summary result of SyncPod() and KillPod() type PodSyncResult struct { // Result of different sync actions SyncResults []*SyncResult // Error encountered in SyncPod() and KillPod() that is not already included in SyncResults SyncError error }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 19 15:48:08 UTC 2020 - 4.6K bytes - Viewed (0) -
pkg/kubelet/runonce.go
if err := kl.mirrorPodClient.CreateMirrorPod(pod); err != nil { klog.ErrorS(err, "Failed creating a mirror pod", "pod", klog.KObj(pod)) } mirrorPod, _ := kl.podManager.GetMirrorPodByPod(pod) if isTerminal, err = kl.SyncPod(ctx, kubetypes.SyncPodUpdate, pod, mirrorPod, status); err != nil { return fmt.Errorf("error syncing pod %q: %v", format.Pod(pod), err) } if retry >= runOnceMaxRetries {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 5.9K bytes - Viewed (0) -
src/internal/pkgbits/sync.go
const ( _ SyncMarker = iota // Public markers (known to go/types importers). // Low-level coding markers. SyncEOF SyncBool SyncInt64 SyncUint64 SyncString SyncValue SyncVal SyncRelocs SyncReloc SyncUseReloc // Higher-level object and type markers. SyncPublic SyncPos SyncPosBase SyncObject SyncObject1 SyncPkg SyncPkgDef SyncMethod SyncType SyncTypeIdx
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Aug 04 17:12:28 UTC 2022 - 2.4K bytes - Viewed (0) -
src/internal/pkgbits/syncmarker_string.go
// Re-run the stringer command to generate them again. var x [1]struct{} _ = x[SyncEOF-1] _ = x[SyncBool-2] _ = x[SyncInt64-3] _ = x[SyncUint64-4] _ = x[SyncString-5] _ = x[SyncValue-6] _ = x[SyncVal-7] _ = x[SyncRelocs-8] _ = x[SyncReloc-9] _ = x[SyncUseReloc-10] _ = x[SyncPublic-11] _ = x[SyncPos-12] _ = x[SyncPosBase-13] _ = x[SyncObject-14] _ = x[SyncObject1-15] _ = x[SyncPkg-16]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 11 20:24:07 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/proxy/healthcheck/proxier_health.go
// or the proxier is fully synced. continue } if currentTime.Sub(hs.oldestPendingQueuedMap[ipFamily]) < hs.healthTimeout { // there's an unprocessed update queued for this proxier, but it's not late yet. continue } return false, proxierLastUpdated } return true, lastUpdated } // SyncNode syncs the node and determines if it is eligible or not. Eligible is
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 16 10:41:18 UTC 2023 - 8K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/testdata/multiXdsStatusMultiPilot.txt
NAME CLUSTER CDS LDS EDS RDS ECDS ISTIOD VERSION proxy1 cluster1 STALE SYNCED SYNCED NOT SENT SYNCED istiod1 1.20 proxy2 cluster2 STALE SYNCED STALE SYNCED STALE istiod2 1.19 proxy3 cluster3 NOT SENT ERROR STALE NOT SENT NOT SENT istiod3 1.20
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 03:42:52 UTC 2024 - 522 bytes - Viewed (0) -
pkg/kube/krt/join.go
o.name = fmt.Sprintf("Join[%v]", ptr.TypeName[T]()) } synced := make(chan struct{}) c := slices.Map(cs, func(e Collection[T]) internalCollection[T] { return e.(internalCollection[T]) }) go func() { for _, c := range c { if !c.Synced().WaitUntilSynced(o.stop) { return } } close(synced) log.Infof("%v synced", o.name) }()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 3.3K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/testdata/multiXdsStatusSinglePilot.txt
NAME CLUSTER CDS LDS EDS RDS ECDS ISTIOD VERSION proxy1 cluster1 STALE SYNCED SYNCED NOT SENT NOT SENT istiod1 1.20
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 03:42:52 UTC 2024 - 300 bytes - Viewed (0) -
pkg/kube/krt/sync.go
_ Syncer = channelSyncer{} _ Syncer = pollSyncer{} ) type channelSyncer struct { name string synced <-chan struct{} } func (c channelSyncer) WaitUntilSynced(stop <-chan struct{}) bool { return waitForCacheSync(c.name, stop, c.synced) } func (c channelSyncer) HasSynced() bool { select { case <-c.synced: return true default: return false } } type pollSyncer struct { name string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 03 14:25:07 UTC 2024 - 1.8K bytes - Viewed (0) -
pkg/kube/krt/informer.go
var _ internalCollection[controllers.Object] = &informer[controllers.Object]{} func (i *informer[I]) _internalHandler() {} func (i *informer[I]) Synced() Syncer { return channelSyncer{ name: i.collectionName, synced: i.synced, } } // nolint: unused // (not true, its to implement an interface) func (i *informer[I]) dump() { i.log.Errorf(">>> BEGIN DUMP") for _, obj := range i.inf.List(metav1.NamespaceAll, klabels.Everything()) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 11:01:46 UTC 2024 - 6.1K bytes - Viewed (0)