- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for syncPod (0.17 sec)
-
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) -
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) -
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) -
pkg/kubelet/kuberuntime/kuberuntime_manager_test.go
// GetPodStatus and the following SyncPod will not return errors in the // case where the pod has been deleted. We are not adding any pods into // the fakePodProvider so they are 'deleted'. podStatus, err := m.GetPodStatus(ctx, pod.UID, pod.Name, pod.Namespace) assert.NoError(t, err) result := m.SyncPod(context.Background(), pod, podStatus, []v1.Secret{}, backOff)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 96K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
} } return pods, err } // syncJob will sync the job with the given key if it has had its expectations fulfilled, meaning // it did not expect to see any more of its pods created or deleted. This function is not meant to be invoked // concurrently with the same key. func (jm *Controller) syncJob(ctx context.Context, key string) (rErr error) { startTime := jm.clock.Now()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
// dsStoreSynced returns true if the daemonset store has been synced at least once. // Added as a member to the struct to allow injection for testing. dsStoreSynced cache.InformerSynced // historyLister get list/get history from the shared informers's store historyLister appslisters.ControllerRevisionLister // historyStoreSynced returns true if the history store has been synced at least once.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/kubelet/nodestatus/setters_test.go
} cases := []struct { desc string node *v1.Node synced bool volumesInUse []v1.UniqueVolumeName expectVolumesInUse []v1.UniqueVolumeName }{ { desc: "synced", node: withVolumesInUse.DeepCopy(), synced: true, volumesInUse: []v1.UniqueVolumeName{"bar"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 21:47:24 UTC 2024 - 76.1K bytes - Viewed (0) -
src/go/parser/parser.go
// both parseOperand and parseStmt call advance and // correctly do not advance, thus the need for the // invocation limit p.syncCnt). if p.pos == p.syncPos && p.syncCnt < 10 { p.syncCnt++ return } if p.pos > p.syncPos { p.syncPos = p.pos p.syncCnt = 0 return } // Reaching here indicates a parser bug, likely an // incorrect token list in this function, but it only
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Dec 08 20:07:50 UTC 2023 - 72.2K bytes - Viewed (0) -
src/cmd/compile/internal/ppc64/ssa.go
st = ppc64.AMOVW } arg0 := v.Args[0].Reg() arg1 := v.Args[1].Reg() // If AuxInt == 0, LWSYNC (Store-Release), else SYNC // SYNC syncOp := ppc64.ASYNC if v.AuxInt == 0 { syncOp = ppc64.ALWSYNC } psync := s.Prog(syncOp) psync.To.Type = obj.TYPE_NONE // Store p := s.Prog(st) p.To.Type = obj.TYPE_MEM p.To.Reg = arg0 p.From.Type = obj.TYPE_REG p.From.Reg = arg1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 19:59:38 UTC 2024 - 55.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
handler = apifilters.WithAuditInit(handler) return handler } func unsyncedInformers(status map[reflect.Type]bool) []string { names := make([]string, 0) for objType, synced := range status { if !synced { names = append(names, objType.Name()) } } return names } func newConfiguration(fsName, plName, user string, concurrency int32, queueLength int32) []runtime.Object {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0)