Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 68 for triage (0.14 sec)

  1. internal/grid/trace.go

    	v := ctx.Value(TraceParamsKey{})
    	// Should match SingleHandler.Call checks.
    	switch typed := v.(type) {
    	case *MSS:
    		trace.Path += typed.ToQuery()
    	case map[string]string:
    		m := MSS(typed)
    		trace.Path += m.ToQuery()
    	case *URLValues:
    		trace.Path += typed.Values().Encode()
    	case *NoPayload, *Bytes:
    		trace.Path = fmt.Sprintf("%s?payload=%T", trace.Path, typed)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 02 22:54:54 GMT 2024
    - 4K bytes
    - Viewed (0)
  2. internal/http/listener.go

    	}
    
    	for i, serverAddr := range serverAddrs {
    		l, e := listenCfg.Listen(ctx, "tcp", serverAddr)
    		if e != nil {
    			if opts.Trace != nil {
    				opts.Trace(fmt.Sprint("listenCfg.Listen: ", e))
    			}
    
    			listenErrs[i] = e
    			continue
    		}
    
    		if opts.Trace != nil {
    			opts.Trace(fmt.Sprint("adding listener to ", l.Addr()))
    		}
    
    		listeners = append(listeners, l)
    	}
    
    	if len(listeners) == 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  3. tests/tracer_test.go

    	S.Logger.Warn(ctx, s, i...)
    }
    
    func (S Tracer) Error(ctx context.Context, s string, i ...interface{}) {
    	S.Logger.Error(ctx, s, i...)
    }
    
    func (S Tracer) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error) {
    	S.Logger.Trace(ctx, begin, fc, err)
    	S.Test(ctx, begin, fc, err)
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Tue Oct 18 09:28:06 GMT 2022
    - 830 bytes
    - Viewed (0)
  4. cmd/leak-detect_test.go

    	}
    	for _, g := range pickRelevantGoroutines() {
    		snapshot.relevantRoutines[g] = true
    	}
    	return snapshot
    }
    
    // CompareCurrentSnapshot - Compares the initial relevant stack trace with the current one (during the time of invocation).
    func (initialSnapShot LeakDetect) CompareCurrentSnapshot() []string {
    	var stackDiff []string
    	for _, g := range pickRelevantGoroutines() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.2K bytes
    - Viewed (0)
  5. cmd/http-tracer.go

    	op = strings.Replace(op, "ReadinessCheckHandler", "health.Readiness", 1)
    	op = strings.Replace(op, "-fm", "", 1)
    	return op
    }
    
    // If trace is enabled, execute the request if it is traced by other handlers
    // otherwise, generate a trace event with request information but no response.
    func httpTracerMiddleware(h http.Handler) http.Handler {
    	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 5.9K bytes
    - Viewed (0)
  6. istioctl/pkg/admin/istiodconfig_test.go

    	switch request.Method {
    	case http.MethodGet:
    		_, _ = writer.Write([]byte(getResponse))
    	}
    }
    
    func adsHandler(writer http.ResponseWriter, request *http.Request) {
    	const getResponse = `{"name":"ads","description":"ads debugging","output_level":"info","stack_trace_level":"none","log_callers":false}`
    
    	switch request.Method {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Jun 15 15:02:17 GMT 2023
    - 6.2K bytes
    - Viewed (0)
  7. internal/grid/connection.go

    func (c *Connection) Subroute(s string) *Subroute {
    	if c == nil {
    		return nil
    	}
    	return &Subroute{
    		Connection: c,
    		route:      s,
    		subID:      makeSubHandlerID(0, s),
    		trace:      c.trace.subroute(s),
    	}
    }
    
    // Subroute adds a subroute to the subroute.
    // The subroutes are combined with '/'.
    func (c *Subroute) Subroute(s string) *Subroute {
    	route := strings.Join([]string{c.route, s}, "/")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  8. cmd/peer-rest-client.go

    			default:
    				// There was error in the REST request, retry after sometime as probably the peer is down.
    				time.Sleep(5 * time.Second)
    			}
    		}
    	}()
    }
    
    // Trace - send http trace request to peer nodes
    func (client *peerRESTClient) Trace(ctx context.Context, traceCh chan<- []byte, traceOpts madmin.ServiceTraceOpts) {
    	go func() {
    		for {
    			// Blocks until context is canceled or an error occurs.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  9. src/bufio/example_test.go

    			return 0, nil, nil
    		}
    		// There is one final token to be delivered, which may be the empty string.
    		// Returning bufio.ErrFinalToken here tells Scan there are no more tokens after this
    		// but does not trigger an error to be returned from Scan itself.
    		return 0, data, bufio.ErrFinalToken
    	}
    	scanner.Split(onComma)
    	// Scan.
    	for scanner.Scan() {
    		fmt.Printf("%q ", scanner.Text())
    	}
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Oct 23 09:06:30 GMT 2023
    - 4.9K bytes
    - Viewed (0)
  10. cmd/admin-router.go

    		adminRouter.Methods(http.MethodPost).Path(adminVersion + adminAPIClientDevExtraTime).HandlerFunc(adminMiddleware(adminAPI.ClientDevNullExtraTime, noGZFlag))
    
    		// HTTP Trace
    		adminRouter.Methods(http.MethodGet).Path(adminVersion + "/trace").HandlerFunc(adminMiddleware(adminAPI.TraceHandler, noObjLayerFlag))
    
    		// Console Logs
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 25.5K bytes
    - Viewed (0)
Back to top