Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for EnforcePtr (0.16 sec)

  1. 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)
  2. staging/src/k8s.io/apimachinery/pkg/conversion/helper_test.go

    func TestInvalidPtrValueKind(t *testing.T) {
    	var simple interface{}
    	switch obj := simple.(type) {
    	default:
    		_, err := EnforcePtr(obj)
    		if err == nil {
    			t.Errorf("Expected error on invalid kind")
    		}
    	}
    }
    
    func TestEnforceNilPtr(t *testing.T) {
    	var nilPtr *struct{}
    	_, err := EnforcePtr(nilPtr)
    	if err == nil {
    		t.Errorf("Expected error on nil pointer")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 11 14:09:48 UTC 2017
    - 978 bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top