- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for proxyRequest (0.06 sec)
-
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 118.2K bytes - Viewed (0) -
cmd/bucket-listobjects-handlers.go
} if index < 0 || index >= len(globalProxyEndpoints) { return proxied, success } ep := globalProxyEndpoints[index] if ep.IsLocal { return proxied, success } return true, proxyRequest(ctx, w, r, ep, returnErr) } // ListObjectsV1Handler - GET Bucket (List Objects) Version 1. // -------------------------- // This implementation of the GET operation returns some or all (up to 1000)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 11.6K 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 14.3K bytes - Viewed (0) -
cmd/object-api-interface.go
NoLock bool // indicates to lower layers if the caller is expecting to hold locks. HasIfMatch bool // indicates if the request has If-Match header 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 17.5K bytes - Viewed (0) -
cmd/handler-utils.go
if globalIsDistErasure { hostName = globalLocalNodeName } else { hostName = r.Host } return hostName } // Proxy any request to an endpoint. func proxyRequest(ctx context.Context, w http.ResponseWriter, r *http.Request, ep ProxyEndpoint, returnErr bool) (success bool) { success = true // Make sure we remove any existing headers before // proxying the request to another node.Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 16.4K bytes - Viewed (1) -
cmd/endpoint.go
PathEndpointType EndpointType = iota + 1 // URLEndpointType - URL style endpoint type enum. URLEndpointType ) // ProxyEndpoint - endpoint used for proxy redirects // See proxyRequest() for details. type ProxyEndpoint struct { Endpoint Transport http.RoundTripper } // Node holds information about a node in this cluster type Node struct { *url.URL Pools []int IsLocal boolRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 34.5K bytes - Viewed (0) -
api/go1.20.txt
pkg net/http/httputil, method (*ProxyRequest) SetURL(*url.URL) #53002 pkg net/http/httputil, method (*ProxyRequest) SetXForwarded() #53002 pkg net/http/httputil, type ProxyRequest struct #53002 pkg net/http/httputil, type ProxyRequest struct, In *http.Request #53002 pkg net/http/httputil, type ProxyRequest struct, Out *http.Request #53002
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Fri Feb 17 21:23:32 UTC 2023 - 602.6K bytes - Viewed (0)