Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 71 for matchList (0.19 sec)

  1. staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics_test.go

    			initialVerb:   "LIST",
    			suggestedVerb: "WATCHLIST",
    			request: &http.Request{
    				Method: "GET",
    				URL: &url.URL{
    					RawQuery: "/api/v1/watch/pods",
    				},
    			},
    			expectedVerb: "WATCH",
    		},
    		{
    			desc:         "WATCHLIST should be transformed to WATCH",
    			initialVerb:  "WATCHLIST",
    			request:      nil,
    			expectedVerb: "WATCH",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 07:29:19 UTC 2023
    - 14.3K bytes
    - Viewed (0)
  2. security/pkg/pki/util/verify_cert.go

    		}
    	}
    	if strings.HasPrefix(host, "spiffe") {
    		matchHost := false
    		ids, err := ExtractIDs(cert.Extensions)
    		if err != nil {
    			return err
    		}
    		for _, id := range ids {
    			if strings.HasSuffix(id, host) {
    				matchHost = true
    				break
    			}
    		}
    		if !matchHost {
    			return fmt.Errorf("the certificate doesn't have the expected SAN for: %s", host)
    		}
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Sep 05 10:37:29 UTC 2022
    - 5.9K bytes
    - Viewed (0)
  3. api/openapi-spec/README.md

    are associated with a [kubernetes resource](https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources).
    Action can be one of `get`, `list`, `put`, `patch`, `post`, `delete`, `deletecollection`, `watch`, `watchlist`, `proxy`, or `connect`.
    
    
    For example:
    
    ``` json
    "paths": {
        ...
        "/api/v1/namespaces/{namespace}/pods/{name}": {
            ...
            "get": {
            ...
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 15 01:29:23 UTC 2022
    - 1.7K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apimachinery/pkg/util/strategicpatch/patch.go

    	if err != nil {
    		return nil, nil, nil, err
    	}
    
    	var patchList, deleteList, setOrderList []interface{}
    	kind := elementType.Kind()
    	switch kind {
    	case reflect.Map:
    		patchList, deleteList, err = diffListsOfMaps(original, modified, schema, mergeKey, diffOptions)
    		if err != nil {
    			return nil, nil, nil, err
    		}
    		patchList, err = normalizeSliceOrder(patchList, modified, mergeKey, kind)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 23:34:23 UTC 2023
    - 75.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/apis/meta/internalversion/validation/validation.go

    		}
    		if !isWatchListFeatureEnabled {
    			allErrs = append(allErrs, field.Forbidden(field.NewPath("sendInitialEvents"), "sendInitialEvents is forbidden for watch unless the WatchList feature gate is enabled"))
    		}
    	}
    	if len(match) > 0 {
    		if options.SendInitialEvents == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 01 09:55:40 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/features/kube_features.go

    	InPlacePodVerticalScaling featuregate.Feature = "InPlacePodVerticalScaling"
    
    	// owner: @p0lyn0mial
    	// alpha: v1.27
    	//
    	// Allow the API server to stream individual items instead of chunking
    	WatchList featuregate.Feature = "WatchList"
    
    	// owner: @serathius
    	// kep: http://kep.k8s.io/2340
    	// alpha: v1.28
    	//
    	// Allow the API server to serve consistent lists from cache
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:36:46 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/get.go

    			scope.err(err, w, req)
    			return
    		}
    
    		metainternalversion.SetListOptionsDefaults(&opts, utilfeature.DefaultFeatureGate.Enabled(features.WatchList))
    		if errs := metainternalversionvalidation.ValidateListOptions(&opts, utilfeature.DefaultFeatureGate.Enabled(features.WatchList)); len(errs) > 0 {
    			err := errors.NewInvalid(schema.GroupKind{Group: metav1.GroupName, Kind: "ListOptions"}, "", errs)
    			scope.err(err, w, req)
    			return
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 10:22:16 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go

    		},
    	}
    	for _, scenario := range scenarios {
    		t.Run(scenario.name, func(t *testing.T) {
    			if scenario.enableWatchList {
    				featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.WatchList, true)
    			}
    			origCtx, store, _ := testSetup(t, scenario.setupFn)
    			ctx, cancel := context.WithCancel(origCtx)
    			defer cancel()
    
    			w, err := store.watcher.Watch(ctx, "/abc", 0, scenario.requestOpts)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 12.3K bytes
    - Viewed (1)
  9. staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics.go

    	reportedVerb := verb
    	if suggestedVerb := getVerbIfWatch(request); suggestedVerb == "WATCH" {
    		reportedVerb = "WATCH"
    	}
    	// normalize the legacy WATCHLIST to WATCH to ensure users aren't surprised by metrics
    	if verb == "WATCHLIST" {
    		reportedVerb = "WATCH"
    	}
    	if verb == "PATCH" && request.Header.Get("Content-Type") == string(types.ApplyPatchType) {
    		reportedVerb = "APPLY"
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 07:29:19 UTC 2023
    - 35K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/width.go

    		// during its initialization (sending init events), its cost should then
    		// be computed the same way as for a regular list.
    		if utilfeature.DefaultFeatureGate.Enabled(features.WatchList) {
    			return e.listWorkEstimator.EstimateWork(r, flowSchemaName, priorityLevelName)
    		}
    	case "create", "update", "patch", "delete":
    		return e.mutatingWorkEstimator.EstimateWork(r, flowSchemaName, priorityLevelName)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 17 19:26:52 UTC 2023
    - 5K bytes
    - Viewed (0)
Back to top