Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 570 for index (0.06 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/watch_tracker.go

    	}
    
    	w.lock.Lock()
    	defer w.lock.Unlock()
    	w.updateIndexLocked(identifier, index, 1)
    	return w.forgetWatch(identifier, index)
    }
    
    func (w *watchTracker) updateIndexLocked(identifier *watchIdentifier, index *indexValue, incr int) {
    	if index == nil {
    		w.watchCount[*identifier] += incr
    	} else {
    		// For resources with defined index, for a given watch event we are
    		// only processing the watchers that:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Dec 18 04:27:38 UTC 2022
    - 7.4K bytes
    - Viewed (0)
  2. pkg/controller/volume/common/common.go

    	v1 "k8s.io/api/core/v1"
    	"k8s.io/client-go/tools/cache"
    	"k8s.io/component-helpers/storage/ephemeral"
    )
    
    const (
    	// PodPVCIndex is the lookup name for the index function, which is to index by pod pvcs.
    	PodPVCIndex = "pod-pvc-index"
    )
    
    // PodPVCIndexFunc creates an index function that returns PVC keys (=
    // namespace/name) for given pod.  This includes the PVCs
    // that might be created for generic ephemeral volumes.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 11 18:54:20 UTC 2021
    - 2.2K bytes
    - Viewed (0)
  3. staging/src/k8s.io/cli-runtime/pkg/printers/jsonpath.go

    				x = int64(index.Uint())
    			default:
    				return false
    			}
    			if x < 0 || x >= int64(v.Len()) {
    				return false
    			}
    			v = v.Index(int(x))
    		case reflect.Map:
    			if !index.IsValid() {
    				index = reflect.Zero(v.Type().Key())
    			}
    			if !index.Type().AssignableTo(v.Type().Key()) {
    				return false
    			}
    			if x := v.MapIndex(index); x.IsValid() {
    				v = x
    			} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 25 16:23:43 UTC 2022
    - 4.3K bytes
    - Viewed (0)
  4. test/fixedbugs/issue33275_run.go

    import (
    	"os/exec"
    	"strings"
    )
    
    func main() {
    	out, _ := exec.Command("go", "run", "fixedbugs/issue33275.go").CombinedOutput()
    	if strings.Contains(string(out), "index out of range") {
    		panic(`go run issue33275.go reported "index out of range"`)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:25 UTC 2023
    - 717 bytes
    - Viewed (0)
  5. tests/integration/security/util/reachability/context.go

    			E = apps.EchoNamespace.All[index]
    		case namespacedName.Name == HeadlessSvc:
    			Headless = apps.EchoNamespace.All[index]
    		case namespacedName.Name == HeadlessNakedSvc:
    			HeadlessNaked = apps.EchoNamespace.All[index]
    		case namespacedName.Name == ExternalSvc:
    			External = apps.EchoNamespace.All[index]
    		case namespacedName.Name == NakedSvc:
    			Naked = apps.EchoNamespace.All[index]
    		case namespacedName.Name == VMSvc:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Aug 23 21:20:43 UTC 2022
    - 8.6K bytes
    - Viewed (0)
  6. src/internal/pkgbits/encoder.go

    	RelocMap map[RelocEnt]uint32
    	Data     bytes.Buffer // accumulated element bitstream data
    
    	encodingRelocHeader bool
    
    	k   RelocKind
    	Idx Index // index within relocation section
    }
    
    // Flush finalizes the element's bitstream and returns its Index.
    func (w *Encoder) Flush() Index {
    	var sb strings.Builder
    
    	// Backup the data so we write the relocations at the front.
    	var tmp bytes.Buffer
    	io.Copy(&tmp, &w.Data)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Aug 10 23:26:58 UTC 2022
    - 9.6K bytes
    - Viewed (0)
  7. tests/integration/security/filebased_tls_origination/main_test.go

    	for index, namespacedName := range apps.Ns1.All.NamespacedNames() {
    		switch {
    		case namespacedName.Name == "client":
    			client = apps.Ns1.All[index]
    		case namespacedName.Name == "server":
    			server = apps.Ns1.All[index]
    		case namespacedName.Name == "internal-client":
    			internalClient = apps.Ns1.All[index]
    		}
    	}
    	for index, namespacedName := range apps.Ns2.All.NamespacedNames() {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 02 21:29:40 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  8. cmd/gotemplate/gotemplate.go

    func main() {
    	kvs := make(map[string]string)
    
    	for _, keyValue := range os.Args[1:] {
    		index := strings.Index(keyValue, "=")
    		if index <= 0 {
    			fmt.Fprintf(os.Stderr, "optional arguments must be of the form <key>=<value>, got instead: %q\n", keyValue)
    			os.Exit(1)
    		}
    		kvs[keyValue[0:index]] = keyValue[index+1:]
    	}
    
    	if err := generate(os.Stdin, os.Stdout, kvs); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 22 18:39:23 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/cel/common/equality.go

    		Duration: r.Duration,
    	}
    	r.children[field] = res
    	return res
    }
    
    // Index returns the child of the receiver at the given index.
    // Returns nil if the given index is out of bounds, or its value is not
    // correlatable to an old value.
    // If receiver is nil or if the new value is not an array, returns nil.
    func (r *CorrelatedObject) Index(i int) *CorrelatedObject {
    	start := time.Now()
    	defer func() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 25 21:53:21 UTC 2023
    - 9.1K bytes
    - Viewed (0)
  10. pkg/apis/apiserverinternal/validation/validation.go

    		if condition.Reason == "" {
    			allErrs = append(allErrs, field.Required(fldPath.Index(i).Child("reason"), "reason cannot be empty"))
    		}
    		if condition.Message == "" {
    			allErrs = append(allErrs, field.Required(fldPath.Index(i).Child("message"), "message cannot be empty"))
    		}
    	}
    	return allErrs
    }
    
    const dns1035LabelFmt string = "[a-z]([-a-z0-9]*[a-z0-9])?"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 13 21:43:49 UTC 2023
    - 9.1K bytes
    - Viewed (0)
Back to top