Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 100 of 529 for handles (0.05 seconds)

  1. src/bufio/bufio_test.go

    		},
    		// ReadLine doesn't fit the data/pattern easily
    		// so we leave it out. It should be covered via
    		// the ReadSlice test since ReadLine simply calls
    		// ReadSlice, and it's that function that handles
    		// the last byte.
    	}
    
    	// Try all readers with UnreadByte.
    	for rno, read := range readers {
    		// Some input data that is longer than the minimum reader buffer size.
    		const n = 10
    		var buf bytes.Buffer
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Feb 07 01:08:54 GMT 2025
    - 51.6K bytes
    - Click Count (0)
  2. cmd/auth-handler.go

    	_, ok := supportedS3AuthTypes[aType]
    	return ok
    }
    
    // setAuthMiddleware to validate authorization header for the incoming request.
    func setAuthMiddleware(h http.Handler) http.Handler {
    	// handler for validating incoming authorization headers.
    	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt)
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  3. internal/grid/README.md

    and other connections will be blocked while the large payload is being sent.
    
    ## Handlers & Routes
    
    Handlers have a predefined Handler ID.
    In addition, there can be several *static* subroutes used to differentiate between different handlers of the same ID.
    A subroute on a client must match a subroute on the server. So routes cannot be used for dynamic routing, unlike HTTP.
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:03 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  4. cmd/handler-utils.go

    	success = true
    
    	// Make sure we remove any existing headers before
    	// proxying the request to another node.
    	for k := range w.Header() {
    		w.Header().Del(k)
    	}
    
    	f := handlers.NewForwarder(&handlers.Forwarder{
    		PassHost:     true,
    		RoundTripper: ep.Transport,
    		ErrorHandler: func(w http.ResponseWriter, r *http.Request, err error) {
    			success = false
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.4K bytes
    - Click Count (1)
  5. cmd/bucket-lifecycle-handlers.go

    	"github.com/minio/mux"
    	"github.com/minio/pkg/v3/policy"
    )
    
    const (
    	// Lifecycle configuration file.
    	bucketLifecycleConfig = "lifecycle.xml"
    )
    
    // PutBucketLifecycleHandler - This HTTP handler stores given bucket lifecycle configuration as per
    // https://docs.aws.amazon.com/AmazonS3/latest/dev/object-lifecycle-mgmt.html
    func (api objectAPIHandlers) PutBucketLifecycleHandler(w http.ResponseWriter, r *http.Request) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Jan 20 14:49:07 GMT 2025
    - 7K bytes
    - Click Count (0)
  6. cmd/erasure-server-pool.go

    	if err = checkDelObjArgs(ctx, bucket, object); err != nil {
    		return objInfo, err
    	}
    
    	if !opts.DeletePrefix { // DeletePrefix handles dir object encoding differently.
    		object = encodeDirObject(object)
    	}
    
    	// Acquire a write lock before deleting the object.
    	lk := z.NewNSLock(bucket, object)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  7. cmd/metrics-router.go

    		auth = NoAuthMiddleware
    	}
    
    	metricsRouter.Handle(prometheusMetricsPathLegacy, auth(metricsHandler()))
    	metricsRouter.Handle(prometheusMetricsV2ClusterPath, auth(metricsServerHandler()))
    	metricsRouter.Handle(prometheusMetricsV2BucketPath, auth(metricsBucketHandler()))
    	metricsRouter.Handle(prometheusMetricsV2NodePath, auth(metricsNodeHandler()))
    	metricsRouter.Handle(prometheusMetricsV2ResourcePath, auth(metricsResourceHandler()))
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Jul 15 16:28:02 GMT 2024
    - 2.6K bytes
    - Click Count (0)
  8. cmd/bucket-policy-handlers.go

    	maxBucketPolicySize = 20 * humanize.KiByte
    
    	// Policy configuration file.
    	bucketPolicyConfig = "policy.json"
    )
    
    // PutBucketPolicyHandler - This HTTP handler stores given bucket policy configuration as per
    // https://docs.aws.amazon.com/AmazonS3/latest/dev/access-policy-language-overview.html
    func (api objectAPIHandlers) PutBucketPolicyHandler(w http.ResponseWriter, r *http.Request) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 6.1K bytes
    - Click Count (0)
  9. cmd/api-router.go

    	return h&flag != 0
    }
    
    // s3APIMiddleware - performs some common handler functionality for S3 API
    // handlers.
    //
    // It is set per-"handler function registration" in the router to allow for
    // behavior modification via flags.
    //
    // This middleware always calls `collectAPIStats` to collect API stats.
    //
    // The passed in handler function must be a method of `objectAPIHandlers` for
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:19 GMT 2025
    - 23.3K bytes
    - Click Count (0)
  10. cmd/bucket-notification-handlers.go

    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/mux"
    	"github.com/minio/pkg/v3/policy"
    )
    
    const (
    	bucketNotificationConfig = "notification.xml"
    )
    
    // GetBucketNotificationHandler - This HTTP handler returns event notification configuration
    // as per http://docs.aws.amazon.com/AmazonS3/latest/dev/NotificationHowTo.html.
    // It returns empty configuration if its not set.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 5.1K bytes
    - Click Count (0)
Back to Top