- Sort Score
- Result 10 results
- Languages All
Results 11 - 18 of 18 for withValues (0.25 sec)
-
cmd/admin-handlers-config-kv.go
if err != nil { return } tgts, err := config.ParseConfigTargetID(bytes.NewReader(kvBytes)) if err != nil { return } ctx = context.WithValue(ctx, config.ContextKeyForTargetFromConfig, tgts) if verr := validateConfig(ctx, result.Cfg, result.SubSys); verr != nil { err = badConfigErr{Err: verr} return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.7K bytes - Viewed (0) -
src/crypto/tls/quic_test.go
t.Fatalf("error during connection handshake: %v", err) } } func TestQUICStartContextPropagation(t *testing.T) { const key = "key" const value = "value" ctx := context.WithValue(context.Background(), key, value) config := testConfig.Clone() config.MinVersion = VersionTLS13 calls := 0 config.GetConfigForClient = func(info *ClientHelloInfo) (*Config, error) { calls++
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:23:54 UTC 2024 - 19.3K bytes - Viewed (0) -
src/cmd/go/internal/cfg/cfg.go
return "" } // WithBuildXWriter returns a Context in which BuildX output is written // to given io.Writer. func WithBuildXWriter(ctx context.Context, xLog io.Writer) context.Context { return context.WithValue(ctx, buildXContextKey{}, xLog) } type buildXContextKey struct{} // BuildXWriter returns nil if BuildX is false, or // the writer to which BuildX output should be written otherwise.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 24 17:13:51 UTC 2024 - 19.3K bytes - Viewed (0) -
src/net/lookup_test.go
keyValues := []struct { key, value any }{ {"key-1", 12}, {384, "value2"}, {new(float64), 137}, } ctx := context.Background() for _, kv := range keyValues { ctx = context.WithValue(ctx, kv.key, kv.value) } wantIPs := []IPAddr{ {IP: IPv4(127, 0, 0, 1)}, {IP: IPv6loopback}, }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 41.4K bytes - Viewed (0) -
src/log/slog/logger_test.go
{l.ErrorContext, LevelError}, {DebugContext, LevelDebug}, {InfoContext, LevelInfo}, {WarnContext, LevelWarn}, {ErrorContext, LevelError}, } { h.clear() ctx := context.WithValue(context.Background(), "L", test.wantLevel) test.f(ctx, "msg") if gv := h.ctx.Value("L"); gv != test.wantLevel || h.r.Level != test.wantLevel {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 10 21:25:30 UTC 2023 - 19.5K bytes - Viewed (0) -
src/net/dial.go
resolveCtx := ctx if trace, _ := ctx.Value(nettrace.TraceKey{}).(*nettrace.Trace); trace != nil { shadow := *trace shadow.ConnectStart = nil shadow.ConnectDone = nil resolveCtx = context.WithValue(resolveCtx, nettrace.TraceKey{}, &shadow) } addrs, err := d.resolver().resolveAddrList(resolveCtx, "dial", network, address, d.LocalAddr) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 26.9K bytes - Viewed (0) -
src/net/dial_test.go
id = ctx.Value("id").(int) return controlOnConnSetup(network, address, c) }} c, err := d.DialContext(context.WithValue(context.Background(), "id", i+1), network, ln.Addr().String()) if err != nil { t.Fatal(err) } if id != i+1 { t.Errorf("got id %d, want %d", id, i+1) } c.Close() })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 30.3K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
return ctx, done, nil } if contextCanceled(ctx) { return ctx, done, ctx.Err() } atomic.StoreInt64(&p.health.lastStarted, time.Now().UnixNano()) p.health.waiting.Add(1) ctx = context.WithValue(ctx, healthDiskCtxKey{}, &healthDiskCtxValue{lastSuccess: &p.health.lastSuccess}) si := p.updateStorageMetrics(s, paths...) var once sync.Once return ctx, func(sz int64, errp *error) { p.health.waiting.Add(-1)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.4K bytes - Viewed (0)