Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 15 of 15 for syncJob (0.24 sec)

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

    	}
    	return resource.ExtractResourceValueByContainerName(fs, pod, containerName)
    }
    
    // killPod instructs the container runtime to kill the pod. This method requires that
    // the pod status contains the result of the last syncPod, otherwise it may fail to
    // terminate newly created containers and sandboxes.
    func (kl *Kubelet) killPod(ctx context.Context, pod *v1.Pod, p kubecontainer.Pod, gracePeriodOverride *int64) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
Back to top