- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 199 for newSel (0.1 sec)
-
pkg/controller/disruption/disruption_test.go
informerFactory, }, ps } func fooBar() map[string]string { return map[string]string{"foo": "bar"} } func newSel(labels map[string]string) *metav1.LabelSelector { return &metav1.LabelSelector{MatchLabels: labels} } func newSelFooBar() *metav1.LabelSelector { return newSel(map[string]string{"foo": "bar"}) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0) -
pkg/test/framework/label/labels_test.go
{filter: "", labels: NewSet(Postsubmit), expected: true}, {filter: "", labels: NewSet(Postsubmit, CustomSetup), expected: true}, {filter: "$requires.kube", labels: NewSet(Postsubmit, CustomSetup), err: true}, {filter: "zoo", labels: NewSet(Postsubmit, CustomSetup), expected: true}, {filter: "postsubmit", labels: NewSet(Postsubmit), expected: true}, {filter: "postsubmit", labels: NewSet(CustomSetup), expected: false},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 18 17:08:05 UTC 2021 - 3.2K bytes - Viewed (0) -
pkg/cache/ttlCache_test.go
c := NewTTL(5*time.Minute, 1*time.Minute) benchmarkCacheSet(c, b) } func BenchmarkTTLSetConcurrent(b *testing.B) { c := NewTTL(5*time.Minute, 1*time.Minute) benchmarkCacheSetConcurrent(c, b) } func BenchmarkTTLGetSetConcurrent(b *testing.B) { c := NewTTL(5*time.Minute, 1*time.Minute) benchmarkCacheGetSetConcurrent(c, b) } func BenchmarkTTLSetRemove(b *testing.B) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.5K bytes - Viewed (0) -
src/runtime/slice.go
// // A new backing store is allocated with space for at least newLen elements. // Existing entries [0, oldLen) are copied over to the new backing store. // Added entries [oldLen, newLen) are not initialized by growslice // (although for pointer-containing element types, they are zeroed). They // must be initialized by the caller. // Trailing entries [newLen, newCap) are zeroed. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 12.2K bytes - Viewed (0) -
istioctl/pkg/writer/table/writer_test.go
w := NewStyleWriter(got) w.AddHeader("NAME", "NAMESPACE", "VERSION") w.SetAddRowFunc(func(obj interface{}) Row { o := obj.(testObject) return Row{ Cells: []Cell{ NewCell(o.name), NewCell(o.namespace, color.FgGreen), NewCell(o.version), }, } }) w.AddRow(newTestObject("foo", "bar", "1.0")) w.AddRow(newTestObject("baz", "qux", "2.0")) w.AddRow(newTestObject("qux", "quux", "3")) w.Flush()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Oct 08 04:41:42 UTC 2022 - 1.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/proxy.go
newReq := req.WithContext(newCtx) newReq.Header = utilnet.CloneHeader(req.Header) newReq.URL = location newReq.Host = location.Host // If the original request has an audit ID, let's make sure we propagate this // to the aggregated server. if auditID, found := audit.AuditIDFrom(req.Context()); found { newReq.Header.Set(auditinternal.HeaderAuditID, string(auditID)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 5.6K bytes - Viewed (0) -
src/hash/crc32/crc32_ppc64le.go
if uint64(uintptr(unsafe.Pointer(&p[0])))&uint64(vecAlignMask) != 0 { align := uint64(uintptr(unsafe.Pointer(&p[0]))) & uint64(vecAlignMask) newlen := vecMinLen - align crc = ppc64SlicingUpdateBy8(crc, archCastagnoliTable8, p[:newlen]) p = p[newlen:] } // p should be aligned now aligned := len(p) & ^vecAlignMask crc = vectorCrc32(crc, crcCast, p[:aligned]) p = p[aligned:] } if len(p) == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 18 17:59:44 UTC 2022 - 2.2K bytes - Viewed (0) -
pkg/registry/flowcontrol/flowschema/strategy.go
"flowcontrol.apiserver.k8s.io/v1beta1": fieldpath.NewSet( fieldpath.MakePathOrDie("status"), ), "flowcontrol.apiserver.k8s.io/v1beta2": fieldpath.NewSet( fieldpath.MakePathOrDie("status"), ), "flowcontrol.apiserver.k8s.io/v1beta3": fieldpath.NewSet( fieldpath.MakePathOrDie("status"), ), "flowcontrol.apiserver.k8s.io/v1": fieldpath.NewSet( fieldpath.MakePathOrDie("status"), ), }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 11:48:22 UTC 2023 - 6K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/PopulatedCachesTest.java
warmed.add(entryOf(entry.getKey(), newValue)); Object newKey = new Object(); assertNull(cache.asMap().put(newKey, entry.getValue())); // this getUnchecked() call shouldn't be a cache miss; verified below assertEquals(newValue, cache.getUnchecked(entry.getKey())); assertEquals(entry.getValue(), cache.getUnchecked(newKey)); // don't let the new entry get GCed
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 15K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/stripmeta.go
if ok { if vs == nil { panic(fmt.Sprintf("Found unexpected nil manager which should never happen: %s", manager)) } newSet := vs.Set().Difference(f.stripSet) if newSet.Empty() { delete(managed, manager) } else { managed[manager] = fieldpath.NewVersionedSet(newSet, vs.APIVersion(), vs.Applied()) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 3K bytes - Viewed (0)