- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 189 for newobj (0.14 sec)
-
src/go/doc/doc.go
func simpleImporter(imports map[string]*ast.Object, path string) (*ast.Object, error) { pkg := imports[path] if pkg == nil { // note that strings.LastIndex returns -1 if there is no "/" pkg = ast.NewObj(ast.Pkg, path[strings.LastIndex(path, "/")+1:]) pkg.Data = ast.NewScope(nil) // required by ast.NewPackage for dot-import imports[path] = pkg } return pkg, nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 12:02:03 UTC 2023 - 11.2K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2.go
logger.V(2).Info("Unparseable schedule for cronjob", "cronjob", klog.KObj(newCJ), "schedule", newCJ.Spec.Schedule, "err", err) jm.recorder.Eventf(newCJ, corev1.EventTypeWarning, "UnParseableCronJobSchedule", "unparseable schedule for cronjob: %s", newCJ.Spec.Schedule) return } now := jm.now() t := nextScheduleTimeDuration(newCJ, now, sched) jm.enqueueControllerAfter(curr, *t) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 29.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
} out := &example.Pod{} store.GuaranteedUpdate(ctx, key, out, true, nil, storage.SimpleUpdate( func(runtime.Object) (runtime.Object, error) { newObj := storedObj.DeepCopy() newObj.Annotations = map[string]string{"version": "2"} return newObj, nil }), nil) testCheckResult(t, w, watch.Event{Type: watch.Modified, Object: out}) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18.2K bytes - Viewed (0) -
operator/pkg/translate/translate.go
if err != nil { return nil, fmt.Errorf("get error: %s to merge patch:\n%s for base:\n%s", err, overlayJSON, baseJSON) } newObj, err := object.ParseJSONToK8sObject(newBytes) if err != nil { return nil, err } return newObj.ResolveK8sConflict(), nil } // createPatchObjectFromPath constructs patch object for node with path, returns nil object and error if the path is invalid.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 12 19:43:09 UTC 2024 - 36.3K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
} 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 { return nil, fmt.Errorf("adding Job event handler: %w", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/rest/rest.go
// The only time an empty oldObj should be passed in is if a "create on update" is occurring (there is no oldObj). UpdatedObject(ctx context.Context, oldObj runtime.Object) (newObj runtime.Object, err error) } // ValidateObjectFunc is a function to act on a given object. An error may be returned // if the hook cannot be completed. A ValidateObjectFunc may NOT transform the provided // object.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 20 14:29:25 UTC 2023 - 18.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go
} // updateCustomResourceDefinition removes potentially stale storage so it gets re-created func (r *crdHandler) updateCustomResourceDefinition(oldObj, newObj interface{}) { oldCRD := oldObj.(*apiextensionsv1.CustomResourceDefinition) newCRD := newObj.(*apiextensionsv1.CustomResourceDefinition) r.customStorageLock.Lock() defer r.customStorageLock.Unlock() // Add CRD to the establishing controller queue.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 19:06:46 UTC 2024 - 52.9K bytes - Viewed (0) -
src/go/printer/testdata/parser.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jul 20 20:19:51 UTC 2023 - 50.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/rest/resttest/resttest.go
t.setObjectMeta(foo, t.namer(1)) if err := createFn(ctx, foo); err != nil { t.Errorf("unexpected error: %v", err) } newObj, err := getFn(ctx, foo) if err != nil { t.Errorf("unexpected error: %v", err) } objectMeta := t.getObjectMetaOrFail(newObj) opts.Preconditions = metav1.NewRVDeletionPrecondition("wrongVersion").Preconditions
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 55.8K bytes - Viewed (0)