Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for newRoute (0.12 sec)

  1. cmd/metrics-router.go

    	prometheusPublic prometheusAuthType = "public"
    )
    
    // registerMetricsRouter - add handler functions for metrics.
    func registerMetricsRouter(router *mux.Router) {
    	// metrics router
    	metricsRouter := router.NewRoute().PathPrefix(minioReservedBucketPath).Subrouter()
    	authType := prometheusAuthType(strings.ToLower(env.Get(EnvPrometheusAuthType, string(prometheusJWT))))
    
    	auth := AuthMiddleware
    	if authType == prometheusPublic {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/authenticator/JavaNetAuthenticatorTest.kt

      fun tearDown() {
        Authenticator.setDefault(null)
        factory.close()
      }
    
      @Test
      fun testBasicAuth() {
        fakeDns["server"] = listOf(InetAddress.getLocalHost())
    
        val route = factory.newRoute()
    
        val request =
          Request.Builder()
            .url("https://server/robots.txt")
            .build()
        val response =
          Response.Builder()
            .request(request)
            .code(401)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt

      private val addressA = factory.newAddress("a")
      private val routeA1 = factory.newRoute(addressA)
      private val addressB = factory.newAddress("b")
      private val routeB1 = factory.newRoute(addressB)
      private val addressC = factory.newAddress("c")
      private val routeC1 = factory.newRoute(addressC)
    
      @AfterEach fun tearDown() {
        factory.close()
        peer.close()
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jun 22 16:06:35 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/connection/RetryConnectionTest.kt

        val sslV3 =
          ConnectionSpec.Builder(ConnectionSpec.MODERN_TLS)
            .tlsVersions(TlsVersion.SSL_3_0)
            .build()
        val routePlanner = factory.newRoutePlanner(client)
        val route = factory.newRoute()
        val connectionSpecs = listOf(ConnectionSpec.MODERN_TLS, ConnectionSpec.COMPATIBLE_TLS, sslV3)
        val enabledSocketTlsVersions =
          arrayOf(
            TlsVersion.TLS_1_2,
            TlsVersion.TLS_1_1,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt

        var planningThrowable: Throwable? = null
        var canceled = false
        var connectState = ConnectState.READY
        val connection =
          factory.newConnection(
            pool = pool,
            route = factory.newRoute(address),
            idleAtNanos = defaultConnectionIdleAtNanos,
          )
        var retry: FakePlan? = null
        var retryTaken = false
        var yieldBeforePlanReturns = false
    
        override val isReady: Boolean
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 24 04:40:49 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  6. okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt

          proxyAuthenticator = proxyAuthenticator,
          proxy = proxy,
          protocols = protocols,
          connectionSpecs = connectionSpecs,
          proxySelector = proxySelector,
        )
      }
    
      fun newRoute(
        address: Address = newAddress(),
        proxy: Proxy = this.proxy,
        socketAddress: InetSocketAddress = InetSocketAddress.createUnresolved(uriHost, uriPort),
      ): Route {
        return Route(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/KotlinDeprecationErrorTest.kt

        val sentRequestAtMillis: Long = response.sentRequestAtMillis()
        val receivedResponseAtMillis: Long = response.receivedResponseAtMillis()
      }
    
      @Test @Disabled
      fun route() {
        val route: Route = factory.newRoute()
        val address: Address = route.address()
        val proxy: Proxy = route.proxy()
        val inetSocketAddress: InetSocketAddress = route.socketAddress()
      }
    
      @Test @Disabled
      fun tlsVersion() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt

      }
    
      @Test
      fun javaNetAuthenticator() {
        val authenticator = JavaNetAuthenticator()
        val response = Response.Builder().build()
        var request: Request? = authenticator.authenticate(factory.newRoute(), response)
        request = authenticator.authenticate(null, response)
      }
    
      @Test
      fun javaNetCookieJar() {
        val cookieJar: JavaNetCookieJar = JavaNetCookieJar(newCookieHandler())
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 46.5K bytes
    - Viewed (0)
  9. cmd/sts-handlers.go

    // registerSTSRouter - registers AWS STS compatible APIs.
    func registerSTSRouter(router *mux.Router) {
    	// Initialize STS.
    	sts := &stsAPIHandlers{}
    
    	// STS Router
    	stsRouter := router.NewRoute().PathPrefix(SlashSeparator).Subrouter()
    
    	// Assume roles with no JWT, handles AssumeRole.
    	stsRouter.Methods(http.MethodPost).MatcherFunc(func(r *http.Request, rm *mux.RouteMatch) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 33.9K bytes
    - Viewed (0)
  10. cmd/routers.go

    func configureServerHandler(endpointServerPools EndpointServerPools) (http.Handler, error) {
    	// Initialize router. `SkipClean(true)` stops minio/mux from
    	// normalizing URL path minio/minio#3256
    	router := mux.NewRouter().SkipClean(true).UseEncodedPath()
    
    	// Initialize distributed NS lock.
    	if globalIsDistErasure {
    		registerDistErasureRouters(router, endpointServerPools)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.9K bytes
    - Viewed (0)
Back to top