- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for EnforcePtr (0.16 sec)
-
staging/src/k8s.io/apimachinery/pkg/conversion/helper.go
limitations under the License. */ package conversion import ( "fmt" "reflect" ) // EnforcePtr ensures that obj is a pointer of some sort. Returns a reflect.Value // of the dereferenced pointer, ensuring that it is settable/addressable. // Returns an error if this is not possible. func EnforcePtr(obj interface{}) (reflect.Value, error) { v := reflect.ValueOf(obj) if v.Kind() != reflect.Pointer {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 25 16:23:43 UTC 2022 - 1.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/meta/help.go
} return obj, nil } // getItemsPtr returns a pointer to the list object's Items member or an error. func getItemsPtr(list runtime.Object) (interface{}, error) { v, err := conversion.EnforcePtr(list) if err != nil { return nil, err } items := v.FieldByName("Items") if !items.IsValid() { return nil, errExpectFieldItems } switch items.Kind() { case reflect.Interface, reflect.Pointer:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 16:25:43 UTC 2023 - 9.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/helper.go
field := v.FieldByName(fieldName) if !field.IsValid() { return fmt.Errorf("couldn't find %v field in %T", fieldName, v.Interface()) } destValue, err := conversion.EnforcePtr(dest) if err != nil { return err } if field.Type().AssignableTo(destValue.Type()) { destValue.Set(field) return nil } if field.Type().ConvertibleTo(destValue.Type()) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Dec 13 22:54:34 UTC 2023 - 8.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/conversion/converter.go
return fn(src, dest, scope) } if fn, ok := c.generatedConversionFuncs.untyped[pair]; ok { return fn(src, dest, scope) } dv, err := EnforcePtr(dest) if err != nil { return err } sv, err := EnforcePtr(src) if err != nil { return err } return fmt.Errorf("converting (%s) to (%s): unknown conversion", sv.Type(), dv.Type())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 25 16:23:43 UTC 2022 - 7.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/dryrun.go
preconditions *storage.Preconditions, tryUpdate storage.UpdateFunc, dryRun bool, cachedExistingObject runtime.Object) error { if dryRun { var current runtime.Object v, err := conversion.EnforcePtr(destination) if err != nil { return fmt.Errorf("unable to convert output object to pointer: %v", err) } if u, ok := v.Addr().Interface().(runtime.Unstructured); ok { current = u.NewEmptyInstance() } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 02 20:40:48 UTC 2023 - 3.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
validateDeletion storage.ValidateObjectFunc, cachedExistingObject runtime.Object) error { preparedKey, err := s.prepareKey(key) if err != nil { return err } v, err := conversion.EnforcePtr(out) if err != nil { return fmt.Errorf("unable to convert output object to pointer: %v", err) } return s.conditionalDelete(ctx, preparedKey, out, v, preconditions, validateDeletion, cachedExistingObject) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/scheme.go
} if len(gvk.Version) == 0 { return nil, false, NewMissingVersionErr("unstructured object has no version") } return []schema.GroupVersionKind{gvk}, false, nil } v, err := conversion.EnforcePtr(obj) if err != nil { return nil, false, err } t := v.Type() gvks, ok := s.typeToGVK[t] if !ok { return nil, false, NewNotRegisteredErrForType(s.schemeName, t) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 25.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/meta/meta.go
// api conventions). func TypeAccessor(obj interface{}) (Type, error) { if typed, ok := obj.(runtime.Object); ok { return objectAccessor{typed}, nil } v, err := conversion.EnforcePtr(obj) if err != nil { return nil, err } t := v.Type() if v.Kind() != reflect.Struct { return nil, fmt.Errorf("expected struct, but got %v: %v (%#v)", v.Kind(), t, v.Interface()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 25 16:23:43 UTC 2022 - 16.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
return c.storage.Get(ctx, key, opts, objPtr) } if err := c.ready.wait(ctx); err != nil { return errors.NewServiceUnavailable(err.Error()) } } objVal, err := conversion.EnforcePtr(objPtr) if err != nil { return err } obj, exists, readResourceVersion, err := c.watchCache.WaitUntilFreshAndGet(ctx, getRV, key) if err != nil { return err } if exists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/installer.go
func AddObjectParams(ws *restful.WebService, route *restful.RouteBuilder, obj interface{}, excludedNames ...string) error { sv, err := conversion.EnforcePtr(obj) if err != nil { return err } st := sv.Type() excludedNameSet := sets.NewString(excludedNames...) switch st.Kind() { case reflect.Struct: for i := 0; i < st.NumField(); i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 51.5K bytes - Viewed (0)