- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 677 for Contexto (0.22 sec)
-
cmd/auth-handler.go
_, _, s3Err = checkRequestAuthTypeCredential(ctx, r, action) return s3Err } func authenticateRequest(ctx context.Context, r *http.Request, action policy.Action) (s3Err APIErrorCode) { if logger.GetReqInfo(ctx) == nil { bugLogIf(ctx, errors.New("unexpected context.Context does not have a logger.ReqInfo"), logger.ErrorKind) return ErrAccessDenied } var cred auth.Credentials var owner bool switch getRequestAuthType(r) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Sep 17 16:45:46 UTC 2024 - 26.1K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
func (lm *LRWMutex) lockLoop(ctx context.Context, id, source string, timeout time.Duration, isWriteLock bool) (locked bool) { r := rand.New(rand.NewSource(time.Now().UnixNano())) retryCtx, cancel := context.WithTimeout(ctx, timeout) defer cancel() for { select { case <-retryCtx.Done(): // Caller context canceled or we timedout, // return false anyways for both situations.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Jan 02 17:15:06 UTC 2022 - 4.8K bytes - Viewed (0) -
cmd/generic-handlers.go
} } sr, err := globalDNSConfig.Get(bucket) if err != nil { defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r)) if err == dns.ErrNoEntriesFound { writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(ErrNoSuchBucket), r.URL) } else { writeErrorResponse(r.Context(), w, toAPIError(r.Context(), err), r.URL) } return }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 20.5K bytes - Viewed (0) -
tests/tracer_test.go
} func (S Tracer) Warn(ctx context.Context, s string, i ...interface{}) { S.Logger.Warn(ctx, s, i...) } func (S Tracer) Error(ctx context.Context, s string, i ...interface{}) { S.Logger.Error(ctx, s, i...) } func (S Tracer) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error) { S.Logger.Trace(ctx, begin, fc, err) S.Test(ctx, begin, fc, err)
Registered: Sun Oct 27 09:35:08 UTC 2024 - Last Modified: Tue Oct 18 09:28:06 UTC 2022 - 830 bytes - Viewed (0) -
cmd/object-api-input-checks.go
func checkGetObjArgs(ctx context.Context, bucket, object string) error { return checkBucketAndObjectNames(ctx, bucket, object) } // Checks on DeleteObject arguments, bucket and object. func checkDelObjArgs(ctx context.Context, bucket, object string) error { return checkBucketAndObjectNames(ctx, bucket, object) } // Checks bucket and object name validity, returns nil if both are valid.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 5.7K bytes - Viewed (0) -
internal/crypto/sse-kms.go
// and the KMS context on success. func (ssekms) ParseHTTP(h http.Header) (string, kms.Context, error) { if h == nil { return "", nil, ErrInvalidEncryptionMethod } algorithm := h.Get(xhttp.AmzServerSideEncryption) if algorithm != xhttp.AmzEncryptionKMS { return "", nil, ErrInvalidEncryptionMethod } var ctx kms.Context if context, ok := h[xhttp.AmzServerSideEncryptionKmsContext]; ok {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 8.5K bytes - Viewed (0) -
cmd/storage-rest-client.go
func (client *storageRESTClient) MakeVolBulk(ctx context.Context, volumes ...string) (err error) { return errInvalidArgument } // MakeVol - create a volume on a remote disk. func (client *storageRESTClient) MakeVol(ctx context.Context, volume string) (err error) { return errInvalidArgument } // ListVols - List all volumes on a remote disk. func (client *storageRESTClient) ListVols(ctx context.Context) (vols []VolInfo, err error) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Oct 13 13:07:21 UTC 2024 - 30.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/query/TermQueryCommand.java
} return convertTextQuery(fessConfig, context, termQuery, boost, field, text); } protected QueryBuilder convertTextQuery(final FessConfig fessConfig, final QueryContext context, final TermQuery termQuery, final float boost, final String field, final String text) { context.addFieldLog(field, text); context.addHighlightedQuery(text);
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Sat Oct 12 01:54:15 UTC 2024 - 10K bytes - Viewed (0) -
internal/kms/conn.go
// should be decrypted. Therefore, it is the callers // responsibility to remember the corresponding context for // a particular DEK. The context may be nil. GenerateKey(context.Context, *GenerateKeyRequest) (DEK, error) // DecryptKey decrypts the ciphertext with the key referenced // by the key ID. The context must match the context value // used to generate the ciphertext.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 5K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
ps.RebalancedBuckets = append(ps.RebalancedBuckets, bucket) break } } } func (r *rebalanceMeta) load(ctx context.Context, store objectIO) error { return r.loadWithOpts(ctx, store, ObjectOptions{}) } func (r *rebalanceMeta) loadWithOpts(ctx context.Context, store objectIO, opts ObjectOptions) error { data, _, err := readConfigWithMetadata(ctx, store, rebalMetaName, opts) if err != nil { return err
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 13:20:19 UTC 2024 - 28.4K bytes - Viewed (0)