Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Sadler (0.17 sec)

  1. cmd/metrics-v2.go

    			}
    		}
    		if closer, ok := enc.(expfmt.Closer); ok {
    			closer.Close()
    		}
    	})
    }
    
    func metricsBucketHandler() http.Handler {
    	return metricsHTTPHandler(bucketCollector, "handler.MetricsBucket")
    }
    
    func metricsServerHandler() http.Handler {
    	registry := prometheus.NewRegistry()
    
    	// Report all other metrics
    	logger.CriticalIf(GlobalContext, registry.Register(clusterCollector))
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  2. cmd/object-handlers.go

    // This implementation of the PUT operation adds an object to a bucket
    // while reading the object from another source.
    // Notice: The S3 client can send secret keys in headers for encryption related jobs,
    // the handler should ensure to remove these keys before sending them to the object layer.
    // Currently these keys are:
    //   - X-Amz-Server-Side-Encryption-Customer-Key
    //   - X-Amz-Copy-Source-Server-Side-Encryption-Customer-Key
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  3. cmd/server_test.go

    	timeNow := time.Now().UTC()
    	c.Assert(creationTime.Before(timeNow), true)
    	c.Assert(timeNow.Sub(creationTime) < time.Minute*5, true)
    }
    
    // This tests validate if PUT handler can successfully detect signature mismatch.
    func (s *TestSuiteCommon) TestValidateSignature(c *check) {
    	// generate a random bucket name.
    	bucketName := getRandomBucketName()
    	// HTTP request to create the bucket.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  4. cmd/site-replication.go

    	}
    
    	if err := c.syncToAllPeers(ctx, opts); err != nil {
    		result.InitialSyncErrorMessage = err.Error()
    	}
    
    	return result, nil
    }
    
    // PeerJoinReq - internal API handler to respond to a peer cluster's request to join.
    func (c *SiteReplicationSys) PeerJoinReq(ctx context.Context, arg madmin.SRPeerJoinReq) error {
    	var ourName string
    	for d, p := range arg.Peers {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  5. cmd/admin-handlers.go

    		opts.Storage = true
    		opts.OS = true
    		// Older mc - cannot deal with more types...
    	}
    	return
    }
    
    // TraceHandler - POST /minio/admin/v3/trace
    // ----------
    // The handler sends http trace to the connected HTTP client.
    func (a adminAPIHandlers) TraceHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    	// Validate request signature.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  6. cmd/object-handlers_test.go

    		if err != nil {
    			t.Fatalf("Test %d: %s: Failed to create HTTP request for Head Object: <ERROR> %v", i+1, instanceType, err)
    		}
    		// Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler.
    		// Call the ServeHTTP to execute the handler,`func (api objectAPIHandlers) GetObjectHandler`  handles the request.
    		apiRouter.ServeHTTP(rec, req)
    
    		// Assert the response code with the expected status.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
Back to top