- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 169 for addJob (0.31 sec)
-
pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
), } logger := klog.FromContext(ctx) jobInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { tc.addJob(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { tc.updateJob(logger, oldObj, newObj) }, }) tc.jLister = jobInformer.Lister() tc.jListerSynced = jobInformer.Informer().HasSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 23:59:28 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2.go
cronJobListerSynced: cronJobsInformer.Informer().HasSynced, now: time.Now, } jobInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: jm.addJob, UpdateFunc: jm.updateJob, DeleteFunc: jm.deleteJob, }) cronJobsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { jm.enqueueController(obj)
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/job/job_controller.go
clock: clock, podBackoffStore: newBackoffStore(), } if _, err := jobInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { jm.addJob(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { jm.updateJob(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { jm.deleteJob(logger, obj) }, }); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
src/cmd/go/testdata/addmod.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. //go:build ignore // +build ignore // Addmod adds a module as a txtar archive to the testdata/mod directory. // // Usage: // // go run addmod.go path@version... // // It should only be used for very small modules - we do not want to check // very large files into testdata/mod. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Aug 30 19:41:54 UTC 2023 - 3.5K bytes - Viewed (0) -
tensorflow/c/eager/c_api_unified_experimental_test.cc
ASSERT_EQ(TF_OK, TF_GetCode(status.get())) << TF_Message(status.get()); // Build an abstract operation. auto* add_op = TF_NewAbstractOp(graph_ctx); TF_AbstractOpSetOpType(add_op, "Add", status.get()); ASSERT_EQ(TF_OK, TF_GetCode(status.get())) << TF_Message(status.get()); TF_AbstractOpSetOpName(add_op, "my_add", status.get()); ASSERT_EQ(TF_OK, TF_GetCode(status.get())) << TF_Message(status.get());
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 19 21:44:52 UTC 2023 - 39.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
dsw.AddNode(nodeName1) dsw.AddNode(nodeName2) generatedVolumeName, podAddErr := dsw.AddPod(types.UniquePodName(podName1), controllervolumetesting.NewPod(podName1, podName1), volumeSpec, nodeName1) if podAddErr != nil { t.Fatalf("AddPod failed. Expected: <no error> Actual: <%v>", podAddErr) } _, podAddErr = dsw.AddPod(types.UniquePodName(podName2), controllervolumetesting.NewPod(podName2, podName2), volumeSpec, nodeName2)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
releasenotes/notes/addon-remove.yaml
Brian Avery <******@****.***> 1597180858 -0400
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 11 21:20:58 UTC 2020 - 344 bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/facts/imports.go
addType(tparams.At(i)) } } case *types.Struct: for i := 0; i < T.NumFields(); i++ { addObj(T.Field(i)) } case *types.Tuple: for i := 0; i < T.Len(); i++ { addObj(T.At(i)) } case *types.Interface: for i := 0; i < T.NumMethods(); i++ { addObj(T.Method(i)) } for i := 0; i < T.NumEmbeddeds(); i++ { addType(T.EmbeddedType(i)) // walk Embedded for implicits
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 3.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/gpu_fusion.cc
AddV2Op add_op; Value side_input; if (!batch_norm) { // We don't have a FusedBatchNorm as input to the ReLu, but we can get // through an AddV2 as well. add_op = dyn_cast_or_null<AddV2Op>(relu_input); if (!add_op) return failure(); batch_norm = dyn_cast_or_null<FusedBatchNormV3Op>(add_op.getX().getDefiningOp()); if (batch_norm) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Nov 03 12:35:38 UTC 2022 - 5.2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go
dsw.AddNode(nodeName) generatedVolumeName1, pod1AddErr := dsw.AddPod(types.UniquePodName(pod1Name), controllervolumetesting.NewPod(pod1Name, pod1Name), volumeSpec, nodeName) if pod1AddErr != nil { t.Fatalf( "AddPod failed for pod %q. Expected: <no error> Actual: <%v>", pod1Name, pod1AddErr) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 35.9K bytes - Viewed (0)