- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 70 for startLine (0.18 sec)
-
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) -
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) -
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) -
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 = ¬YetActiveDeadlineSeconds 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) -
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) -
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) -
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) -
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) -
staging/src/k8s.io/api/batch/v1/generated.pb.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 20:49:09 UTC 2024 - 133K bytes - Viewed (0) -
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)