Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 1,214 for Func (0.04 sec)

  1. cmd/background-heal-ops.go

    type healRoutine struct {
    	tasks   chan healTask
    	workers int
    }
    
    func activeListeners() int {
    	// Bucket notification and http trace are not costly, it is okay to ignore them
    	// while counting the number of concurrent connections
    	return int(globalHTTPListen.Subscribers()) + int(globalTrace.Subscribers())
    }
    
    func waitForLowIO(maxIO int, maxWait time.Duration, currentIO func() int) {
    	// No need to wait run at full speed.
    	if maxIO <= 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  2. api/go1.9.txt

    pkg math/bits, func OnesCount(uint) int
    pkg math/bits, func OnesCount16(uint16) int
    pkg math/bits, func OnesCount32(uint32) int
    pkg math/bits, func OnesCount64(uint64) int
    pkg math/bits, func OnesCount8(uint8) int
    pkg math/bits, func Reverse(uint) uint
    pkg math/bits, func Reverse16(uint16) uint16
    pkg math/bits, func Reverse32(uint32) uint32
    pkg math/bits, func Reverse64(uint64) uint64
    pkg math/bits, func Reverse8(uint8) uint8
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 04 20:20:20 UTC 2021
    - 10.7K bytes
    - Viewed (0)
  3. cmd/warm-backend-azure.go

    	Bucket       string
    	Prefix       string
    	StorageClass string
    }
    
    func (az *warmBackendAzure) tier() *blob.AccessTier {
    	if az.StorageClass == "" {
    		return nil
    	}
    	for _, t := range blob.PossibleAccessTierValues() {
    		if strings.EqualFold(az.StorageClass, string(t)) {
    			return &t
    		}
    	}
    	return nil
    }
    
    func (az *warmBackendAzure) getDest(object string) string {
    	destObj := object
    	if az.Prefix != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 7K bytes
    - Viewed (0)
  4. internal/bucket/lifecycle/expiration.go

    	return nil
    }
    
    // IsDaysNull returns true if days field is null
    func (e Expiration) IsDaysNull() bool {
    	return e.Days == ExpirationDays(0)
    }
    
    // IsDateNull returns true if date field is null
    func (e Expiration) IsDateNull() bool {
    	return e.Date.Time.IsZero()
    }
    
    // IsNull returns true if both date and days fields are null
    func (e Expiration) IsNull() bool {
    	return e.IsDaysNull() && e.IsDateNull()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Feb 21 20:28:34 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  5. internal/http/transports.go

    // only supports HTTP/1.1
    func (s ConnSettings) NewCustomHTTPProxyTransport() func() *http.Transport {
    	s.EnableHTTP2 = false
    	tr := s.getDefaultTransport(0)
    
    	// Settings specific to proxied requests.
    	tr.ResponseHeaderTimeout = 30 * time.Minute
    
    	return func() *http.Transport {
    		return tr
    	}
    }
    
    // NewHTTPTransportWithTimeout allows setting a timeout for response headers
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  6. internal/etag/reader.go

    }
    
    // Write -  implement hash.Hash Write
    func (u UUIDHash) Write(p []byte) (n int, err error) {
    	return len(p), nil
    }
    
    // Sum -  implement md5.Sum
    func (u UUIDHash) Sum(b []byte) []byte {
    	return u.uuid
    }
    
    // Reset -  implement hash.Hash Reset
    func (u UUIDHash) Reset() {
    	return
    }
    
    // Size -  implement hash.Hash Size
    func (u UUIDHash) Size() int {
    	return len(u.uuid)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  7. internal/event/targetlist_test.go

    	sendErr  bool
    	closeErr bool
    }
    
    func (target ExampleTarget) ID() TargetID {
    	return target.id
    }
    
    // Save - Sends event directly without persisting.
    func (target ExampleTarget) Save(eventData Event) error {
    	return target.send(eventData)
    }
    
    // Store - Returns a nil store.
    func (target ExampleTarget) Store() TargetStore {
    	return nil
    }
    
    func (target ExampleTarget) send(eventData Event) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  8. cmd/encryption-v1_test.go

    		t.Fatalf("Test: expected %d, got %d", 1, partStart)
    	}
    }
    
    func TestGetDecryptedRange(t *testing.T) {
    	var (
    		pkgSz     = int64(64) * humanize.KiByte
    		minPartSz = int64(5) * humanize.MiByte
    		maxPartSz = int64(5) * humanize.GiByte
    
    		getEncSize = func(s int64) int64 {
    			v, _ := sio.EncryptedSize(uint64(s))
    			return int64(v)
    		}
    		udMap = func(isMulti bool) map[string]string {
    			m := map[string]string{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 24 04:17:08 UTC 2022
    - 19.9K bytes
    - Viewed (0)
  9. internal/etag/etag.go

    //
    // The returned string is a hex representation of the
    // binary ETag with an optional '-<part-number>' suffix.
    func (e ETag) String() string {
    	if e.IsMultipart() {
    		return hex.EncodeToString(e[:16]) + string(e[16:])
    	}
    	return hex.EncodeToString(e)
    }
    
    // IsEncrypted reports whether the ETag is encrypted.
    func (e ETag) IsEncrypted() bool {
    	// An encrypted ETag must be at least 32 bytes long.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 21:09:36 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  10. cmd/object-api-utils_test.go

    	return rs
    }
    
    func benchmark(b *testing.B, data []string) {
    	b.Run("concat naive", func(b *testing.B) {
    		b.ResetTimer()
    		b.ReportAllocs()
    		for i := 0; i < b.N; i++ {
    			concatNaive(data...)
    		}
    	})
    	b.Run("concat fast", func(b *testing.B) {
    		b.ResetTimer()
    		b.ReportAllocs()
    		for i := 0; i < b.N; i++ {
    			concat(data...)
    		}
    	})
    }
    
    func BenchmarkConcatImplementation(b *testing.B) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 24.1K bytes
    - Viewed (0)
Back to top