- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for proxyrequest (0.15 sec)
-
src/net/http/httputil/reverseproxy.go
"net/http/httptrace" "net/http/internal/ascii" "net/textproto" "net/url" "strings" "sync" "time" "golang.org/x/net/http/httpguts" ) // A ProxyRequest contains a request to be rewritten by a [ReverseProxy]. type ProxyRequest struct { // In is the request received by the proxy. // The Rewrite function must not modify In. In *http.Request // Out is the request which will be sent by the proxy.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 27 23:37:42 UTC 2024 - 24.9K bytes - Viewed (0) -
pilot/pkg/xds/monitoring.go
model.SecretTrigger: pushTriggers.With(typeTag.Value(string(model.SecretTrigger))), model.NetworksTrigger: pushTriggers.With(typeTag.Value(string(model.NetworksTrigger))), model.ProxyRequest: pushTriggers.With(typeTag.Value(string(model.ProxyRequest))), model.NamespaceUpdate: pushTriggers.With(typeTag.Value(string(model.NamespaceUpdate))), model.ClusterUpdate: pushTriggers.With(typeTag.Value(string(model.ClusterUpdate))), }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 6.7K bytes - Viewed (0) -
src/net/http/httputil/example_test.go
defer backendServer.Close() rpURL, err := url.Parse(backendServer.URL) if err != nil { log.Fatal(err) } frontendProxy := httptest.NewServer(&httputil.ReverseProxy{ Rewrite: func(r *httputil.ProxyRequest) { r.SetXForwarded() r.SetURL(rpURL) }, }) defer frontendProxy.Close() resp, err := http.Get(frontendProxy.URL) if err != nil { log.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 16 20:01:36 UTC 2022 - 3.2K bytes - Viewed (0) -
pilot/pkg/xds/discovery_test.go
model.ConfigUpdate, model.ServiceUpdate, model.ProxyUpdate, model.GlobalUpdate, model.UnknownTrigger, model.DebugTrigger, model.SecretTrigger, model.NetworksTrigger, model.ProxyRequest, model.NamespaceUpdate, } // Number of (simulated) proxies proxies := 500 // Number of (simulated) pushes merged pushesMerged := 10 // Number of configs per push configs := 1
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 9.2K bytes - Viewed (0) -
cmd/bucket-listobjects-handlers.go
return false } if index < 0 || index >= len(globalProxyEndpoints) { return false } ep := globalProxyEndpoints[index] if ep.IsLocal { return false } return proxyRequest(ctx, w, r, ep) } // ListObjectsV1Handler - GET Bucket (List Objects) Version 1. // -------------------------- // This implementation of the GET operation returns some or all (up to 1000)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 11.4K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy_test.go
return &ReverseProxy{ Rewrite: func(r *ProxyRequest) { r.SetURL(u) }, } }) } func TestReverseProxyQueryParameterSmugglingRewritePreservesRawQuery(t *testing.T) { testReverseProxyQueryParameterSmuggling(t, testWantsRawQuery, func(u *url.URL) *ReverseProxy { return &ReverseProxy{ Rewrite: func(r *ProxyRequest) { r.SetURL(u) r.Out.URL.RawQuery = r.In.URL.RawQuery
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 54.6K bytes - Viewed (0) -
cmd/bucket-replication.go
func getProxyTargets(ctx context.Context, bucket, object string, opts ObjectOptions) (tgts *madmin.BucketTargets) { if opts.VersionSuspended { return &madmin.BucketTargets{} } if opts.ProxyRequest || (opts.ProxyHeaderSet && !opts.ProxyRequest) { return &madmin.BucketTargets{} } cfg, err := getReplicationConfig(ctx, bucket) if err != nil || cfg == nil { replLogOnceIf(ctx, err, bucket)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0) -
cmd/object-api-options.go
var clientKey [32]byte var sse encrypt.ServerSide opts = ObjectOptions{UserDefined: metadata} if v, ok := header[xhttp.MinIOSourceProxyRequest]; ok { opts.ProxyHeaderSet = true opts.ProxyRequest = strings.Join(v, "") == "true" } if _, ok := header[xhttp.MinIOSourceReplicationRequest]; ok { opts.ReplicationRequest = true } opts.Speedtest = header.Get(globalObjectPerfUserMetadata) != ""
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 14.3K bytes - Viewed (0) -
cmd/handler-utils.go
if globalIsDistErasure { hostName = globalLocalNodeName } else { hostName = r.Host } return } // Proxy any request to an endpoint. func proxyRequest(ctx context.Context, w http.ResponseWriter, r *http.Request, ep ProxyEndpoint) (success bool) { success = true // Make sure we remove any existing headers before // proxying the request to another node.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.5K bytes - Viewed (0) -
cmd/object-api-interface.go
PreserveETag string // preserves this etag during a PUT call. NoLock bool // indicates to lower layers if the caller is expecting to hold locks. ProxyRequest bool // only set for GET/HEAD in active-active replication scenario ProxyHeaderSet bool // only set for GET/HEAD in active-active replication scenario
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 06 20:27:52 UTC 2024 - 17K bytes - Viewed (0)