Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 116 for fetch (0.04 sec)

  1. cmd/utils.go

    	req, err = http.NewRequestWithContext(ctx, http.MethodGet, u.String(), nil)
    	if err != nil {
    		return "", fmt.Errorf("new request err (/ldap): %v", err)
    	}
    	_, err = dexClient.Do(req)
    	// fmt.Printf("Fetch LDAP login page: %#v %#v\n", resp, err)
    	if err != nil {
    		return "", fmt.Errorf("request err: %v", err)
    	}
    	// {
    	// 	bodyBuf, err := io.ReadAll(resp.Body)
    	// 	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  2. tensorflow/c/eager/c_api_experimental.h

    // inspect values. This would let people e.g. copy over most attributes and then
    // modify some based on their values.
    
    // A reference to an op's name -> attribute mapping
    typedef struct TFE_OpAttrs TFE_OpAttrs;
    
    // Fetch a reference to `op`'s attributes. The returned reference is only valid
    // while `op` is alive.
    TF_CAPI_EXPORT extern const TFE_OpAttrs* TFE_OpGetAttrs(const TFE_Op* op);
    // Add attributes in `attrs` to `op`.
    //
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Feb 21 22:37:46 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  3. cmd/metrics-v2.go

    	mg := &MetricsGroupV2{
    		cacheInterval:    1 * time.Minute,
    		metricsGroupOpts: opts,
    	}
    	mg.RegisterRead(func(ctx context.Context) (metrics []MetricV2) {
    		objLayer := newObjectLayerFn()
    
    		// Fetch disk space info, ignore errors
    		metrics = make([]MetricV2, 0, 10)
    		storageInfo := objLayer.StorageInfo(ctx, true)
    		onlineDrives, offlineDrives := getOnlineOfflineDisksStats(storageInfo.Disks)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  4. cmd/erasure-sets.go

    	// Prepare heal-result
    	res = madmin.HealResultItem{
    		Type:      madmin.HealItemMetadata,
    		Detail:    "disk-format",
    		DiskCount: s.setCount * s.setDriveCount,
    		SetCount:  s.setCount,
    	}
    
    	// Fetch all the drive info status.
    	beforeDrives := formatsToDrivesInfo(s.endpoints.Endpoints, formats, sErrs)
    
    	res.After.Drives = make([]madmin.HealDriveInfo, len(beforeDrives))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  5. src/archive/tar/reader.go

    // to store the rest of the sparse map.
    //
    // The Header.Size does not reflect the size of any extended headers used.
    // Thus, this function will read from the raw io.Reader to fetch extra headers.
    // This method mutates blk in the process.
    func (tr *Reader) readOldGNUSparseMap(hdr *Header, blk *block) (sparseDatas, error) {
    	// Make sure that the input format is GNU.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  6. cmd/test-utils_test.go

    // to enable InsecureSkipVerify in TLS config
    
    // Starts the test server and returns the TestServer with TLS configured instance.
    func StartTestTLSServer(t TestErrHandler, instanceType string, cert, key []byte) TestServer {
    	// Fetch TLS key and pem files from test-data/ directory.
    	//	dir, _ := os.Getwd()
    	//	testDataDir := filepath.Join(filepath.Dir(dir), "test-data")
    	//
    	//	pemFile := filepath.Join(testDataDir, "server.pem")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  7. cmd/iam-store.go

    // operation, we fetch this info from storage, and refresh the cache as well.
    func (store *IAMStoreSys) ListGroups(ctx context.Context) (res []string, err error) {
    	cache := store.lock()
    	defer store.unlock()
    
    	return store.updateGroups(ctx, cache)
    }
    
    // listGroups - lists groups - fetch groups from cache
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Oct 14 16:35:37 UTC 2024
    - 83.2K bytes
    - Viewed (0)
  8. cmd/admin-handlers-users.go

    		rd, wr := isAllowedAccess(bucket.Name)
    		if rd || wr {
    			// Fetch the data usage of the current bucket
    			bui := globalBucketQuotaSys.GetBucketUsageInfo(ctx, bucket.Name)
    			size := bui.Size
    			objectsCount := bui.ObjectsCount
    			objectsHist := bui.ObjectSizesHistogram
    			versionsHist := bui.ObjectVersionsHistogram
    
    			// Fetch the prefix usage of the current bucket
    			var prefixUsage map[string]uint64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 03 23:11:02 UTC 2024
    - 85.1K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool.go

    	if err != nil {
    		for i := range derrs {
    			derrs[i] = err
    		}
    		return dobjects, derrs
    	}
    	ctx = lkctx.Context()
    	defer multiDeleteLock.Unlock(lkctx)
    
    	// Fetch location of up to 10 objects concurrently.
    	poolObjIdxMap := map[int][]ObjectToDelete{}
    	origIndexMap := map[int][]int{}
    
    	// Always perform 1/10th of the number of objects per delete
    	concurrent := len(objects) / 10
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  10. cmd/encryption-v1.go

    				}
    			}
    			objects = objects[N:]
    			continue
    		}
    
    		// There is at least one SSE-S3 single-part object.
    		// For all SSE-S3 single-part objects we have to
    		// fetch their decryption keys. We do this using
    		// a Bulk-Decryption API call, if available.
    		keys, err := crypto.S3.UnsealObjectKeys(ctx, k, metadata, buckets, names)
    		if err != nil {
    			return err
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:06:08 UTC 2024
    - 37.2K bytes
    - Viewed (0)
Back to top