Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 31 for errorHandler (0.17 sec)

  1. src/net/http/httputil/reverseproxy.go

    	// If the backend is unreachable, the optional ErrorHandler is
    	// called without any call to ModifyResponse.
    	//
    	// If ModifyResponse returns an error, ErrorHandler is called
    	// with its error value. If ErrorHandler is nil, its default
    	// implementation is used.
    	ModifyResponse func(*http.Response) error
    
    	// ErrorHandler is an optional function that handles errors
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 27 23:37:42 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/runtime/runtime_test.go

    		panic("test")
    	}()
    	if result != "test" {
    		t.Errorf("did not receive custom handler")
    	}
    }
    
    func TestCustomHandleError(t *testing.T) {
    	old := ErrorHandlers
    	defer func() { ErrorHandlers = old }()
    	var result error
    	ErrorHandlers = []ErrorHandler{
    		func(_ context.Context, err error, msg string, keysAndValues ...interface{}) {
    			result = err
    		},
    	}
    	err := fmt.Errorf("test")
    	HandleError(err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 16:28:45 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  3. pilot/pkg/xds/debug.go

    	})
    	writeJSON(w, configs, req)
    }
    
    // SidecarScope debugging
    func (s *DiscoveryServer) sidecarz(w http.ResponseWriter, req *http.Request) {
    	proxyID, con := s.getDebugConnection(req)
    	if con == nil {
    		s.errorHandler(w, proxyID, con)
    		return
    	}
    	writeJSON(w, con.proxy.SidecarScope, req)
    }
    
    // Resource debugging.
    func (s *DiscoveryServer) resourcez(w http.ResponseWriter, req *http.Request) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apimachinery/pkg/util/runtime/runtime.go

    	}
    }
    
    // ErrorHandlers is a list of functions which will be invoked when a nonreturnable
    // error occurs.
    // TODO(lavalamp): for testability, this and the below HandleError function
    // should be packaged up into a testable and reusable object.
    var ErrorHandlers = []ErrorHandler{
    	logError,
    	func(_ context.Context, _ error, _ string, _ ...interface{}) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 16:28:45 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  5. subprojects/diagnostics/src/main/java/org/gradle/api/tasks/diagnostics/DependencyInsightReportTask.java

        // a value of `configuration.getAttributes()`.
        // TODO:configuration-cache find a way to clean up this #23732
        private Provider<AttributeContainer> zConfigurationAttributes;
        private ResolutionErrorRenderer errorHandler;
        private String configurationName;
        private String configurationDescription;
    
        /**
         * The root component of the dependency graph to be inspected.
         *
         * @since 7.5
         */
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 23 17:29:40 UTC 2024
    - 32.3K bytes
    - Viewed (0)
  6. src/net/http/httputil/reverseproxy_test.go

    		wantCode       int
    		errorHandler   func(http.ResponseWriter, *http.Request, error)
    		transport      http.RoundTripper // defaults to failingRoundTripper
    		modifyResponse func(*http.Response) error
    	}{
    		{
    			name:     "default",
    			wantCode: http.StatusBadGateway,
    		},
    		{
    			name:         "errorhandler",
    			wantCode:     http.StatusTeapot,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 54.6K bytes
    - Viewed (0)
  7. src/go/scanner/scanner.go

    	"go/token"
    	"path/filepath"
    	"strconv"
    	"unicode"
    	"unicode/utf8"
    )
    
    // An ErrorHandler may be provided to [Scanner.Init]. If a syntax error is
    // encountered and a handler was installed, the handler is called with a
    // position and an error message. The position points to the beginning of
    // the offending token.
    type ErrorHandler func(pos token.Position, msg string)
    
    // A Scanner holds the scanner's internal state while processing
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 12:02:03 UTC 2023
    - 24.3K bytes
    - Viewed (0)
  8. platforms/core-runtime/messaging/src/integTest/groovy/org/gradle/internal/remote/internal/hub/MessageHubIntegrationTest.groovy

    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.LinkedBlockingQueue
    
    @Timeout(60)
    class MessageHubIntegrationTest extends ConcurrentSpec {
        final Action<Throwable> errorHandler = Mock()
    
        def "can wire two hubs together"() {
            Dispatch<String> clientHandler = Mock()
            Dispatch<String> serverHandler = Mock()
            def server = new Participant()
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:59:22 UTC 2023
    - 9K bytes
    - Viewed (0)
  9. src/fmt/scan.go

    			v.SetComplex(s.scanComplex(verb, v.Type().Bits()))
    		default:
    			s.errorString("can't scan type: " + val.Type().String())
    		}
    	}
    }
    
    // errorHandler turns local panics into error returns.
    func errorHandler(errp *error) {
    	if e := recover(); e != nil {
    		if se, ok := e.(scanError); ok { // catch local error
    			*errp = se.err
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 21:56:20 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  10. cmd/handler-utils.go

    	// proxying the request to another node.
    	for k := range w.Header() {
    		w.Header().Del(k)
    	}
    
    	f := handlers.NewForwarder(&handlers.Forwarder{
    		PassHost:     true,
    		RoundTripper: ep.Transport,
    		ErrorHandler: func(w http.ResponseWriter, r *http.Request, err error) {
    			success = false
    			if err != nil && !errors.Is(err, context.Canceled) {
    				replLogIf(GlobalContext, err)
    			}
    		},
    	})
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
Back to top