Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getRemoteInstanceTransport (0.48 sec)

  1. 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)
  2. cmd/batch-expire.go

    	if err != nil {
    		return err
    	}
    
    	if r.NotificationCfg.Token != "" {
    		req.Header.Set("Authorization", r.NotificationCfg.Token)
    	}
    
    	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: Thu Apr 04 12:04:40 GMT 2024
    - 21K bytes
    - Viewed (1)
  3. cmd/object-handlers.go

    	return defaultMeta, nil
    }
    
    // getRemoteInstanceTransport contains a roundtripper for external (not peers) servers
    var remoteInstanceTransport atomic.Value
    
    func setRemoteInstanceTransport(tr http.RoundTripper) {
    	remoteInstanceTransport.Store(tr)
    }
    
    func getRemoteInstanceTransport() http.RoundTripper {
    	rt, ok := remoteInstanceTransport.Load().(http.RoundTripper)
    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)
Back to top