- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 127 for CRONJOB (0.09 sec)
-
staging/src/k8s.io/api/testdata/HEAD/batch.v1beta1.CronJob.pb
Shingo Omura <******@****.***> 1717022429 +0900
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 11.2K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/v1.30.0/batch.v1.CronJob.pb
SataQiu <******@****.***> 1713430345 +0800
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:52:25 UTC 2024 - 11.1K bytes - Viewed (0) -
pkg/registry/batch/cronjob/strategy_test.go
}, }, }, } Strategy.PrepareForCreate(ctx, cronJob) if len(cronJob.Status.Active) != 0 { t.Errorf("CronJob does not allow setting status on create") } if cronJob.Generation != 1 { t.Errorf("expected Generation=1, got %d", cronJob.Generation) } errs := Strategy.Validate(ctx, cronJob) if len(errs) != 0 { t.Errorf("Unexpected error validating %v", errs) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 14:34:53 UTC 2024 - 12.2K bytes - Viewed (0) -
pkg/registry/batch/cronjob/doc.go
See the License for the specific language governing permissions and limitations under the License. */ // Package cronjob provides Registry interface and it's RESTStorage // implementation for storing CronJob api objects.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 17 08:24:07 UTC 2017 - 763 bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2.go
logger.V(2).Info("Error reconciling cronjob", "cronjob", klog.KObj(cronJob), "err", syncErr) } // Update the CronJob if needed if updateStatusAfterCleanup || updateStatusAfterSync { if _, err := jm.cronJobControl.UpdateStatus(ctx, cronJobCopy); err != nil { logger.V(2).Info("Unable to update status for cronjob", "cronjob", klog.KObj(cronJob), "resourceVersion", cronJob.ResourceVersion, "err", err) return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2_test.go
now time.Time cronJob *batchv1.CronJob finishedJobs []*batchv1.Job jobCreateError error expectedDeletedJobs []string }{ { name: "jobs are still deleted when a cronjob can't create jobs due to jobs quota being reached (avoiding a deadlock)", now: *justAfterTheHour(), cronJob: &batchv1.CronJob{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 70.8K bytes - Viewed (0) -
staging/src/k8s.io/api/batch/v1beta1/zz_generated.deepcopy.go
func (in *CronJob) DeepCopyInto(out *CronJob) { *out = *in out.TypeMeta = in.TypeMeta in.ObjectMeta.DeepCopyInto(&out.ObjectMeta) in.Spec.DeepCopyInto(&out.Spec) in.Status.DeepCopyInto(&out.Status) return } // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CronJob. func (in *CronJob) DeepCopy() *CronJob { if in == nil { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 01 21:43:25 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/controller/cronjob/injection.go
CronJob *batchv1.CronJob Updates []batchv1.CronJob } func (c *fakeCJControl) GetCronJob(ctx context.Context, namespace, name string) (*batchv1.CronJob, error) { if name == c.CronJob.Name && namespace == c.CronJob.Namespace { return c.CronJob, nil } return nil, errors.NewNotFound(schema.GroupResource{ Group: "v1beta1", Resource: "cronjobs", }, name) } var _ cjControlInterface = &fakeCJControl{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 22 09:37:31 UTC 2023 - 4.7K bytes - Viewed (0) -
pkg/registry/batch/cronjob/strategy.go
// PrepareForCreate clears the status of a scheduled job before creation. func (cronJobStrategy) PrepareForCreate(ctx context.Context, obj runtime.Object) { cronJob := obj.(*batch.CronJob) cronJob.Status = batch.CronJobStatus{} cronJob.Generation = 1 pod.DropDisabledTemplateFields(&cronJob.Spec.JobTemplate.Spec.Template, nil) } // PrepareForUpdate clears fields that are not allowed to be set by end users on update.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 15:14:03 UTC 2023 - 7.3K bytes - Viewed (0) -
pkg/apis/batch/v1beta1/defaults_test.go
) func TestSetDefaultCronJob(t *testing.T) { tests := map[string]struct { original *batchv1beta1.CronJob expected *batchv1beta1.CronJob }{ "empty batchv1beta1.CronJob should default batchv1beta1.ConcurrencyPolicy and Suspend": { original: &batchv1beta1.CronJob{}, expected: &batchv1beta1.CronJob{ Spec: batchv1beta1.CronJobSpec{ ConcurrencyPolicy: batchv1beta1.AllowConcurrent,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 08 12:14:37 UTC 2023 - 3.9K bytes - Viewed (0)