- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for syncJob (0.12 sec)
-
pkg/kubelet/container/testing/runtime_mock.go
} // SyncPod indicates an expected call of SyncPod. func (mr *MockRuntimeMockRecorder) SyncPod(ctx, pod, podStatus, pullSecrets, backOff any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SyncPod", reflect.TypeOf((*MockRuntime)(nil).SyncPod), ctx, pod, podStatus, pullSecrets, backOff) } // Type mocks base method. func (m *MockRuntime) Type() string { m.ctrl.T.Helper()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 27K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/sync/sync.go
// // This method is safe to call from multiple goroutines. func (sync *NodeSync) Delete(node *v1.Node) { sync.opChan <- &deleteOp{node} close(sync.opChan) } // syncOp is the interface for generic sync operation. type syncOp interface { // run the requested sync operation. run(logger klog.Logger, sync *NodeSync) error } // updateOp handles creation and updates of a node. type updateOp struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 07:50:01 UTC 2023 - 12.6K bytes - Viewed (0) -
src/go/internal/gcimporter/ureader.go
// to avoid eager loading of imports. r.Sync(pkgbits.SyncObject) assert(!r.Bool()) r.p.objIdx(r.Reloc(pkgbits.RelocObj)) assert(r.Len() == 0) } r.Sync(pkgbits.SyncEOF) for _, fn := range pr.laterFns { fn() } for _, iface := range pr.ifaces { iface.Complete() } // Imports() of pkg are all of the transitive packages that were loaded.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/kubelet/status/status_manager.go
m.syncPod(update.podUID, update.status) } return len(updatedStatuses) } // syncPod syncs the given status with the API server. The caller must not hold the status lock. func (m *manager) syncPod(uid types.UID, status versionedPodStatus) { // TODO: make me easier to express from client code
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 44.3K bytes - Viewed (0) -
pkg/kubelet/container/testing/fake_runtime.go
pods = append(pods, fakePod.Pod) } } return pods, f.Err } func (f *FakeRuntime) SyncPod(_ context.Context, pod *v1.Pod, _ *kubecontainer.PodStatus, _ []v1.Secret, backOff *flowcontrol.Backoff) (result kubecontainer.PodSyncResult) { f.Lock() defer f.Unlock() f.CalledFunctions = append(f.CalledFunctions, "SyncPod") f.StartedPods = append(f.StartedPods, string(pod.UID)) for _, c := range pod.Spec.Containers {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 14 00:23:50 UTC 2024 - 13.9K bytes - Viewed (0) -
pkg/kubelet/preemption/preemption.go
Message: "Pod was preempted by Kubelet to accommodate a critical pod.", }) } }) if err != nil { klog.ErrorS(err, "Failed to evict pod", "pod", klog.KObj(pod)) // In future syncPod loops, the kubelet will retry the pod deletion steps that it was stuck on. continue } if len(insufficientResources) > 0 { metrics.Preemptions.WithLabelValues(insufficientResources[0].resourceName.String()).Inc()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 02 16:53:19 UTC 2023 - 11.5K bytes - Viewed (0) -
pkg/kubelet/container/runtime.go
// will be GC'd. // TODO: Revisit this method and make it cleaner. GarbageCollect(ctx context.Context, gcPolicy GCPolicy, allSourcesReady bool, evictNonDeletedPods bool) error // SyncPod syncs the running pod into the desired pod. SyncPod(ctx context.Context, pod *v1.Pod, podStatus *PodStatus, pullSecrets []v1.Secret, backOff *flowcontrol.Backoff) PodSyncResult
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 27.8K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
if err != nil { return err } switch prefix { case podKeyPrefix: return ec.syncPod(ctx, namespace, name) case claimKeyPrefix: return ec.syncClaim(ctx, namespace, name) default: return fmt.Errorf("unexpected key prefix: %s", prefix) } } func (ec *Controller) syncPod(ctx context.Context, namespace, name string) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go
// processing it at a very high frequency. The pod will be reprocessed when volume manager calls // ReprocessPod() which is triggered by SyncPod. dswp.markPodProcessed(uniquePodName) } } // checkVolumeFSResize records desired PVC size for a volume mounted by the pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 23.8K bytes - Viewed (0)