- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for Proxies (0.1 sec)
-
okhttp/src/test/java/okhttp3/CallTest.kt
*/ @Test fun connectTimeoutsAttemptsAlternateRoute() { val proxySelector = RecordingProxySelector() proxySelector.proxies.add(Proxy(Proxy.Type.HTTP, TestUtil.UNREACHABLE_ADDRESS_IPV4)) proxySelector.proxies.add(server.toProxyAddress()) server.enqueue(MockResponse(body = "success!")) client = client.newBuilder() .proxySelector(proxySelector)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 142.5K bytes - Viewed (0) -
cmd/bucket-replication.go
ri.Checksum = oi.Checksum } if dsc.Synchronous() { replicateObject(ctx, ri, o) } else { globalReplicationPool.Get().queueReplicaTask(ri) } } // proxyTaggingToRepTarget proxies tagging requests to remote targets for // active-active replicated setups
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 06:49:55 UTC 2024 - 116.1K bytes - Viewed (0) -
docs/metrics/prometheus/grafana/bucket/minio-bucket.json
"interval": "1m", "intervalFactor": 2, "legendFormat": "{{bucket}}", "refId": "A" } ], "title": "Total Proxied Head Requests", "type": "timeseries" }, { "datasource": { "type": "prometheus", "uid": "${DS_PROMETHEUS}" }, "fieldConfig": {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 11:11:51 UTC 2024 - 101.8K bytes - Viewed (0) -
cmd/metrics-v2.go
Value: float64(m.Proxied.GetTotal), }) ml = append(ml, MetricV2{ Description: getClusterReplProxiedHeadOperationsMD(clusterMetricNamespace), Value: float64(m.Proxied.HeadTotal), }) ml = append(ml, MetricV2{ Description: getClusterReplProxiedPutTaggingOperationsMD(clusterMetricNamespace), Value: float64(m.Proxied.PutTagTotal), })
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 131.9K bytes - Viewed (0) -
cmd/object-handlers.go
} } writeErrorResponseHeadersOnly(w, toAPIError(ctx, err)) return } if !proxy.Proxy { // apply lifecycle rules only locally not for proxied requests // Automatically remove the object/version if an expiry lifecycle rule can be applied if lc, err := globalLifecycleSys.Get(bucket); err == nil { rcfg, err := globalBucketObjectLockSys.Get(bucket)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 05 05:16:15 UTC 2024 - 117.4K bytes - Viewed (0) -
cmd/site-replication.go
sm.Queued.Max.Bytes = peer.Queued.Max.Bytes sm.Queued.Max.Count = peer.Queued.Max.Count } sm.ReplicaCount += peer.ReplicaCount sm.ReplicaSize += peer.ReplicaSize sm.Proxied.Add(madmin.ReplProxyMetric(peer.Proxied)) for dID, v := range peer.Metrics { v2, ok := sm.Metrics[dID] if !ok { v2 = madmin.SRMetric{} v2.Failed.ErrCounts = make(map[string]int) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 185.1K bytes - Viewed (0)