Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1321 - 1330 of 1,605 for var1 (0.08 sec)

  1. cmd/warm-backend-s3.go

    	case conf.Bucket == "":
    		return nil, errors.New("no bucket name was provided")
    	}
    
    	// Credentials initialization
    	var creds *credentials.Credentials
    	switch {
    	case conf.AWSRole:
    		creds = credentials.New(&credentials.IAM{
    			Client: &http.Client{
    				Transport: NewHTTPTransport(),
    			},
    		})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  2. internal/config/scanner/scanner.go

    	// MaxWait is maximum wait time between operations
    	MaxWait time.Duration
    	// Cycle is the time.Duration between each scanner cycles
    	Cycle time.Duration
    }
    
    // DefaultKVS - default KV config for heal settings
    var DefaultKVS = config.KVS{
    	config.KV{
    		Key:   Speed,
    		Value: "default",
    	},
    	config.KV{
    		Key:           IdleSpeed,
    		Value:         "",
    		HiddenIfEmpty: true,
    	},
    	config.KV{
    		Key:   ExcessVersions,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  3. internal/bucket/lifecycle/rule_test.go

    	                    </Rule>`,
    			expectedErr: errInvalidRuleDelMarkerExpiration,
    		},
    	}
    
    	for i, tc := range invalidTestCases {
    		t.Run(fmt.Sprintf("Test %d", i+1), func(t *testing.T) {
    			var rule Rule
    			err := xml.Unmarshal([]byte(tc.inputXML), &rule)
    			if err != nil {
    				t.Fatal(err)
    			}
    
    			if err := rule.Validate(); err != tc.expectedErr {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  4. cmd/dynamic-timeouts_test.go

    		t.Errorf("Failure to decrease timeout appropriately")
    	}
    }
    
    func TestDynamicTimeoutConcurrent(t *testing.T) {
    	// Race test.
    	timeout := newDynamicTimeout(time.Second, time.Millisecond)
    	var wg sync.WaitGroup
    	for i := 0; i < runtime.GOMAXPROCS(0); i++ {
    		wg.Add(1)
    		rng := rand.New(rand.NewSource(int64(i)))
    		go func() {
    			defer wg.Done()
    			for i := 0; i < 100; i++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 14 10:08:40 UTC 2022
    - 5.4K bytes
    - Viewed (0)
  5. internal/mountinfo/mountinfo_linux.go

    func (mts mountInfos) checkCrossMounts(path string) error {
    	if !filepath.IsAbs(path) {
    		return fmt.Errorf("Invalid argument, path (%s) is expected to be absolute", path)
    	}
    	var crossMounts mountInfos
    	for _, mount := range mts {
    		// Add a separator to indicate that this is a proper mount-point.
    		// This is to avoid a situation where prefix is '/tmp/fsmount'
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.7K bytes
    - Viewed (0)
  6. cmd/object-api-putobject_test.go

    	err = obj.MakeBucket(context.Background(), "unused-bucket", MakeBucketOptions{})
    	if err != nil {
    		// Failed to create newbucket, abort.
    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    	var (
    		nilBytes    []byte
    		data        = []byte("hello")
    		fiveMBBytes = bytes.Repeat([]byte("a"), 5*humanize.MiByte)
    	)
    	invalidMD5 := getMD5Hash([]byte("meh"))
    	invalidMD5Header := md5Header([]byte("meh"))
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  7. cmd/format-erasure.go

    		drives += len(set)
    	}
    	return drives
    }
    
    func (f *formatErasureV3) Clone() *formatErasureV3 {
    	b, err := json.Marshal(f)
    	if err != nil {
    		panic(err)
    	}
    	var dst formatErasureV3
    	if err = json.Unmarshal(b, &dst); err != nil {
    		panic(err)
    	}
    	return &dst
    }
    
    // Returns formatErasure.Erasure.Version
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  8. cmd/metrics-v3-bucket-replication.go

    	bucketL                                        = "bucket"
    	operationL                                     = "operation"
    	targetArnL                                     = "targetArn"
    )
    
    var (
    	bucketReplLastHrFailedBytesMD = NewGaugeMD(bucketReplLastHrFailedBytes,
    		"Total number of bytes failed at least once to replicate in the last hour on a bucket",
    		bucketL)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  9. cmd/metrics-v3-system-process.go

    	processResidentMemoryBytes      = "resident_memory_bytes"
    	processVirtualMemoryBytes       = "virtual_memory_bytes"
    	processVirtualMemoryMaxBytes    = "virtual_memory_max_bytes"
    )
    
    var (
    	processLocksReadTotalMD           = NewGaugeMD(processLocksReadTotal, "Number of current READ locks on this peer")
    	processLocksWriteTotalMD          = NewGaugeMD(processLocksWriteTotal, "Number of current WRITE locks on this peer")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jun 20 17:55:03 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  10. internal/http/transports.go

    package http
    
    import (
    	"context"
    	"crypto/tls"
    	"crypto/x509"
    	"net/http"
    	"syscall"
    	"time"
    
    	"github.com/minio/pkg/v3/certs"
    )
    
    // tlsClientSessionCacheSize is the cache size for client sessions.
    var tlsClientSessionCacheSize = 100
    
    const (
    	WriteBufferSize = 64 << 10 // WriteBufferSize 64KiB moving up from 4KiB default
    	ReadBufferSize  = 64 << 10 // ReadBufferSize 64KiB moving up from 4KiB default
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
Back to top