Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 521 - 530 of 639 for asName (0.04 seconds)

  1. cmd/tier.go

    	randInterval := func() time.Duration {
    		return time.Duration(r.Float64() * 5 * float64(time.Second))
    	}
    
    	// To avoid all MinIO nodes reading the tier config object at the same
    	// time.
    	t := time.NewTimer(tierCfgRefresh + randInterval())
    	defer t.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-t.C:
    			err := config.Reload(ctx, objAPI)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  2. cmd/erasure.go

    	}
    
    	// Put all buckets into channel.
    	bucketCh := make(chan BucketInfo, len(buckets))
    
    	// Shuffle buckets to ensure total randomness of buckets, being scanned.
    	// Otherwise same set of buckets get scanned across erasure sets always.
    	// at any given point in time. This allows different buckets to be scanned
    	// in different order per erasure set, this wider spread is needed when
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.1K bytes
    - Click Count (0)
  3. cmd/config-current.go

    	// Bucket federation is 'true' only when IAM assets are not namespaced
    	// per tenant and all tenants interested in globally available users
    	// if namespace was requested such as specifying etcdPathPrefix then
    	// we assume that users are interested in global bucket support
    	// but not federation.
    	globalBucketFederation = etcdCfg.PathPrefix == "" && etcdCfg.Enabled
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 28.5K bytes
    - Click Count (0)
  4. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultWagonManager.java

                }
    
                // The temporary file is named destination + ".tmp" and is done this way to ensure
                // that the temporary file is in the same file system as the destination because the
                // File.renameTo operation doesn't really work across file systems.
                // So we will attempt to do a File.renameTo for efficiency and atomicity, if this fails
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Sat Apr 05 11:52:05 GMT 2025
    - 29.9K bytes
    - Click Count (0)
  5. cmd/xl-storage.go

    	}
    
    	return s.deleteFile(volumeDir, pathJoin(volumeDir, path, xlStorageFormatFile), true, false)
    }
    
    // DeleteVersions deletes slice of versions, it can be same object
    // or multiple objects.
    func (s *xlStorage) DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error {
    	errs := make([]error, len(versions))
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
  6. cmd/handler-utils.go

    	if location == "" {
    		location = globalSite.Region()
    	}
    	if !isValidLocation(location) {
    		return location, ErrInvalidRegion
    	}
    
    	return location, ErrNone
    }
    
    // Validates input location is same as configured region
    // of MinIO server.
    func isValidLocation(location string) bool {
    	region := globalSite.Region()
    	return region == "" || region == location
    }
    
    // Supported headers that needs to be extracted.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.4K bytes
    - Click Count (1)
  7. internal/rest/client.go

    		connected = int32(offline)
    		err = &url.Error{URL: urlStr, Err: err}
    	}
    	// The host's colon:port should be normalized. See Issue 14836.
    	u.Host = removeEmptyPort(u.Host)
    
    	// Transport is exactly same as Go default in https://golang.org/pkg/net/http/#RoundTripper
    	// except custom DialContext and TLSClientConfig.
    	clnt := &Client{
    		httpClient:               &http.Client{Transport: tr},
    		url:                      u,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  8. internal/config/identity/openid/openid.go

    			}
    			if p.ClientID == "" {
    				return c, config.Errorf("client ID must not be empty")
    			}
    
    			// We set the resource ID of the role arn as a hash of client
    			// ID, so we can get a short roleARN that stays the same on
    			// restart.
    			var resourceID string
    			{
    				h := sha1.New()
    				h.Write([]byte(p.ClientID))
    				bs := h.Sum(nil)
    				resourceID = base64.RawURLEncoding.EncodeToString(bs)
    			}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 17.3K bytes
    - Click Count (0)
  9. cmd/bucket-handlers.go

    			return
    		}
    		maxParts--
    
    		name := part.FormName()
    		if name == "" {
    			continue
    		}
    
    		fileName = part.FileName()
    
    		// Multiple values for the same key (one map entry, longer slice) are cheaper
    		// than the same number of values for different keys (many map entries), but
    		// using a consistent per-value cost for overhead is simpler.
    		maxMemoryBytes := 2 * int64(10<<20)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (0)
  10. cmd/server_test.go

    	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.
    func (c *check) Assert(gotValue any, expectedValue any) {
    	c.Helper()
    	if !reflect.DeepEqual(gotValue, expectedValue) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 118.1K bytes
    - Click Count (0)
Back to Top