Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 107 for Walker (0.23 sec)

  1. cmd/tier.go

    	return valid
    }
    
    // isTierNameInUse returns tier type and true if there exists a remote tier by
    // name tierName, otherwise returns madmin.Unsupported and false. N B this
    // function is meant for internal use, where the caller is expected to take
    // appropriate locks.
    func (config *TierConfigMgr) isTierNameInUse(tierName string) (madmin.TierType, bool) {
    	if t, ok := config.Tiers[tierName]; ok {
    		return t.Type, true
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  2. internal/rest/client.go

    		// side-channel check has failed, we shall take
    		// the client offline in such situations.
    		// generally all implementations should simply return
    		// 403, but in situations where there is a dependency
    		// with the caller to take the client offline purpose
    		// fully it should make sure to respond with '412'
    		// instead, see cmd/storage-rest-server.go for ideas.
    		if c.HealthCheckFn != nil && resp.StatusCode == http.StatusPreconditionFailed {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 14.4K bytes
    - Viewed (0)
  3. cmd/erasure-metadata.go

    func (e ErasureInfo) ShardSize() int64 {
    	return ceilFrac(e.BlockSize, int64(e.DataBlocks))
    }
    
    // IsValid - tells if erasure info fields are valid.
    func (fi FileInfo) IsValid() bool {
    	if fi.Deleted {
    		// Delete marker has no data, no need to check
    		// for erasure coding information
    		return true
    	}
    	dataBlocks := fi.Erasure.DataBlocks
    	parityBlocks := fi.Erasure.ParityBlocks
    	correctIndexes := (fi.Erasure.Index > 0 &&
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  4. docs/bucket/lifecycle/README.md

    the prefix `user-uploads/` as soon as the latest object satisfies the expiration criteria. 
    
    > NOTE: If the latest object is a delete marker then filtering based on `Filter.Tags` is ignored and 
    > if the DELETE marker modTime satisfies the `Expiration.Days` then all versions of the object are 
    > immediately purged.
    
    ```
    {
        "Rules": [
            {
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Aug 26 07:33:25 GMT 2023
    - 9K bytes
    - Viewed (1)
  5. cmd/streaming-signature-v4.go

    // so they are only valid until the next bufio read.
    func readChunkLine(b *bufio.Reader) ([]byte, []byte, error) {
    	buf, err := b.ReadSlice('\n')
    	if err != nil {
    		// We always know when EOF is coming.
    		// If the caller asked for a line, there should be a line.
    		if err == io.EOF {
    			err = io.ErrUnexpectedEOF
    		} else if err == bufio.ErrBufferFull {
    			err = errLineTooLong
    		}
    		return nil, nil, err
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 18.2K bytes
    - Viewed (0)
  6. cmd/storage-rest-client.go

    		// transport is already down.
    		return "", errDiskNotFound
    	}
    
    	// This call should never be over the network, this is always
    	// a cached value - caller should make sure to use this
    	// function on a fresh disk or make sure to look at the error
    	// from a different networked call to validate the GetDiskID()
    	return *client.diskID.Load(), nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  7. internal/bucket/bandwidth/reader.go

    	if r.throttle == nil {
    		return r.r.Read(buf)
    	}
    	if r.lastErr != nil {
    		err = r.lastErr
    		return
    	}
    	b := r.throttle.Burst()  // maximum available tokens
    	need := len(buf)         // number of bytes requested by caller
    	hdr := r.opts.HeaderSize // remaining header bytes
    	var tokens int           // number of tokens to request
    
    	if hdr > 0 { // available tokens go towards header first
    		if hdr < b { // all of header can be accommodated
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Sep 06 03:21:59 GMT 2023
    - 3.1K bytes
    - Viewed (0)
  8. internal/grid/connection.go

    	if err != nil {
    		return nil, err
    	}
    	cl.subroute = &c.subID
    	return cl, nil
    }
    
    // Request allows to do a single remote request.
    // 'req' will not be used after the call and caller can reuse.
    // If no deadline is set on ctx, a 1-minute deadline will be added.
    func (c *Connection) Request(ctx context.Context, h HandlerID, req []byte) ([]byte, error) {
    	if !h.valid() {
    		return nil, ErrUnknownHandler
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  9. cmd/storage-rest-server.go

    		}
    	}()
    	err = s.getStorage().ReadMultiple(r.Context(), req, responses)
    	wg.Wait()
    	rw.CloseWithError(err)
    }
    
    // globalLocalSetDrives is used for local drive as well as remote REST
    // API caller for other nodes to talk to this node.
    //
    // Any updates to this must be serialized via globalLocalDrivesMu (locker)
    var globalLocalSetDrives [][][]StorageAPI
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  10. cmd/batch-expire.go

    //           # retainVersions: 0 # (default) delete all versions of the object. This option is the fastest.
    //           # retainVersions: 5 # keep the latest 5 versions of the object.
    //
    //     - type: deleted # objects with delete marker as their latest version
    //       name: NAME # match object names that satisfy the wildcard expression.
    //       olderThan: 10h # match objects older than this value (e.g. 7d10h31s)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 21K bytes
    - Viewed (1)
Back to top