Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for WithValue (0.09 sec)

  1. internal/grid/handlers.go

    	if err != nil {
    		return resp, err
    	}
    	switch any(req).(type) {
    	case *MSS, *URLValues:
    		ctx = context.WithValue(ctx, TraceParamsKey{}, req)
    	case *NoPayload, *Bytes:
    		// do not need to trace nopayload and bytes payload
    	default:
    		ctx = context.WithValue(ctx, TraceParamsKey{}, fmt.Sprintf("type=%T", req))
    	}
    	if h.callReuseReq {
    		defer h.recycleReq(req)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  2. cmd/http-tracer.go

    		tc := mcontext.TraceCtxt{
    			AmzReqID:         w.Header().Get(xhttp.AmzRequestID),
    			RequestRecorder:  reqRecorder,
    			ResponseRecorder: respRecorder,
    		}
    
    		r = r.WithContext(context.WithValue(r.Context(), mcontext.ContextTraceKey, &tc))
    
    		reqStartTime := time.Now().UTC()
    		h.ServeHTTP(respRecorder, r)
    		reqEndTime := time.Now().UTC()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. internal/logger/audit.go

    func SetAuditEntry(ctx context.Context, audit *audit.Entry) context.Context {
    	if ctx == nil {
    		LogIf(context.Background(), "audit", fmt.Errorf("context is nil"))
    		return nil
    	}
    	return context.WithValue(ctx, contextAuditKey, audit)
    }
    
    // GetAuditEntry returns Audit entry if set.
    func GetAuditEntry(ctx context.Context) *audit.Entry {
    	if ctx != nil {
    		r, ok := ctx.Value(contextAuditKey).(*audit.Entry)
    		if ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. internal/logger/reqinfo.go

    func SetReqInfo(ctx context.Context, req *ReqInfo) context.Context {
    	if ctx == nil {
    		LogIf(context.Background(), "", fmt.Errorf("context is nil"))
    		return nil
    	}
    	return context.WithValue(ctx, contextLogKey, req)
    }
    
    // GetReqInfo returns ReqInfo if set.
    func GetReqInfo(ctx context.Context) *ReqInfo {
    	if ctx != nil {
    		r, ok := ctx.Value(contextLogKey).(*ReqInfo)
    		if ok {
    			return r
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  5. api/go1.7.txt

    pkg context, func WithCancel(Context) (Context, CancelFunc)
    pkg context, func WithDeadline(Context, time.Time) (Context, CancelFunc)
    pkg context, func WithTimeout(Context, time.Duration) (Context, CancelFunc)
    pkg context, func WithValue(Context, interface{}, interface{}) Context
    pkg context, type CancelFunc func()
    pkg context, type Context interface { Deadline, Done, Err, Value }
    pkg context, type Context interface, Deadline() (time.Time, bool)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Jun 28 15:08:11 UTC 2016
    - 13.6K bytes
    - Viewed (0)
  6. internal/dsync/drwmutex.go

    	// Also, pass the trace context info if found for debugging
    	netLockCtx := context.Background()
    	tc, ok := ctx.Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    	if ok {
    		netLockCtx = context.WithValue(netLockCtx, mcontext.ContextTraceKey, tc)
    	}
    
    	for index, c := range restClnts {
    		wg.Add(1)
    		// broadcast lock request to all nodes
    		go func(index int, isReadLock bool, c NetLocker) {
    			defer wg.Done()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  7. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
Back to top