Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for laking (0.22 sec)

  1. cmd/mrf.go

    				}
    				if wildcard.Match("tmp-old/*", u.object) {
    					continue
    				}
    			}
    
    			now := time.Now()
    			if now.Sub(u.queued) < time.Second {
    				// let recently failed networks to reconnect
    				// making MRF wait for 1s before retrying,
    				// i.e 4 reconnect attempts.
    				time.Sleep(time.Second)
    			}
    
    			// wait on timer per heal
    			wait := healSleeper.Timer(context.Background())
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  2. README.fips.md

    executables are available at <http://dl.min.io> - they are only published for `linux-amd64` architecture as binary files with the suffix `.fips`. We also publish corresponding container images to our official image repositories.
    
    We are not making any statements or representations about the suitability of this code or build in relation to the FIPS 140-2 standard. Interested users will have to evaluate for themselves whether this is useful for their own purposes....
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Jul 17 15:43:14 GMT 2022
    - 869 bytes
    - Viewed (0)
  3. docs/erasure/README.md

    ## What is Bit Rot protection?
    
    Bit Rot, also known as data rot or silent data corruption is a data loss issue faced by disk drives today. Data on the drive may silently get corrupted without signaling an error has occurred, making bit rot more dangerous than a permanent hard drive failure.
    
    MinIO's erasure coded backend uses high speed [HighwayHash](https://github.com/minio/highwayhash) checksums to protect against Bit Rot.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 4.1K bytes
    - Viewed (0)
  4. internal/handlers/proxy.go

    		s := strings.Index(fwd, ", ")
    		if s == -1 {
    			s = len(fwd)
    		}
    		addr = fwd[:s]
    	} else if fwd := r.Header.Get(xRealIP); fwd != "" {
    		// X-Real-IP should only contain one IP address (the client making the
    		// request).
    		addr = fwd
    	} else if fwd := r.Header.Get(forwarded); fwd != "" {
    		// match should contain at least two elements if the protocol was
    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)
  5. internal/s3select/csv/reader.go

    		// Move to next block
    		item, ok := <-r.queue
    		if !ok {
    			r.err = io.EOF
    			return nil, r.err
    		}
    		//nolint:staticcheck // SA6002 Using pointer would allocate more since we would have to copy slice header before taking a pointer.
    		r.csvDstPool.Put(r.current)
    		r.current = <-item.dst
    		r.err = item.err
    		r.recordsRead = 0
    	}
    	csvRecord := r.current[r.recordsRead]
    	r.recordsRead++
    
    	// If no column names are set, use _(index)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  6. internal/config/identity/openid/providercfg.go

    // UserInfo returns claims for authenticated user from userInfo endpoint.
    //
    // Some OIDC implementations such as GitLab do not support
    // claims as part of the normal oauth2 flow, instead rely
    // on service providers making calls to IDP to fetch additional
    // claims available from the UserInfo endpoint
    func (p *providerCfg) UserInfo(ctx context.Context, accessToken string, transport http.RoundTripper) (map[string]interface{}, error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  7. internal/cachevalue/cache.go

    // `.TnitOnce`.
    func New[T any]() *Cache[T] {
    	return &Cache[T]{}
    }
    
    // NewFromFunc allocates a new cached value instance and initializes it with an
    // update function, making it ready for use.
    func NewFromFunc[T any](ttl time.Duration, opts Opts, update func() (T, error)) *Cache[T] {
    	return &Cache[T]{
    		ttl:      ttl,
    		updateFn: update,
    		opts:     opts,
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  8. internal/s3select/json/preader.go

    		// Move to next block
    		item, ok := <-r.queue
    		if !ok {
    			r.err = io.EOF
    			return nil, r.err
    		}
    		//nolint:staticcheck // SA6002 Using pointer would allocate more since we would have to copy slice header before taking a pointer.
    		r.kvDstPool.Put(r.current)
    		r.current = <-item.dst
    		r.err = item.err
    		r.recordsRead = 0
    	}
    	kvRecord := r.current[r.recordsRead]
    	r.recordsRead++
    
    	dstRec, ok := dst.(*Record)
    	if !ok {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 05 04:57:35 GMT 2023
    - 6.4K bytes
    - Viewed (0)
  9. cmd/shared-lock.go

    				// if one lock lost quorum due to cluster instability
    				// in that case, try to lock again.
    				break keepLock
    			case ld.lockContext <- lkctx:
    				// Send the lock context to anyone asking for it
    			}
    		}
    	}
    }
    
    func mergeContext(ctx1, ctx2 context.Context) (context.Context, context.CancelFunc) {
    	ctx, cancel := context.WithCancel(context.Background())
    	go func() {
    		select {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 13 09:26:38 GMT 2023
    - 2.3K bytes
    - Viewed (0)
  10. docs/distributed/DECOMMISSION.md

    - On Operator based MinIO deployments, you need to modify the `tenant.yaml` specification and modify the `pools:` section from two entries to a single entry. After making relevant changes, proceed to execute `kubectl apply -f tenant.yaml`.
    
    > Without a 'Complete' status any 'Active' or 'Draining' pool(s) are not allowed to be removed once configured.
    
    ## NOTE
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jul 11 14:59:49 GMT 2022
    - 8.3K bytes
    - Viewed (0)
Back to top