- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for newRoute (0.12 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)