Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 52 for currentCL (0.16 sec)

  1. cmd/batch-handlers.go

    			slowCh = make(chan itemOrErr[ObjectInfo], 100)
    		)
    
    		if r.Source.Snowball.Disable != nil && !*r.Source.Snowball.Disable && r.Source.Type.isMinio() && r.Target.Type.isMinio() {
    			go func() {
    				// Snowball currently needs the high level minio-go Client, not the Core one
    				cl, err := miniogo.New(u.Host, &miniogo.Options{
    					Creds:        credentials.NewStaticV4(cred.AccessKey, cred.SecretKey, cred.SessionToken),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/cache/CacheBuilder.java

       * implementation; otherwise refreshes will be performed during unrelated cache read and write
       * operations.
       *
       * <p>Currently automatic refreshes are performed when the first stale request for an entry
       * occurs. The request triggering refresh will make a synchronous call to {@link
       * CacheLoader#reload}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 52K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/Futures.java

         * outputs users get when calling this with <Foo> and calling it with <@Nullable Foo>. The only
         * difference is that calling it with <Foo> won't work when an input Future has a @Nullable
         * type. So why even make that error possible by giving callers the choice?
         *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  4. cmd/xl-storage-format-v2.go

    	// Linear search, we likely have to insert at front.
    	for i, existing := range x.versions {
    		if existing.header.ModTime <= modTime {
    			// Insert at current idx. First move current back.
    			copy(x.versions[i+1:], x.versions[i:])
    			x.versions[i] = xlMetaV2ShallowVersion{
    				header: ver.header(),
    				meta:   encoded,
    			}
    			return nil
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 64K bytes
    - Viewed (1)
  5. android/guava/src/com/google/common/collect/Iterators.java

          Iterator<T> iterator, Predicate<? super T> predicate) {
        checkNotNull(predicate, "predicate");
        for (int i = 0; iterator.hasNext(); i++) {
          T current = iterator.next();
          if (predicate.apply(current)) {
            return i;
          }
        }
        return -1;
      }
    
      /**
       * Returns a view containing the result of applying {@code function} to each element of {@code
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 50.3K bytes
    - Viewed (0)
  6. cmd/admin-handlers-users.go

    		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
    			if enablePrefixUsage {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 03 23:11:02 UTC 2024
    - 85.1K bytes
    - Viewed (0)
  7. cmd/peer-rest-server.go

    		}
    	}
    	return &BucketStatsMap{Stats: bucketStatsMap, Timestamp: time.Now()}, nil
    }
    
    // GetBucketStatsHandler - fetches current in-memory bucket stats, currently only
    // returns BucketStats, that currently includes ReplicationStats.
    func (s *peerRESTServer) GetBucketStatsHandler(vars *grid.MSS) (*BucketStats, *grid.RemoteErr) {
    	bucketName := vars.Get(peerRESTBucket)
    	if bucketName == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  8. istioctl/pkg/describe/describe.go

    	hcm, err := getInboundHTTPConnectionManager(cd, port)
    	if err != nil || hcm == nil {
    		return []string{}, err
    	}
    
    	// Identify RBAC policies. Currently there are no "breadcrumbs" so we only return the policy names.
    	for _, httpFilter := range hcm.HttpFilters {
    		if httpFilter.Name == wellknown.HTTPRoleBasedAccessControl {
    			rbac := &rbachttp.RBAC{}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  9. guava/src/com/google/common/cache/CacheBuilder.java

       * implementation; otherwise refreshes will be performed during unrelated cache read and write
       * operations.
       *
       * <p>Currently automatic refreshes are performed when the first stale request for an entry
       * occurs. The request triggering refresh will make a synchronous call to {@link
       * CacheLoader#reload}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/Futures.java

         * outputs users get when calling this with <Foo> and calling it with <@Nullable Foo>. The only
         * difference is that calling it with <Foo> won't work when an input Future has a @Nullable
         * type. So why even make that error possible by giving callers the choice?
         *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
Back to top