Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for clients (0.16 sec)

  1. cmd/object-handlers.go

    			// write error response only if no data or headers has been written to client yet
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    		return
    	}
    
    	if err = httpWriter.Close(); err != nil {
    		if !httpWriter.HasWritten() && !statusCodeWritten { // write error response only if no data or headers has been written to client yet
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    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)
  2. cmd/bucket-replication.go

    	}
    
    	req, err := http.NewRequestWithContext(ctx, http.MethodGet, reqURL.String(), nil)
    	if err != nil {
    		return err
    	}
    
    	client := &http.Client{
    		Transport: globalRemoteTargetTransport,
    		Timeout:   10 * time.Second,
    	}
    
    	resp, err := client.Do(req)
    	if err != nil {
    		return err
    	}
    	if err == nil {
    		// Drain the connection.
    		xhttp.DrainBody(resp.Body)
    	}
    	if resp != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  3. cmd/site-replication.go

    	}
    	client, err := madmin.New(epURL.Host, accessKey, secretKey, epURL.Scheme == "https")
    	if err != nil {
    		return nil, err
    	}
    	client.SetCustomTransport(globalRemoteTargetTransport)
    	return client, nil
    }
    
    func getS3Client(pc madmin.PeerSite) (*minioClient.Client, error) {
    	ep, err := url.Parse(pc.Endpoint)
    	if err != nil {
    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)
  4. cmd/server_test.go

    type TestSuiteCommon struct {
    	serverType string
    	testServer TestServer
    	endPoint   string
    	accessKey  string
    	secretKey  string
    	signer     signerType
    	secure     bool
    	client     *http.Client
    }
    
    type check struct {
    	*testing.T
    	testType string
    }
    
    // Assert - checks if gotValue is same as expectedValue, if not fails the test.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  5. cmd/metrics-v2.go

    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/mcontext"
    	"github.com/minio/minio/internal/rest"
    	"github.com/prometheus/client_golang/prometheus"
    	dto "github.com/prometheus/client_model/go"
    	"github.com/prometheus/common/expfmt"
    	"github.com/prometheus/procfs"
    )
    
    //go:generate msgp -file=$GOFILE -unexported -io=false
    
    var (
    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)
  6. cmd/admin-handlers.go

    		if globalIsDistErasure {
    			ng := WithNPeers(len(globalNotificationSys.peerClients))
    			for idx, client := range globalNotificationSys.peerClients {
    				_, ok := failedClients[idx]
    				if ok {
    					continue
    				}
    				client := client
    				ng.Go(ctx, func() error {
    					return client.CommitBinary(ctx)
    				}, idx, *client.host)
    			}
    
    			for _, nerr := range ng.Wait() {
    				if nerr.Err != nil {
    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)
Back to top