Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 43 for Sets (0.13 sec)

  1. docs/distributed/CONFIG.md

    ### Usage
    
    ```
    minio server --config config.yaml
    ```
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 4.2K bytes
    - Viewed (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
    	// there are lots of buckets with different order of objects in them.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
  3. internal/logger/logger.go

    // unique set. data is expected to be pre-sorted, and the resulting set in
    // the range [0:size] will remain in sorted order. Uniq, following a
    // sort.Sort call, can be used to prepare arbitrary inputs for use as sets.
    func uniq(data sort.Interface) (size int) {
    	p, l := 0, data.Len()
    	if l <= 1 {
    		return l
    	}
    	for i := 1; i < l; i++ {
    		if !data.Less(p, i) {
    			continue
    		}
    		p++
    		if p < i {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  4. internal/http/dial_linux.go

    			}
    
    			// Enable TCP open
    			// https://lwn.net/Articles/508865/ - 32k queue size.
    			_ = syscall.SetsockoptInt(fd, syscall.SOL_TCP, unix.TCP_FASTOPEN, 32*1024)
    
    			// Enable TCP fast connect
    			// TCPFastOpenConnect sets the underlying socket to use
    			// the TCP fast open connect. This feature is supported
    			// since Linux 4.11.
    			_ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_FASTOPEN_CONNECT, 1)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 4.3K bytes
    - Viewed (3)
  5. cmd/object-handlers_test.go

    		uploadID          string // uploadID of the transaction.
    		invalidPartNumber bool   // Sets an invalid multipart.
    		maximumPartNumber bool   // Sets a maximum parts.
    		accessKey         string
    		secretKey         string
    		// expected output.
    		expectedRespStatus int
    	}{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
  6. internal/bucket/lifecycle/lifecycle.go

    	if days == 0 {
    		return modTime
    	}
    	t := modTime.UTC().Add(time.Duration(days+1) * 24 * time.Hour)
    	return t.Truncate(24 * time.Hour)
    }
    
    // SetPredictionHeaders sets time to expiry and transition headers on w for a
    // given obj.
    func (lc Lifecycle) SetPredictionHeaders(w http.ResponseWriter, obj ObjectOpts) {
    	event := lc.eval(obj, time.Time{})
    	switch event.Action {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 17.5K bytes
    - Viewed (0)
  7. cmd/batch-handlers.go

    						continue
    					}
    				}
    			}
    			job.delete(j.ctx, j.objLayer)
    			j.canceler(job.ID, false)
    		case <-j.workerKillCh:
    			return
    		}
    	}
    }
    
    // ResizeWorkers sets replication workers pool to new size
    func (j *BatchJobPool) ResizeWorkers(n int) {
    	if j == nil {
    		return
    	}
    
    	j.mu.Lock()
    	defer j.mu.Unlock()
    
    	for j.workerSize < n {
    		j.workerSize++
    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)
  8. cmd/admin-handlers.go

    		}
    		erasureSet, ok := poolInfo[d.SetIndex]
    		if !ok {
    			erasureSet.ID = d.SetIndex
    			cache := dataUsageCache{}
    			if err := cache.load(ctx, z.serverPools[d.PoolIndex].sets[d.SetIndex], dataUsageCacheName); err == nil {
    				dataUsageInfo := cache.dui(dataUsageRoot, nil)
    				erasureSet.ObjectsCount = dataUsageInfo.ObjectsTotalCount
    				erasureSet.VersionsCount = dataUsageInfo.VersionsTotalCount
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  9. cmd/admin-handlers-users.go

    		Type:      madmin.SRIAMItemPolicy,
    		Name:      policyName,
    		Policy:    iamPolicyBytes,
    		UpdatedAt: updatedAt,
    	}))
    }
    
    // SetPolicyForUserOrGroup - sets a policy on a user or a group.
    //
    // PUT /minio/admin/v3/set-policy?policy=xxx&user-or-group=?[&is-group]
    //
    // Deprecated: This API is replaced by attach/detach policy APIs for specific
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 12:41:13 GMT 2024
    - 77.5K bytes
    - Viewed (0)
  10. cmd/sts-handlers.go

    		// Any client can create a certificate with arbitrary key usage settings.
    		//
    		// However, this check ensures that a certificate with an invalid key usage
    		// gets rejected even when we skip certificate verification. This helps
    		// clients detect malformed certificates during testing instead of e.g.
    		// a self-signed certificate that works while a comparable certificate
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 21:31:13 GMT 2024
    - 34.7K bytes
    - Viewed (2)
Back to top