Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for populate (0.15 sec)

  1. .gitignore

    docs/debugging/hash-set/hash-set
    docs/debugging/healing-bin/healing-bin
    docs/debugging/inspect/inspect
    docs/debugging/pprofgoparser/pprofgoparser
    docs/debugging/reorder-disks/reorder-disks
    docs/debugging/populate-hard-links/populate-hardlinks
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 29 23:52:41 GMT 2023
    - 707 bytes
    - Viewed (0)
  2. internal/config/identity/openid/jwt.go

    	pCfg, ok := r.arnProviderCfgsMap[arn]
    	if !ok {
    		return fmt.Errorf("Role %s does not exist", arn)
    	}
    
    	jwtToken, err := jp.ParseWithClaims(token, &claims, keyFuncCallback)
    	if err != nil {
    		// Re-populate the public key in-case the JWKS
    		// pubkeys are refreshed
    		if err = r.PopulatePublicKey(arn); err != nil {
    			return err
    		}
    		jwtToken, err = jwtgo.ParseWithClaims(token, &claims, keyFuncCallback)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 16 04:42:31 GMT 2023
    - 8.3K bytes
    - Viewed (5)
  3. internal/bpool/bpool.go

    	}
    	return &BytePoolCap{
    		c:    make(chan []byte, maxSize),
    		w:    width,
    		wcap: capwidth,
    	}
    }
    
    // Populate - populates and pre-warms the byte pool, this function is non-blocking.
    func (bp *BytePoolCap) Populate() {
    	for _, buf := range reedsolomon.AllocAligned(cap(bp.c), bp.wcap) {
    		bp.Put(buf[:bp.w])
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 2.6K bytes
    - Viewed (0)
  4. cmd/auth-handler.go

    		if err != nil {
    			authZLogIf(ctx, err, logger.ErrorKind)
    			return ErrMalformedXML
    		}
    
    		// Populate payload to extract location constraint.
    		r.Body = io.NopCloser(bytes.NewReader(payload))
    		region, s3Err = parseLocationConstraint(r)
    		if s3Err != ErrNone {
    			return s3Err
    		}
    
    		// Populate payload again to handle it in HTTP handler.
    		r.Body = io.NopCloser(bytes.NewReader(payload))
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 26K bytes
    - Viewed (0)
  5. cmd/update-notifier.go

    	// color characters, the result is incorrect.
    	line1Length := len(fmt.Sprintf(msgLine1Fmt, newerThan))
    	line2Length := len(fmt.Sprintf(msgLine2Fmt, updateString))
    
    	// Populate lines with color coding.
    	line1InColor := fmt.Sprintf(msgLine1Fmt, color.YellowBold(newerThan))
    	line2InColor := fmt.Sprintf(msgLine2Fmt, color.CyanBold(updateString))
    
    	// calculate the rectangular box size.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Mar 09 03:07:08 GMT 2024
    - 3.6K bytes
    - Viewed (0)
  6. docs/metrics/prometheus/list.md

    Metrics marked as ``Site Replication Only`` only populate on deployments with [Site Replication](https://min.io/docs/minio/linux/operations/install-deploy-manage/multi-site-replication.html) configurations.
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 43.4K bytes
    - Viewed (2)
  7. cmd/erasure-server-pool.go

    	}
    
    	// Initialize byte pool once for all sets, bpool size is set to
    	// setCount * setDriveCount with each memory upto blockSizeV2.
    	buffers := bpool.NewBytePoolCap(n, blockSizeV2, blockSizeV2*2)
    	buffers.Populate()
    	globalBytePoolCap.Store(buffers)
    
    	var localDrives []StorageAPI
    	local := endpointServerPools.FirstLocal()
    	for i, ep := range endpointServerPools {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  8. cmd/metrics-v2.go

    	dependGlobalLockServer          bool
    	dependGlobalIsDistErasure       bool
    	dependGlobalBackgroundHealState bool
    	dependBucketTargetSys           bool
    }
    
    // RegisterRead register the metrics populator function to be used
    // to populate new values upon cache invalidation.
    func (g *MetricsGroupV2) RegisterRead(read func(context.Context) []MetricV2) {
    	g.metricsCache = cachevalue.NewFromFunc(g.cacheInterval,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  9. cmd/streaming-signature-v4.go

    		}
    		cr.err = errMalformedEncoding
    		return n, cr.err
    	}
    
    	cr.offset = copy(buf, cr.buffer)
    	n += cr.offset
    	return n, err
    }
    
    // readTrailers will read all trailers and populate cr.trailers with actual values.
    func (cr *s3ChunkedReader) readTrailers() error {
    	if cr.debug {
    		fmt.Printf("pre trailer sig: %s\n", cr.seedSignature)
    	}
    	var valueBuffer bytes.Buffer
    	// Read value
    	for {
    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)
  10. cmd/metacache-entries.go

    		case <-ctxDone:
    			return ctx.Err()
    		case entry, ok := <-in[idx]:
    			if !ok {
    				top[idx] = nil
    				nDone++
    			} else {
    				top[idx] = &entry
    			}
    		}
    		return nil
    	}
    	// Populate all...
    	for i := range in {
    		if err := selectFrom(i); err != nil {
    			return err
    		}
    	}
    	last := ""
    	var toMerge []int
    
    	// Choose the best to return.
    	for {
    		if nDone == len(in) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 23.2K bytes
    - Viewed (0)
Back to top