- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 357 for Res (0.02 sec)
-
platforms/core-execution/build-cache-http/src/integTest/groovy/org/gradle/caching/http/internal/HttpBuildCacheServiceIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 22 23:08:20 UTC 2024 - 15.8K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
res := sets.New(existing...) res.InsertAll(request.ResourceNamesSubscribe...) // This is set by Envoy on first request on reconnection so that we are aware of what Envoy knows // and can continue the xDS session properly. for k := range request.InitialResourceVersions { res.Insert(k) } res.DeleteAll(request.ResourceNamesUnsubscribe...) wildcard := false
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller.go
if !features.EnableAmbient { return nil } var res []model.ServiceInfo for _, p := range c.GetRegistries() { res = append(res, p.ServicesForWaypoint(key)...) } return res } func (c *Controller) WorkloadsForWaypoint(key model.WaypointKey) []model.WorkloadInfo { if !features.EnableAmbientWaypoints { return nil } var res []model.WorkloadInfo for _, p := range c.GetRegistries() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
internal/hash/checksum.go
duplicates = res != nil res = NewChecksumWithType(ChecksumSHA256|ChecksumTrailing, "") case strings.EqualFold(header, ChecksumSHA1.Key()): duplicates = res != nil res = NewChecksumWithType(ChecksumSHA1|ChecksumTrailing, "") } if duplicates { return nil, ErrInvalidChecksum } } if res != nil { return res, nil } } t, s := getContentChecksum(h)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 08 16:18:34 UTC 2024 - 12.6K bytes - Viewed (0) -
tests/scan_test.go
} DB.Table("users").Select("id, name, age").Where("id = ?", user2.ID).Scan(&res) if res.ID != user2.ID || res.Name != user2.Name || res.Age != int(user2.Age) { t.Fatalf("Scan into struct should work, got %#v, should %#v", res, user2) } DB.Model(&User{Model: gorm.Model{ID: user3.ID}}).Select("id, name, age").Scan(&res)
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed Jun 12 10:57:36 UTC 2024 - 10.9K bytes - Viewed (0) -
src/net/cgo_unix.go
if ctx.Done() == nil { defer releaseThread() return blocking() } type result struct { res T err error } res := make(chan result, 1) go func() { defer releaseThread() var r result r.res, r.err = blocking() res <- r }() select { case r := <-res: return r.res, r.err case <-ctx.Done(): var zero T return zero, &DNSError{ Name: lookupName,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 11.4K bytes - Viewed (0) -
src/encoding/base32/base32_test.go
if n > 0 { res = append(res, dbuf[:n]...) } } testEqual(t, "Decoding of %q = %q, want %q", string(input), string(res), tc.res) testEqual(t, "Decoding of %q err = %v, expected %v", string(input), err, tc.err) } } // TestDecoderError verifies decode errors are propagated when there are no read // errors. func TestDecoderError(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 16:25:54 UTC 2024 - 26K bytes - Viewed (0) -
src/runtime/type.go
if base >= md.types && base < md.etypes { res := md.types + uintptr(off) if res > md.etypes { println("runtime: nameOff", hex(off), "out of range", hex(md.types), "-", hex(md.etypes)) throw("runtime: name offset out of range") } return name{Bytes: (*byte)(unsafe.Pointer(res))} } } // No module found. see if it is a run time name. reflectOffsLock() res, found := reflectOffs.m[int32(off)]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:17:26 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go
} // 3. Service if svc := a.lookupService(key); svc != nil { res := []model.AddressInfo{serviceToAddressInfo(svc.Service)} for _, w := range a.workloads.ByServiceKey.Lookup(svc.ResourceName()) { res = append(res, workloadToAddressInfo(w.Workload)) } return res } return nil } func (a *index) lookupService(key string) *model.ServiceInfo {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 19 17:19:41 UTC 2024 - 15.8K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy.go
return } removeHopByHopHeaders(res.Header) if !p.modifyResponse(rw, res, outreq) { return } copyHeader(rw.Header(), res.Header) // The "Trailer" header isn't included in the Transport's response, // at least for *http.Transport. Build it up from Trailer. announcedTrailers := len(res.Trailer) if announcedTrailers > 0 { trailerKeys := make([]string, 0, len(res.Trailer))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 27 23:37:42 UTC 2024 - 24.9K bytes - Viewed (0)