Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 70 for startLine (0.18 sec)

  1. pkg/registry/batch/job/strategy_test.go

    				Status: batch.JobStatus{
    					StartTime: &now,
    				},
    			},
    			newJob: &batch.Job{
    				ObjectMeta: validObjectMeta,
    				Status: batch.JobStatus{
    					StartTime: nil,
    				},
    			},
    			wantErrs: field.ErrorList{
    				{Type: field.ErrorTypeRequired, Field: "status.startTime"},
    			},
    		},
    		"verify startTime cannot be updated for unsuspended job": {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 101.5K bytes
    - Viewed (0)
  2. pkg/controller/job/job_controller_test.go

    			}
    			if tc.initialStatus != nil {
    				startTime := metav1.Now()
    				job.Status.StartTime = &startTime
    				job.Status.Active = int32(tc.initialStatus.active)
    				job.Status.Succeeded = int32(tc.initialStatus.succeed)
    				job.Status.Failed = int32(tc.initialStatus.failed)
    				if tc.initialStatus.startTime != nil {
    					startTime := metav1.NewTime(*tc.initialStatus.startTime)
    					job.Status.StartTime = &startTime
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet.go

    		if err != nil {
    			return nil, fmt.Errorf("while starting informer-based ClusterTrustBundle manager: %w", err)
    		}
    		kubeInformers.Start(wait.NeverStop)
    		klog.InfoS("Started ClusterTrustBundle informer")
    	} else {
    		// In static kubelet mode, use a no-op manager.
    		clusterTrustBundleManager = &clustertrustbundle.NoopManager{}
    		klog.InfoS("Not starting ClusterTrustBundle informer because we are in static kubelet mode")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_test.go

    	notYetActiveDeadlineSeconds := int64(120)
    	startTime := metav1.NewTime(clock.Now())
    	pods[0].Status.StartTime = &startTime
    	pods[0].Spec.ActiveDeadlineSeconds = &exceededActiveDeadlineSeconds
    	pods[1].Status.StartTime = &startTime
    	pods[1].Spec.ActiveDeadlineSeconds = &notYetActiveDeadlineSeconds
    	pods[2].Status.StartTime = &startTime
    	pods[2].Spec.ActiveDeadlineSeconds = &exceededActiveDeadlineSeconds
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  5. cmd/bucket-replication.go

    	startTime := time.Now()
    	return func(sz int64, err error) {
    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceReplicationResync) > 0 {
    			globalTrace.Publish(replicationResyncTrace(resyncID, startTime, duration, path, err, sz))
    		}
    	}
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 114.4K bytes
    - Viewed (0)
  6. src/runtime/proc.go

    		pp.preempt = true
    		preemptM(mp)
    	}
    
    	return true
    }
    
    var starttime int64
    
    func schedtrace(detailed bool) {
    	now := nanotime()
    	if starttime == 0 {
    		starttime = now
    	}
    
    	lock(&sched.lock)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  7. cmd/admin-handlers.go

    			}
    			b, err := json.Marshal(madmin.HealStartSuccess{
    				ClientToken:   clientToken,
    				ClientAddress: nh.clientAddress,
    				StartTime:     nh.startTime,
    			})
    			if err != nil {
    				writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    				return
    			}
    			// Client token not specified but a heal sequence exists on a path,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 98K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet_pods_test.go

    					UpdateType: kubetypes.SyncPodCreate,
    					StartTime:  time.Unix(1, 0).UTC(),
    					Pod:        pod,
    				})
    				drainAllWorkers(w)
    
    				// terminate the pod (which won't complete) and then deliver a recreate by that same UID
    				w.UpdatePod(UpdatePodOptions{
    					UpdateType: kubetypes.SyncPodKill,
    					StartTime:  time.Unix(2, 0).UTC(),
    					Pod:        pod,
    				})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/batch/v1/generated.pb.go

    			if postIndex < 0 {
    				return ErrInvalidLengthGenerated
    			}
    			if postIndex > l {
    				return io.ErrUnexpectedEOF
    			}
    			if m.StartTime == nil {
    				m.StartTime = &v1.Time{}
    			}
    			if err := m.StartTime.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
    				return err
    			}
    			iNdEx = postIndex
    		case 3:
    			if wireType != 2 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 20:49:09 UTC 2024
    - 133K bytes
    - Viewed (0)
  10. cmd/metrics-v2.go

    			internalLogOnceIf(ctx, err, string(nodeMetricNamespace))
    			return
    		}
    
    		openFDs, _ := p.FileDescriptorsLen()
    		l, _ := p.Limits()
    		io, _ := p.IO()
    		stat, _ := p.Stat()
    		startTime, _ := stat.StartTime()
    
    		metrics = make([]MetricV2, 0, 20)
    
    		if openFDs > 0 {
    			metrics = append(metrics,
    				MetricV2{
    					Description: getMinioFDOpenMD(),
    					Value:       float64(openFDs),
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:54 UTC 2024
    - 131.9K bytes
    - Viewed (0)
Back to top