Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for factor (0.23 sec)

  1. internal/logger/target/kafka/kafka_scram_client_contrib.go

    // each authentication attempt.
    type XDGSCRAMClient struct {
    	*scram.Client
    	*scram.ClientConversation
    	scram.HashGeneratorFcn
    }
    
    // Begin constructs a SCRAM client component based on a given hash.Hash
    // factory receiver.  This constructor will normalize the username, password
    // and authzID via the SASLprep algorithm, as recommended by RFC-5802.  If
    // SASLprep fails, the method returns an error.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.3K bytes
    - Viewed (1)
  2. internal/handlers/proxy.go

    // and heavily modified for MinIO's internal needs.
    
    package handlers
    
    import (
    	"net"
    	"net/http"
    	"regexp"
    	"strings"
    )
    
    var (
    	// De-facto standard header keys.
    	xForwardedFor    = http.CanonicalHeaderKey("X-Forwarded-For")
    	xForwardedHost   = http.CanonicalHeaderKey("X-Forwarded-Host")
    	xForwardedPort   = http.CanonicalHeaderKey("X-Forwarded-Port")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 22 00:56:55 GMT 2023
    - 5.1K bytes
    - Viewed (0)
  3. docs/debugging/hash-set/main.go

    // This function currently supports
    // - SIPMOD
    func sipHashMod(key string, cardinality int, id [16]byte) int {
    	if cardinality <= 0 {
    		return -1
    	}
    	// use the faster version as per siphash docs
    	// https://github.com/dchest/siphash#usage
    	k0, k1 := binary.LittleEndian.Uint64(id[0:8]), binary.LittleEndian.Uint64(id[8:16])
    	sum64 := siphash.Hash(k0, k1, []byte(key))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 3.7K bytes
    - Viewed (0)
  4. cmd/xl-storage.go

    		// xl.meta has "inlined data" we prefer writing O_DIRECT and then doing
    		// fdatasync() at the end instead of opening the file with O_DSYNC.
    		//
    		// This is an optimization mainly to ensure faster I/O.
    		if len(b) > xioutil.DirectioAlignSize {
    			r := bytes.NewReader(b)
    			return s.writeAllDirect(ctx, filePath, r.Size(), r, flags, skipParent)
    		}
    		w, err = s.openFileSync(filePath, flags, skipParent)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  5. cmd/data-scanner.go

    	}
    }
    
    // Sleep sleeps the specified time multiplied by the sleep factor.
    // If the factor is updated the sleep will be done again with the new factor.
    func (d *dynamicSleeper) Sleep(ctx context.Context, base time.Duration) {
    	for {
    		// Grab current values
    		d.mu.RLock()
    		minWait, maxWait := d.minSleep, d.maxSleep
    		factor := d.factor
    		cycle := d.cycle
    		d.mu.RUnlock()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  6. cmd/erasure-sets.go

    	}
    
    	return s, nil
    }
    
    // cleanup ".trash/" folder every 5m minutes with sufficient sleep cycles, between each
    // deletes a dynamic sleeper is used with a factor of 10 ratio with max delay between
    // deletes to be 2 seconds.
    func (s *erasureSets) cleanupDeletedObjects(ctx context.Context) {
    	timer := time.NewTimer(globalAPIConfig.getDeleteCleanupInterval())
    	defer timer.Stop()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
  7. internal/bucket/lifecycle/lifecycle_test.go

    			objectName:     "fooobject",
    			objectTags:     "storeforever=false&factory=true",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 53.2K bytes
    - Viewed (0)
  8. internal/event/target/kafka_scram_client_contrib.go

    // each authentication attempt.
    type XDGSCRAMClient struct {
    	*scram.Client
    	*scram.ClientConversation
    	scram.HashGeneratorFcn
    }
    
    // Begin constructs a SCRAM client component based on a given hash.Hash
    // factory receiver.  This constructor will normalize the username, password
    // and authzID via the SASLprep algorithm, as recommended by RFC-5802.  If
    // SASLprep fails, the method returns an error.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.2K bytes
    - Viewed (0)
Back to top