- Sort Score
- Result 10 results
- Languages All
Results 331 - 340 of 453 for ctx_ (0.05 sec)
-
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) -
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/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) -
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) -
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) -
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) -
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) -
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) -
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)