Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 493 for proxied (0.04 seconds)

  1. cmd/admin-handlers-pools.go

    	host := env.Get("_MINIO_DECOM_ENDPOINT_HOST", defaultEndPoint.Host)
    	if host == "" {
    		return proxy
    	}
    	for nodeIdx, proxyEp := range globalProxyEndpoints {
    		if proxyEp.Host == host && !proxyEp.IsLocal {
    			if proxied, success := proxyRequestByNodeIndex(ctx, w, r, nodeIdx, false); proxied && success {
    				return true
    			}
    		}
    	}
    	return proxy
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  2. cmd/bucket-listobjects-handlers.go

    	if len(globalProxyEndpoints) == 0 {
    		return proxied, success
    	}
    	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.
    // --------------------------
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  3. cmd/site-replication-metrics_gen.go

    				return
    			}
    		case "Queued":
    			err = z.Queued.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Queued")
    				return
    			}
    		case "Proxied":
    			err = z.Proxied.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "Proxied")
    				return
    			}
    		case "Metrics":
    			var zb0002 uint32
    			zb0002, err = dc.ReadMapHeader()
    			if err != nil {
    				err = msgp.WrapError(err, "Metrics")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 40.3K bytes
    - Click Count (0)
  4. cmd/site-replication-metrics.go

    	ReplicaSize int64 `json:"replicaSize"`
    
    	// Total number of replica received
    	ReplicaCount int64 `json:"replicaCount"`
    	// Queued operations
    	Queued InQueueMetric `json:"queued"`
    	// Proxy stats
    	Proxied ProxyMetric `json:"proxied"`
    	// replication metrics summary for each site replication peer
    	Metrics map[string]SRMetric `json:"replMetrics"`
    	// uptime of node being queried for site replication metrics
    	Uptime int64 `json:"uptime"`
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  5. 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),
    			})
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
  6. docs/orchestration/docker-compose/README.md

    ```
    
    Distributed instances are now accessible on the host using the Minio CLI on port 9000 and the Minio Web Console on port 9001. Proceed to access the Web browser at <http://127.0.0.1:9001/>. Here 4 MinIO server instances are reverse proxied through Nginx load balancing.
    
    ### Notes
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 15 17:29:55 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  7. 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)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 120.6K bytes
    - Click Count (0)
  8. cmd/batch-handlers.go

    		return
    	}
    
    	jobID := r.Form.Get("id")
    	if jobID == "" {
    		writeErrorResponseJSON(ctx, w, toAPIError(ctx, errInvalidArgument), r.URL)
    		return
    	}
    
    	if _, proxied, _ := proxyRequestByToken(ctx, w, r, jobID, true); proxied {
    		return
    	}
    
    	if err := globalBatchJobPool.canceler(jobID, true); err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrInvalidRequest, err), r.URL)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 63.5K bytes
    - Click Count (1)
  9. cmd/generic-handlers.go

    		// Requests in federated setups for STS type calls which are
    		// performed at '/' resource should be routed by the muxer,
    		// the assumption is simply such that requests without a bucket
    		// in a federated setup cannot be proxied, so serve them at
    		// current server.
    		if bucket == "" {
    			h.ServeHTTP(w, r)
    			return
    		}
    
    		// MakeBucket requests should be handled at current endpoint
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.7K bytes
    - Click Count (1)
  10. 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)
    			}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
Back to Top