Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for VersionedParams (0.17 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1/customresourcedefinition.go

    	result = &v1.CustomResourceDefinition{}
    	err = c.client.Get().
    		Resource("customresourcedefinitions").
    		Name(name).
    		VersionedParams(&options, scheme.ParameterCodec).
    		Do(ctx).
    		Into(result)
    	return
    }
    
    // List takes label and field selectors, and returns the list of CustomResourceDefinitions that match those selectors.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 10:52:54 UTC 2024
    - 12K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1beta1/customresourcedefinition.go

    	result = &v1beta1.CustomResourceDefinition{}
    	err = c.client.Get().
    		Resource("customresourcedefinitions").
    		Name(name).
    		VersionedParams(&options, scheme.ParameterCodec).
    		Do(ctx).
    		Into(result)
    	return
    }
    
    // List takes label and field selectors, and returns the list of CustomResourceDefinitions that match those selectors.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 10:52:54 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  3. staging/src/k8s.io/cli-runtime/pkg/resource/helper.go

    		Resource(m.Resource).
    		VersionedParams(options, metav1.ParameterCodec).
    		Watch(context.TODO())
    }
    
    func (m *Helper) WatchSingle(namespace, name, resourceVersion string) (watch.Interface, error) {
    	return m.RESTClient.Get().
    		NamespaceIfScoped(namespace, m.NamespaceScoped).
    		Resource(m.Resource).
    		VersionedParams(&metav1.ListOptions{
    			ResourceVersion: resourceVersion,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 26 03:45:13 UTC 2022
    - 10.5K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/admission/plugin/cel/filter.go

    	if err != nil {
    		return nil, -1, err
    	}
    	var paramsVal, authorizerVal, requestResourceAuthorizerVal any
    	if inputs.VersionedParams != nil {
    		paramsVal, err = objectToResolveVal(inputs.VersionedParams)
    		if err != nil {
    			return nil, -1, err
    		}
    	}
    
    	if inputs.Authorizer != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 24 14:46:11 UTC 2023
    - 12.1K bytes
    - Viewed (0)
  5. operator/pkg/verifier/verifier.go

    		}
    		switch kind {
    		case "Deployment":
    			deployment := &appsv1.Deployment{}
    			err = info.Client.
    				Get().
    				Resource(kinds).
    				Namespace(namespace).
    				Name(name).
    				VersionedParams(&metav1.GetOptions{}, scheme.ParameterCodec).
    				Do(context.TODO()).
    				Into(deployment)
    			if err != nil {
    				v.reportFailure(kind, name, namespace, err)
    				return err
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 19:23:44 UTC 2024
    - 15K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiextensions-apiserver/test/integration/table_test.go

    				Resource(crd.Spec.Names.Plural).
    				SetHeader("Accept", fmt.Sprintf("application/json;as=Table;v=%s;g=%s, application/json", metav1beta1.SchemeGroupVersion.Version, metav1beta1.GroupName)).
    				VersionedParams(&metav1beta1.TableOptions{}, parameterCodec).
    				Do(context.TODO()).
    				Get()
    			if err != nil {
    				t.Fatalf("failed to list %v resources: %v", gvk, err)
    			}
    
    			tbl, ok := ret.(*metav1beta1.Table)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 02 19:34:41 UTC 2021
    - 18.9K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/webhook/webhook.go

    	result = &authenticationv1.TokenReview{}
    
    	restResult := c.client.Post().
    		Resource("tokenreviews").
    		VersionedParams(&opts, scheme.ParameterCodec).
    		Body(tokenReview).
    		Do(ctx)
    
    	restResult.StatusCode(&statusCode)
    	err = restResult.Into(result)
    	return
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 18 00:47:42 UTC 2022
    - 11.5K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/admission/plugin/cel/filter_test.go

    			if err != nil {
    				t.Fatalf("unexpected error on conversion: %v", err)
    			}
    
    			optionalVars := OptionalVariableBindings{VersionedParams: tc.params, Authorizer: tc.authorizer}
    			ctx := context.TODO()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 40.4K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/validator_test.go

    var _ matchconditions.Matcher = &fakeCELMatcher{}
    
    type fakeCELMatcher struct {
    	error   error
    	matches bool
    }
    
    func (f *fakeCELMatcher) Match(ctx context.Context, versionedAttr *admission.VersionedAttributes, versionedParams runtime.Object, authz authorizer.Authorizer) matchconditions.MatchResult {
    	return matchconditions.MatchResult{Matches: f.matches, FailedConditionName: "placeholder", Error: f.error}
    }
    
    func TestValidate(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/webhook.go

    	result = &authorizationv1.SubjectAccessReview{}
    
    	restResult := t.client.Post().
    		Resource("subjectaccessreviews").
    		VersionedParams(&opts, scheme.ParameterCodec).
    		Body(subjectAccessReview).
    		Do(ctx)
    
    	restResult.StatusCode(&statusCode)
    	err = restResult.Into(result)
    	return
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 19:01:15 UTC 2024
    - 18.4K bytes
    - Viewed (0)
Back to top