Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for clnts (0.15 sec)

  1. internal/rest/client.go

    		HealthCheckReconnectUnit: 200 * time.Millisecond,
    		HealthCheckTimeout:       time.Second,
    	}
    	if err != nil {
    		clnt.lastErr = err
    		clnt.lastErrTime = time.Now()
    	}
    
    	if clnt.HealthCheckFn != nil {
    		// make connection pre-emptively.
    		go clnt.HealthCheckFn()
    	}
    	return clnt
    }
    
    // IsOnline returns whether the client is likely to be online.
    func (c *Client) IsOnline() bool {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 14.4K bytes
    - Viewed (0)
  2. cmd/warm-backend-gcs.go

    	credsJSON, err := conf.GetCredentialJSON()
    	if err != nil {
    		return nil, err
    	}
    
    	clnt := &http.Client{
    		Transport: globalRemoteTargetTransport,
    	}
    
    	client, err := storage.NewClient(context.Background(),
    		option.WithCredentialsJSON(credsJSON),
    		option.WithScopes(storage.ScopeReadWrite),
    		option.WithHTTPClient(clnt),
    		option.WithUserAgent(fmt.Sprintf("gcs-tier-%s", tier)+SlashSeparator+ReleaseTag),
    	)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  3. cmd/bucket-targets.go

    func newHCClient() *madmin.AnonymousClient {
    	clnt, e := madmin.NewAnonymousClientNoEndpoint()
    	if e != nil {
    		bugLogIf(GlobalContext, errors.New("Unable to initialize health check client"))
    		return nil
    	}
    	clnt.SetCustomTransport(globalRemoteTargetTransport)
    	return clnt
    }
    
    // heartBeat performs liveness check on remote endpoints.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  4. cmd/update.go

    		return MinioReleaseURL + "minio.exe"
    	}
    
    	return MinioReleaseURL + "minio"
    }
    
    func getUpdateReaderFromURL(u *url.URL, transport http.RoundTripper, mode string) (io.ReadCloser, error) {
    	clnt := &http.Client{
    		Transport: transport,
    	}
    	req, err := http.NewRequest(http.MethodGet, u.String(), nil)
    	if err != nil {
    		return nil, AdminError{
    			Code:       AdminUpdateUnexpectedFailure,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  5. cmd/bucket-replication.go

    			return sameTarget, toAPIError(ctx, BucketRemoteArnTypeInvalid{Bucket: bucket})
    		}
    		clnt := globalBucketTargetSys.GetRemoteTargetClient(bucket, arnStr)
    		if clnt == nil {
    			return sameTarget, toAPIError(ctx, BucketRemoteTargetNotFound{Bucket: bucket})
    		}
    		if checkRemote { // validate remote bucket
    			found, err := clnt.BucketExists(ctx, arn.Bucket)
    			if err != 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)
  6. cmd/batch-handlers.go

    	if err != nil {
    		return err
    	}
    
    	if token != "" {
    		req.Header.Set("Authorization", token)
    	}
    	req.Header.Set("Content-Type", "application/json")
    
    	clnt := http.Client{Transport: getRemoteInstanceTransport()}
    	resp, err := clnt.Do(req)
    	if err != nil {
    		return err
    	}
    
    	xhttp.DrainBody(resp.Body)
    	if resp.StatusCode != http.StatusOK {
    		return errors.New(resp.Status)
    	}
    
    	return nil
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
Back to top