Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 61 for Itoa (0.02 sec)

  1. internal/config/notify/legacy.go

    		config.KV{
    			Key:   target.KafkaQueueLimit,
    			Value: strconv.Itoa(int(cfg.QueueLimit)),
    		},
    		config.KV{
    			Key:   target.KafkaTLS,
    			Value: config.FormatBool(cfg.TLS.Enable),
    		},
    		config.KV{
    			Key:   target.KafkaTLSSkipVerify,
    			Value: config.FormatBool(cfg.TLS.SkipVerify),
    		},
    		config.KV{
    			Key:   target.KafkaTLSClientAuth,
    			Value: strconv.Itoa(int(cfg.TLS.ClientAuth)),
    		},
    		config.KV{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 19 04:37:54 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  2. tests/preload_test.go

    }
    
    func TestNestedPreloadWithUnscoped(t *testing.T) {
    	user := *GetUser("nested_preload", Config{Pets: 1})
    	pet := user.Pets[0]
    	pet.Toy = Toy{Name: "toy_nested_preload_" + strconv.Itoa(1)}
    	pet.Toy = Toy{Name: "toy_nested_preload_" + strconv.Itoa(2)}
    
    	if err := DB.Create(&user).Error; err != nil {
    		t.Fatalf("errors happened when create: %v", err)
    	}
    
    	var user2 User
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 12 10:00:47 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  3. cmd/storage-rest-client.go

    	values := make(url.Values)
    	values.Set(storageRESTVolume, volume)
    	values.Set(storageRESTFilePath, path)
    	values.Set(storageRESTOffset, strconv.Itoa(int(offset)))
    	values.Set(storageRESTLength, strconv.Itoa(int(length)))
    
    	respBody, err := client.callGet(ctx, storageRESTMethodReadFileStream, values, nil, -1)
    	if err != nil {
    		return nil, toStorageErr(err)
    	}
    	return respBody, nil
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  4. tests/helper_test.go

    	for i := 0; i < config.Pets; i++ {
    		user.Pets = append(user.Pets, &Pet{Name: name + "_pet_" + strconv.Itoa(i+1)})
    	}
    
    	for i := 0; i < config.Toys; i++ {
    		user.Toys = append(user.Toys, Toy{Name: name + "_toy_" + strconv.Itoa(i+1)})
    	}
    
    	for i := 0; i < config.Tools; i++ {
    		user.Tools = append(user.Tools, Tools{Name: name + "_tool_" + strconv.Itoa(i+1)})
    	}
    
    	if config.Company {
    		user.Company = Company{Name: "company-" + name}
    	}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Mar 19 03:50:28 UTC 2024
    - 8K bytes
    - Viewed (0)
  5. cmd/generic-handlers_test.go

    func generateHeader(size, usersize int) http.Header {
    	header := http.Header{}
    	for i := 0; i < size; i++ {
    		header.Set(strconv.Itoa(i), "")
    	}
    	userlength := 0
    	for i := 0; userlength < usersize; i++ {
    		userlength += len(userMetadataKeyPrefixes[0] + strconv.Itoa(i))
    		header.Set(userMetadataKeyPrefixes[0]+strconv.Itoa(i), "")
    	}
    	return header
    }
    
    func TestIsHTTPHeaderSizeTooLarge(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  6. internal/grid/benchmark_test.go

    	"strconv"
    	"sync/atomic"
    	"testing"
    	"time"
    
    	"github.com/minio/minio/internal/logger/target/testlogger"
    )
    
    func BenchmarkRequests(b *testing.B) {
    	for n := 2; n <= 32; n *= 2 {
    		b.Run("servers="+strconv.Itoa(n), func(b *testing.B) {
    			benchmarkGridRequests(b, n)
    		})
    	}
    }
    
    func benchmarkGridRequests(b *testing.B, n int) {
    	defer testlogger.T.SetErrorTB(b)()
    	errFatal := func(err error) {
    		b.Helper()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  7. cmd/bucket-lifecycle-audit.go

    	}
    
    	// rule with NewernoncurrentVersions in effect
    	if event.NewerNoncurrentVersions > 0 {
    		tags[ilmNewerNoncurrentVersions] = strconv.Itoa(event.NewerNoncurrentVersions)
    	}
    	if event.NoncurrentDays > 0 {
    		tags[ilmNoncurrentDays] = strconv.Itoa(event.NoncurrentDays)
    	}
    	return tags
    }
    
    func newLifecycleAuditEvent(src lcEventSrc, event lifecycle.Event) lcAuditEvent {
    	return lcAuditEvent{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  8. cmd/healthcheck-handler.go

    	}
    	result := objLayer.Health(ctx, opts)
    	w.Header().Set(xhttp.MinIOWriteQuorum, strconv.Itoa(result.WriteQuorum))
    	w.Header().Set(xhttp.MinIOStorageClassDefaults, strconv.FormatBool(result.UsingDefaults))
    	// return how many drives are being healed if any
    	if result.HealingDrives > 0 {
    		w.Header().Set(xhttp.MinIOHealingDrives, strconv.Itoa(result.HealingDrives))
    	}
    	if !result.Healthy {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 26 07:44:34 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  9. internal/bucket/replication/replication.go

    			targetMap[r.Destination.Bucket] = struct{}{}
    		}
    		if err := r.Validate(bucket, sameTarget); err != nil {
    			return err
    		}
    		if _, ok := priorityMap[strconv.Itoa(r.Priority)]; ok {
    			return errReplicationUniquePriority
    		}
    		priorityMap[strconv.Itoa(r.Priority)] = struct{}{}
    
    		if r.Destination.LegacyArn() {
    			legacyArn = true
    		}
    		if c.RoleArn == "" && !r.Destination.TargetArn() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 28 17:44:56 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  10. cmd/metrics-v3-system-drive.go

    		return nil
    	}
    
    	for _, disk := range driveMetrics.storageInfo.Disks {
    		labels := []string{
    			driveL, disk.DrivePath,
    			poolIndexL, strconv.Itoa(disk.PoolIndex),
    			setIndexL, strconv.Itoa(disk.SetIndex),
    			driveIndexL, strconv.Itoa(disk.DiskIndex),
    		}
    
    		m.setDriveBasicMetrics(disk, labels)
    		if dm, found := driveMetrics.ioStats[disk.DrivePath]; found {
    			m.setDriveIOStatMetrics(dm, labels)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun May 12 17:23:50 UTC 2024
    - 7.9K bytes
    - Viewed (0)
Back to top