- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 389 for Routes (0.52 sec)
-
okhttp/src/test/java/okhttp3/internal/connection/RouteSelectorTest.kt
val selection = routeSelector.next() dns.assertRequests(uriHost) val routes = selection.routes assertRoute(routes[0], address, Proxy.NO_PROXY, dns.lookup(uriHost, 0), uriPort) assertRoute(routes[1], address, Proxy.NO_PROXY, dns.lookup(uriHost, 1), uriPort) assertThat(selection.next()).isSameAs(routes[0]) assertThat(selection.next()).isSameAs(routes[1]) assertThat(selection.hasNext()).isFalse()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 20.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
/** Returns a plan for the first attempt at [route]. This throws if no plan is possible. */ @Throws(IOException::class) internal fun planConnectToRoute( route: Route, routes: List<Route>? = null, ): ConnectPlan { if (route.address.sslSocketFactory == null) { if (ConnectionSpec.CLEARTEXT !in route.address.connectionSpecs) { throw UnknownServiceException("CLEARTEXT communication not enabled for client")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 12K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/testdata/routes/empty-gateway/configdump.json
"configs": [ { "@type": "type.googleapis.com/envoy.admin.v3.RoutesConfigDump", "static_route_configs": [ { "route_config": { "@type": "type.googleapis.com/envoy.config.route.v3.RouteConfiguration", "virtual_hosts": [ { "name": "backend", "domains": [ "*" ], "routes": [ { "match": { "prefix": "/healthz/ready" },
Json - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 1.1K bytes - Viewed (0) -
cni/pkg/repair/netns.go
func getLinkWithDestinationOf(ip string) (netlink.Link, error) { routes, err := netlink.RouteListFiltered( netlink.FAMILY_V4, &netlink.Route{Dst: &net.IPNet{IP: net.ParseIP(ip), Mask: net.CIDRMask(32, 32)}}, netlink.RT_FILTER_DST) if err != nil { return nil, err } if len(routes) == 0 { return nil, fmt.Errorf("no routes found for %s", ip) } linkIndex := routes[0].LinkIndex return netlink.LinkByIndex(linkIndex) }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 4.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
http2Connection.start() } /** * Returns true if this connection can carry a stream allocation to `address`. If non-null * `route` is the resolved route for a connection. */ internal fun isEligible( address: Address, routes: List<Route>?, ): Boolean { lock.assertHeld() // If this connection is not accepting new exchanges, we're done.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
cmd/kms-router.go
kmsAPIVersion = "v1" kmsAPIVersionPrefix = SlashSeparator + kmsAPIVersion ) type kmsAPIHandlers struct{} // registerKMSRouter - Registers KMS APIs func registerKMSRouter(router *mux.Router) { kmsAPI := kmsAPIHandlers{} kmsRouter := router.PathPrefix(kmsPathPrefix).Subrouter() KMSVersions := []string{ kmsAPIVersionPrefix, } gz, err := gzhttp.NewWrapper(gzhttp.MinSize(1000), gzhttp.CompressionLevel(gzip.BestSpeed))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Aug 19 14:37:53 GMT 2023 - 4.5K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/testdata/routes/istio-gateway-http-route-prefix/configdump.json
"configs": [ { "@type": "type.googleapis.com/envoy.admin.v3.RoutesConfigDump", "static_route_configs": [ { "route_config": { "@type": "type.googleapis.com/envoy.config.route.v3.RouteConfiguration", "virtual_hosts": [ { "name": "backend", "domains": [ "*" ], "routes": [ { "match": { "prefix": "/stats/prometheus" },
Json - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 2.9K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/route_test.go
}{ { name: "empty-gateway", }, { name: "istio-gateway-http-route-prefix", }, { name: "k8s-gateway-http-route-path-prefix", }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { gotOut := &bytes.Buffer{} cw := &ConfigWriter{Stdout: gotOut} cd, _ := os.ReadFile(fmt.Sprintf("testdata/routes/%s/configdump.json", tt.name)) if err := cw.Prime(cd); err != nil {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 2.8K bytes - Viewed (0) -
cmd/routers.go
// Add server metrics router registerMetricsRouter(router) // Add STS router always. registerSTSRouter(router) // Add KMS router registerKMSRouter(router) // Add API router registerAPIRouter(router) router.Use(globalMiddlewares...) return router, nil
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 3.6K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RouteDatabase.kt
val failedRoutes: Set<Route> @Synchronized get() = _failedRoutes.toSet() /** Records a failure connecting to [failedRoute]. */ @Synchronized fun failed(failedRoute: Route) { _failedRoutes.add(failedRoute) } /** Records success connecting to [route]. */ @Synchronized fun connected(route: Route) { _failedRoutes.remove(route) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 1.5K bytes - Viewed (0)