Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 242 for syncPod (0.26 sec)

  1. 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)
  2. pkg/kubelet/pod_workers.go

    	// be terminated and have resources reclaimed. It returns false before the
    	// pod workers have synced (syncPod could be called). Once the pod workers
    	// have synced it returns false if the pod has a sync status until
    	// SyncTerminatedPod completes successfully. If the pod workers have synced,
    	// but the pod does not have a status it returns true.
    	//
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 02 13:22:37 UTC 2024
    - 74.8K bytes
    - Viewed (0)
  3. 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)
  4. pkg/kubelet/pod_workers_test.go

    	var channels WorkChannel
    	podWorkers.workerChannelFn = channels.Intercept
    	terminalPhaseSyncer := newTerminalPhaseSync(podWorkers.podSyncer.(*podSyncerFuncs).syncPod)
    	podWorkers.podSyncer.(*podSyncerFuncs).syncPod = terminalPhaseSyncer.SyncPod
    
    	// start pod
    	podWorkers.UpdatePod(UpdatePodOptions{
    		Pod:        newNamedPod("1", "test1", "pod1", false),
    		UpdateType: kubetypes.SyncPodUpdate,
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet.go

    // (pod is running). If SyncPod exits with a transient error, the next
    // invocation of SyncPod is expected to make progress towards reaching the
    // desired state. SyncPod exits with isTerminal when the pod was detected to
    // have reached a terminal lifecycle phase due to container exits (for
    // RestartNever or RestartOnFailure) and the next method invoked will be
    // SyncTerminatingPod. If the pod terminates for any other reason, SyncPod
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    	// If resize results in net pod resource decrease, set pod cgroup config after resizing containers.
    	// If an error occurs at any point, abort. Let future syncpod iterations retry the unfinished stuff.
    	resizeContainers := func(rName v1.ResourceName, currPodCgLimValue, newPodCgLimValue, currPodCgReqValue, newPodCgReqValue int64) error {
    		var err error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  9. 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)
  10. pkg/kubelet/kubelet_test.go

    	})
    
    	_, err = kubelet.SyncPod(context.Background(), kubetypes.SyncPodCreate, pod, nil, &kubecontainer.PodStatus{})
    	require.NoError(t, err)
    
    	require.NoError(t, err)
    	assert.NotEmpty(t, exp.GetSpans())
    
    	// find root span for syncPod
    	var rootSpan *tracetest.SpanStub
    	spans := exp.GetSpans()
    	for i, span := range spans {
    		if span.Name == "syncPod" {
    			rootSpan = &spans[i]
    			break
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
Back to top