Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 135 for Hummer (0.23 sec)

  1. internal/bucket/bandwidth/monitor_gen.go

    		default:
    			bts, err = msgp.Skip(bts)
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z BucketBandwidthReport) Msgsize() (s int) {
    	s = 1
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *Details) DecodeMsg(dc *msgp.Reader) (err error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  2. internal/config/heal/heal.go

    func (opts Config) Clone() (int, time.Duration, string) {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.IOCount, opts.Sleep, opts.Bitrot
    }
    
    // GetWorkers returns the number of workers, -1 is none configured
    func (opts Config) GetWorkers() int {
    	configMutex.RLock()
    	defer configMutex.RUnlock()
    	return opts.DriveWorkers
    }
    
    // Update updates opts with nopts
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 01:10:30 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  3. cmd/storage-datatypes_gen.go

    		default:
    			bts, err = msgp.Skip(bts)
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z BaseOptions) Msgsize() (s int) {
    	s = 1
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *CheckPartsHandlerParams) DecodeMsg(dc *msgp.Reader) (err error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 127.5K bytes
    - Viewed (0)
  4. cmd/iam-etcd-store.go

    	ctx, cancel := context.WithTimeout(ctx, defaultContextTimeout)
    	defer cancel()
    	//  Retrieve all keys and values to avoid too many calls to etcd in case of
    	//  a large number of policies
    	r, err := ies.client.Get(ctx, iamConfigPoliciesPrefix, etcd.WithPrefix())
    	if err != nil {
    		return err
    	}
    
    	// Parse all values to construct the policies data model.
    	for _, kvs := range r.Kvs {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  5. internal/config/storageclass/storage-class.go

    // Supported Storage Class format is "Scheme:Number of parity drives".
    // Currently only supported scheme is "EC".
    func parseStorageClass(storageClassEnv string) (sc StorageClass, err error) {
    	s := strings.Split(storageClassEnv, ":")
    
    	// only two elements allowed in the string - "scheme" and "number of parity drives"
    	if len(s) > 2 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 11.8K bytes
    - Viewed (1)
  6. cmd/local-locker_gen.go

    			if err != nil {
    				err = msgp.WrapError(err, zb0001, zb0003)
    				return
    			}
    		}
    		(*z)[zb0001] = zb0002
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z localLockMap) Msgsize() (s int) {
    	s = msgp.MapHeaderSize
    	if z != nil {
    		for zb0006, zb0007 := range z {
    			_ = zb0007
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  7. cmd/bucket-replication.go

    }
    
    const (
    	// WorkerMaxLimit max number of workers per node for "fast" mode
    	WorkerMaxLimit = 500
    
    	// WorkerMinLimit min number of workers per node for "slow" mode
    	WorkerMinLimit = 50
    
    	// WorkerAutoDefault is default number of workers for "auto" mode
    	WorkerAutoDefault = 100
    
    	// MRFWorkerMaxLimit max number of mrf workers per node for "fast" mode
    	MRFWorkerMaxLimit = 8
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  8. cmd/tier-last-day-stats_gen.go

    				if err != nil {
    					err = msgp.WrapError(err, zb0001)
    					return
    				}
    			}
    		}
    		(*z)[zb0001] = zb0002
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z DailyAllTierStats) Msgsize() (s int) {
    	s = msgp.MapHeaderSize
    	if z != nil {
    		for zb0007, zb0008 := range z {
    			_ = zb0008
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  9. cmd/admin-heal-ops.go

    	cancelCtx context.CancelFunc
    
    	// the last result index sent to client
    	lastSentResultIndex int64
    
    	// Number of total items scanned against item type
    	scannedItemsMap map[madmin.HealItemType]int64
    
    	// Number of total items healed against item type
    	healedItemsMap map[madmin.HealItemType]int64
    
    	// Number of total items where healing failed against endpoint and drive state
    	healFailedItemsMap map[string]int64
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  10. cmd/object-api-utils.go

    					const sseDAREEncPackageBlockSize = SSEDAREPackageBlockSize + SSEDAREPackageMetaSize
    					// Number of full blocks in skipped area
    					seqNum = uint32(compOff / SSEDAREPackageBlockSize)
    					// Skip this many inside a decrypted block to get to compression block start
    					decryptSkip = compOff % SSEDAREPackageBlockSize
    					// Skip this number of full blocks.
    					skipEnc := compOff / SSEDAREPackageBlockSize
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
Back to top