- Sort Score
- Result 10 results
- Languages All
Results 281 - 290 of 391 for ctx_ (0.03 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)