Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 391 for ctx_ (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. internal/config/notify/parse.go

    	xnet "github.com/minio/pkg/v3/net"
    )
    
    const (
    	formatNamespace = "namespace"
    )
    
    const (
    	logSubsys = "notify"
    )
    
    func logOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) {
    	logger.LogOnceIf(ctx, logSubsys, err, id, errKind...)
    }
    
    // ErrTargetsOffline - Indicates single/multiple target failures.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 47K bytes
    - Viewed (0)
  8. docs/extensions/fan-out/README.md

    Fan-Out uploads are automatically enabled if `x-minio-fanout-list` form-field is provided with the PostUpload API, to keep things simple higher level APIs are provided in our SDKs for example in `minio-go` SDK:
    
    ```
    PutObjectFanOut(ctx context.Context, bucket string, fanOutContent io.Reader, fanOutReq minio.PutObjectFanOutRequest) ([]minio.PutObjectFanOutResponse, error)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 25 05:51:07 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  9. cmd/metrics-v2.go

    		metricsGroupOpts: opts,
    	}
    	mg.RegisterRead(func(ctx context.Context) (metrics []MetricV2) {
    		objLayer := newObjectLayerFn()
    		if objLayer == nil {
    			return
    		}
    
    		metrics = make([]MetricV2, 0, 50)
    		dataUsageInfo, err := loadDataUsageFromBackend(ctx, objLayer)
    		if err != nil {
    			metricsLogIf(ctx, err)
    			return
    		}
    
    		// data usage has not captured any data yet.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  10. cmd/sts-errors.go

    import (
    	"context"
    	"encoding/xml"
    	"net/http"
    
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    )
    
    // writeSTSErrorResponse writes error headers
    func writeSTSErrorResponse(ctx context.Context, w http.ResponseWriter, errCode STSErrorCode, err error) {
    	stsErr := stsErrCodes.ToSTSErr(errCode)
    
    	// Generate error response.
    	stsErrorResponse := STSErrorResponse{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 5.8K bytes
    - Viewed (0)
Back to top