- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 570 for index (0.06 sec)
-
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) -
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) -
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) -
test/fixedbugs/issue33275_run.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:25 UTC 2023 - 717 bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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)