- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 311 for Res (0.04 sec)
-
pkg/kube/kclient/client.go
var res []T err := cache.ListAllByNamespace(n.informer.GetIndexer(), namespace, selector, func(i any) { cast := i.(T) if n.applyFilter(cast) { res = append(res, cast) } }) // Should never happen if err != nil && features.EnableUnsafeAssertions { log.Fatalf("lister returned err for %v: %v", namespace, err) } return res }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K bytes - Viewed (0) -
pkg/kube/krt/README.md
Consider a transformation from `Pod` to `SimplePod`: ```go SimplePods := krt.NewSingleton[SimplePod](func(ctx krt.HandlerContext) *[]SimplePod { res := []SimplePod{} for _, pod := range krt.Fetch(ctx, Pod) { res = append(res, SimplePod{Name: pod.Name}) } return &res }) // Results in a Collection[[]SimplePod] ``` While this *works*, it is inefficient and complex to write.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 18 17:21:50 UTC 2023 - 11.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/quantization/import_quant_stats_pass.cc
bool IsQuantizableResult(Operation *op, int index) { if (index < 0 || index >= static_cast<int>(op->getNumResults())) return false; Value res = op->getResult(index); return res.getType().isa<ShapedType>() && res.getType().cast<ShapedType>().getElementType().isa<FloatType>(); } // A method to retrieve the name for the given op. OperationToName op_to_name_;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Mar 08 10:41:08 UTC 2024 - 9.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
default: if wc.acceptAll() { res = &watch.Event{ Type: watch.Modified, Object: curObj, } return res } curObjPasses := wc.filter(curObj) oldObjPasses := wc.filter(oldObj) switch { case curObjPasses && oldObjPasses: res = &watch.Event{ Type: watch.Modified, Object: curObj, } case curObjPasses && !oldObjPasses: res = &watch.Event{ Type: watch.Added,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
// plus we want to return whatever we can to the user. res, err := p.processEntry(p.proc, netnsObserved, desiredUIDs, entry) if err != nil { log.Debugf("error processing entry: %s %v", entry.Name(), err) continue } if res == nil { continue } pod := pods[res.uid] netns := &NetnsWithFd{ netns: res.netns, fd: res.netnsfd, inode: res.inode, } workload := WorkloadInfo{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 21:47:31 UTC 2024 - 11K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/utils.go
}) } func testCheckResultFunc(t *testing.T, w watch.Interface, check func(actualEvent watch.Event)) { select { case res := <-w.ResultChan(): obj := res.Object if co, ok := obj.(runtime.CacheableObject); ok { res.Object = co.GetObject() } check(res) case <-time.After(wait.ForeverTestTimeout): t.Errorf("time out after waiting %v on ResultChan", wait.ForeverTestTimeout) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 22 07:26:55 UTC 2024 - 10.3K bytes - Viewed (1) -
tests/create_test.go
res := DB.FirstOrCreate(&user, "name = ?", user.Name) if res.Error != nil || res.RowsAffected != 1 { t.Fatalf("first or create rows affect err:%v rows:%d", res.Error, res.RowsAffected) } res = DB.FirstOrCreate(&user, "name = ?", user.Name) if res.Error != nil || res.RowsAffected != 0 { t.Fatalf("first or create rows affect err:%v rows:%d", res.Error, res.RowsAffected) } }
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Tue Mar 19 03:50:28 UTC 2024 - 26.4K bytes - Viewed (0) -
src/crypto/internal/nistec/p256_asm_arm64.s
// func p256MovCond(res, a, b *P256Point, cond int) // If cond == 0 res=b, else res=a TEXT ·p256MovCond(SB),NOSPLIT,$0 MOVD res+0(FP), res_ptr MOVD a+8(FP), a_ptr MOVD b+16(FP), b_ptr MOVD cond+24(FP), R3 CMP $0, R3 // Two remarks: // 1) Will want to revisit NEON, when support is better // 2) CSEL might not be constant time on all ARM processors LDP 0*16(a_ptr), (R4, R5)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 17:29:44 UTC 2024 - 29.7K bytes - Viewed (0) -
pkg/dns/client/dns_test.go
currentID.Store(int32(tt.id)) defer func() { currentID.Store(0) }() } res, _, err := clients[i].Exchange(m, addr) if res != nil { t.Log("size: ", len(res.Answer)) } if err != nil { t.Errorf("Failed to resolve query for %s: %v", tt.host, err) } else { for _, answer := range res.Answer { if answer.Header().Class != dns.ClassINET {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 16:17:34 UTC 2024 - 20.4K bytes - Viewed (0) -
src/cmd/compile/internal/types2/assignments.go
func operandTypes(list []*operand) (res []Type) { for _, x := range list { res = append(res, x.typ) } return res } // varTypes returns the list of types for the given variables. func varTypes(list []*Var) (res []Type) { for _, x := range list { res = append(res, x.typ) } return res } // typesSummary returns a string of the form "(t1, t2, ...)" where the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 23 21:21:43 UTC 2024 - 16.4K bytes - Viewed (0)