Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 117 for Float64 (0.47 sec)

  1. cmd/metrics-v3-types.go

    }
    
    // SetHistogramValues - sets values for the given MetricName using the provided map of
    // range to value.
    func SetHistogramValues[V uint64 | int64 | float64](m MetricValues, name MetricName, values map[string]V, labels ...string) {
    	for rng, val := range values {
    		m.Set(name, float64(val), append(labels, rangeL, rng)...)
    	}
    }
    
    // MetricsLoaderFn - represents a function to load metrics from the
    // metricsCache.
    //
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Feb 28 19:33:08 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  2. cmd/site-replication-utils.go

    	// Run the site resync metrics load in a loop
    	for {
    		if err := sm.load(ctx, newObjectLayerFn()); err == nil {
    			<-ctx.Done()
    			return
    		}
    		duration := max(time.Duration(r.Float64()*float64(time.Second*10)),
    			// Make sure to sleep at least a second to avoid high CPU ticks.
    			time.Second)
    		time.Sleep(duration)
    	}
    }
    
    // load resync metrics saved on disk into memory
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  3. internal/dsync/drwmutex.go

    		ctx, done := context.WithTimeout(ctx, drwMutexUnlockCallTimeout)
    		defer done()
    		for !releaseAll(ctx, dm.clnt, tolerance, owner, &locks, isReadLock, restClnts, dm.Names...) {
    			time.Sleep(time.Duration(dm.rng.Float64() * float64(dm.lockRetryMinInterval)))
    			if time.Since(started) > dm.clnt.Timeouts.UnlockCall {
    				return
    			}
    		}
    	}()
    }
    
    // RUnlock releases a read lock held on dm.
    //
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.3K bytes
    - Viewed (0)
  4. internal/s3select/jstream/decoder.go

    func (d *Decoder) number() (float64, error) {
    	d.scratch.reset()
    
    	var (
    		c       = d.cur()
    		n       float64
    		isFloat bool
    	)
    
    	// digits first
    	switch {
    	case c == '0':
    		d.scratch.add(c)
    		c = d.next()
    	case '1' <= c && c <= '9':
    		for ; c >= '0' && c <= '9'; c = d.next() {
    			n = 10*n + float64(c-'0')
    			d.scratch.add(c)
    		}
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.4K bytes
    - Viewed (0)
  5. internal/amztime/iso8601_time.go

    )
    
    // ISO8601Format converts time 't' into ISO8601 time format expected in AWS S3 spec.
    //
    // This function is needed to avoid a Go's float64 precision bug, where Go avoids
    // padding the extra '0' before the timezone.
    func ISO8601Format(t time.Time) string {
    	value := t.Format(iso8601TimeFormat)
    	if len(value) < len(iso8601TimeFormat) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Jan 16 23:38:33 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  6. tests/migrate_test.go

    	type MigrateNullableColumn struct {
    		ID    uint
    		Bonus float64 `gorm:"not null"`
    		Stock float64
    	}
    
    	DB.Migrator().DropTable(&MigrateNullableColumn{})
    
    	DB.AutoMigrate(&MigrateNullableColumn{})
    
    	type MigrateNullableColumn2 struct {
    		ID    uint
    		Bonus float64
    		Stock float64 `gorm:"not null"`
    	}
    
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Wed Aug 20 04:51:17 UTC 2025
    - 65.2K bytes
    - Viewed (0)
  7. cmd/benchmark-utils_test.go

    	b.ReportAllocs()
    	// the actual benchmark for PutObjectPart starts here. Reset the benchmark timer.
    
    	for i := 0; b.Loop(); i++ {
    		// insert the object.
    		totalPartsNR := int(math.Ceil(float64(objSize) / float64(partSize)))
    		for j := range totalPartsNR {
    			if j < totalPartsNR-1 {
    				textPartData = textData[j*partSize : (j+1)*partSize-1]
    			} else {
    				textPartData = textData[j*partSize:]
    			}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  8. logger/slog.go

    	if l.LogLevel <= Silent {
    		return
    	}
    
    	elapsed := time.Since(begin)
    	sql, rows := fc()
    	fields := []slog.Attr{
    		slog.String("duration", fmt.Sprintf("%.3fms", float64(elapsed.Nanoseconds())/1e6)),
    		slog.String("sql", sql),
    	}
    
    	if rows != -1 {
    		fields = append(fields, slog.Int64("rows", rows))
    	}
    
    	switch {
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Thu Oct 30 10:56:26 UTC 2025
    - 2.9K bytes
    - Viewed (0)
  9. cmd/server-main.go

    			}
    			return nil
    		}
    
    		if configRetriableErrors(err) {
    			logger.Info("Waiting for all MinIO sub-systems to be initialized.. possible cause (%v)", err)
    			time.Sleep(time.Duration(r.Float64() * float64(5*time.Second)))
    			continue
    		}
    
    		// Any other unhandled return right here.
    		return fmt.Errorf("Unable to initialize sub-systems: %w", err)
    	}
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:18:36 UTC 2025
    - 35.9K bytes
    - Viewed (4)
  10. cmd/batch-handlers.go

    			ri.Bucket = ""
    			ri.Object = ""
    			ri.Objects = 0
    			ri.BytesFailed = 0
    			ri.BytesTransferred = 0
    			retry = true // indicate we are retrying..
    			time.Sleep(delay + time.Duration(rnd.Float64()*float64(delay)))
    			continue
    		}
    
    		break
    	}
    
    	return nil
    }
    
    // toObjectInfo converts minio.ObjectInfo to ObjectInfo
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (1)
Back to top