Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for WatchList (0.24 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/example.go

    	if watchListOptions, hasWatchListOptionsPrepared, watchListOptionsErr := watchlist.PrepareWatchListOptionsFromListOptions(opts); watchListOptionsErr != nil {
    		klog.Warningf("Failed preparing watchlist options for examples, falling back to the standard LIST semantics, err = %v", watchListOptionsErr)
    	} else if hasWatchListOptionsPrepared {
    		result, err := c.watchList(ctx, watchListOptions)
    		if err == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 10:52:54 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/apis/meta/internalversion/validation/validation_test.go

    	}, {
    		name: "watch-sendInitialEvents-no-watchlist-fg-disabled",
    		opts: internalversion.ListOptions{
    			Watch:                true,
    			SendInitialEvents:    boolPtrFn(true),
    			ResourceVersionMatch: metav1.ResourceVersionMatchNotOlderThan,
    			AllowWatchBookmarks:  true,
    		},
    		expectErrors: []string{"sendInitialEvents: Forbidden: sendInitialEvents is forbidden for watch unless the WatchList feature gate is enabled"},
    	}, {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 02 07:48:42 UTC 2023
    - 7.6K 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/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)
  5. 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)
  6. src/regexp/syntax/compile.go

    // head == 0 denotes the empty list, okay because we start every program
    // with a fail instruction, so we'll never want to point at its output link.
    type patchList struct {
    	head, tail uint32
    }
    
    func makePatchList(n uint32) patchList {
    	return patchList{n, n}
    }
    
    func (l patchList) patch(p *Prog, val uint32) {
    	head := l.head
    	for head != 0 {
    		i := &p.Inst[head>>1]
    		if head&1 == 0 {
    			head = i.Out
    			i.Out = val
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 13 14:52:20 UTC 2021
    - 6.8K bytes
    - Viewed (0)
  7. test/abi/zombie_struct_select.go

    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    package main
    
    type patchlist struct {
    	head, tail uint32
    }
    
    type frag struct {
    	i   uint32
    	out patchlist
    }
    
    //go:noinline
    //go:registerparams
    func patch(l patchlist, i uint32) {
    }
    
    //go:noinline
    //go:registerparams
    func badbad(f1, f2 frag) frag {
    	// concat of failure is failure
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 02 17:58:59 UTC 2021
    - 676 bytes
    - Viewed (0)
  8. test/fixedbugs/issue4847.go

    // Issue 4847: initialization cycle is not detected.
    
    package p
    
    type (
    	E int
    	S int
    )
    
    type matcher func(s *S) E
    
    func matchList(s *S) E { return matcher(matchAnyFn)(s) }
    
    var foo = matcher(matchList)
    
    var matchAny = matcher(matchList) // ERROR "initialization cycle|depends upon itself"
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Sep 23 20:27:09 UTC 2022
    - 519 bytes
    - Viewed (0)
  9. src/internal/types/testdata/check/init1.go

    func f6() { _ = y6 }
    
    // full test case
    
    type (
          E int
          S int
    )
    
    type matcher func(s *S) E
    
    func matchList(s *S) E { return matcher(matchAnyFn)(s) }
    
    var foo = matcher(matchList)
    
    var matchAny /* ERROR "initialization cycle" */ = matcher(matchList)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jan 17 19:54:25 UTC 2023
    - 1.5K bytes
    - Viewed (0)
Back to top