Search Options

Results per page
Sort
Preferred Languages
Advance

Results 331 - 340 of 453 for ctx_ (0.05 sec)

  1. cmd/metacache-manager.go

    // checkMetacacheState should be used if data is not updating.
    // Should only be called if a failure occurred.
    func (o listPathOptions) checkMetacacheState(ctx context.Context, rpc *peerRESTClient) error {
    	// We operate on a copy...
    	o.Create = false
    	c, err := rpc.GetMetacacheListing(ctx, o)
    	if err != nil {
    		return err
    	}
    	cache := *c
    
    	if cache.status == scanStateNone || cache.fileNotFound {
    		return errFileNotFound
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 5.2K bytes
    - Viewed (0)
  2. internal/config/identity/openid/providercfg.go

    // claims available from the UserInfo endpoint
    func (p *providerCfg) UserInfo(ctx context.Context, accessToken string, transport http.RoundTripper) (map[string]interface{}, error) {
    	if p.JWKS.URL == nil || p.JWKS.URL.String() == "" {
    		return nil, errors.New("openid not configured")
    	}
    
    	req, err := http.NewRequestWithContext(ctx, http.MethodPost, p.DiscoveryDoc.UserInfoEndpoint, nil)
    	if err != nil {
    		return nil, err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. internal/s3select/progress.go

    				return nil, errInvalidCompression(err, compType)
    			}
    			return nil, errTruncatedInput(err)
    		}
    		r = gzr
    		pr.closer = gzr
    	case bzip2Type:
    		ctx, cancel := context.WithCancel(context.Background())
    		r = pbzip2.NewReader(ctx, scannedReader, pbzip2.DecompressionOptions(
    			pbzip2.BZConcurrency((runtime.GOMAXPROCS(0)+1)/2),
    			pbzip2.BZConcurrencyPool(bz2Limiter),
    		))
    		pr.closer = &nopReadCloser{fn: cancel}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  4. cmd/bucket-replication-stats.go

    	}
    }
    
    func (r *ReplicationStats) collectWorkerMetrics(ctx context.Context) {
    	if r == nil {
    		return
    	}
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-r.wTimer.C:
    			r.wlock.Lock()
    			r.workers.update()
    			r.wlock.Unlock()
    
    		}
    	}
    }
    
    func (r *ReplicationStats) collectQueueMetrics(ctx context.Context) {
    	if r == nil {
    		return
    	}
    
    	for {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  5. internal/http/server.go

    	srv.TLSConfig = cfg
    	return srv
    }
    
    // UseBaseContext use custom base context for this HTTP *Server
    func (srv *Server) UseBaseContext(ctx context.Context) *Server {
    	srv.BaseContext = func(listener net.Listener) context.Context {
    		return ctx
    	}
    	return srv
    }
    
    // UseCustomLogger use customized logger for this HTTP *Server
    func (srv *Server) UseCustomLogger(l *log.Logger) *Server {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  6. cmd/rebalance-admin.go

    }
    
    func rebalanceStatus(ctx context.Context, z *erasureServerPools) (r rebalanceAdminStatus, err error) {
    	// Load latest rebalance status
    	meta := &rebalanceMeta{}
    	err = meta.load(ctx, z.serverPools[0])
    	if err != nil {
    		return r, err
    	}
    
    	// Compute disk usage percentage
    	si := z.StorageInfo(ctx, true)
    	diskStats := make([]struct {
    		AvailableSpace uint64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Dec 22 00:56:43 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  7. internal/kms/secret-key.go

    type secretKey struct {
    	keyID string
    	key   []byte
    }
    
    // Version returns the version of the builtin KMS.
    func (secretKey) Version(ctx context.Context) (string, error) { return "v1", nil }
    
    // APIs returns an error since the builtin KMS does not provide a list of APIs.
    func (secretKey) APIs(ctx context.Context) ([]madmin.KMSAPI, error) {
    	return nil, ErrNotSupported
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  8. tests/test_annotated.py

            IsDict(
                {
                    "ctx": {"min_length": 1},
                    "loc": ["query", "foo"],
                    "msg": "String should have at least 1 character",
                    "type": "string_too_short",
                    "input": "",
                }
            )
            # TODO: remove when deprecating Pydantic v1
            | IsDict(
                {
                    "ctx": {"limit_value": 1},
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  9. cmd/erasure-healing-common.go

    			// parts. This is considered an outdated disk, since
    			// it needs healing too.
    			verifyResp, verifyErr = onlineDisk.VerifyFile(ctx, bucket, object, meta)
    		default:
    			verifyResp, verifyErr = onlineDisk.CheckParts(ctx, bucket, object, meta)
    		}
    
    		for p := range latestMeta.Parts {
    			if verifyErr != nil {
    				dataErrsByPart[p][i] = convPartErrToInt(verifyErr)
    			} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  10. src/cmd/asm/internal/asm/operand_test.go

    	if architecture == nil {
    		panic("asm: unrecognized architecture " + goarch)
    	}
    	ctxt := obj.Linknew(architecture.LinkArch)
    	ctxt.Pkgpath = "pkg"
    	return architecture, ctxt
    }
    
    func newParser(goarch string) *Parser {
    	architecture, ctxt := setArch(goarch)
    	return NewParser(ctxt, architecture, nil)
    }
    
    // tryParse executes parse func in panicOnError=true context.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 29 18:31:05 UTC 2023
    - 23.9K bytes
    - Viewed (0)
Back to top