- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 25 for ReqInfo (0.12 sec)
-
cmd/utils.go
} return ctx } // Returns context with ReqInfo details set in the context. func newContext(r *http.Request, w http.ResponseWriter, api string) context.Context { reqID := w.Header().Get(xhttp.AmzRequestID) vars := mux.Vars(r) bucket := vars["bucket"] object := likelyUnescapeGeneric(vars["object"], url.PathUnescape) reqInfo := &logger.ReqInfo{ DeploymentID: globalDeploymentID(), RequestID: reqID,
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Aug 13 22:22:04 UTC 2024 - 31.9K bytes - Viewed (0) -
cmd/update.go
if err != nil { // Log errors and return "" as MinIO can be deployed // without Helm charts as well. if !osIsNotExist(err) { reqInfo := (&logger.ReqInfo{}).AppendTags("helmInfoFilePath", helmInfoFilePath) ctx := logger.SetReqInfo(GlobalContext, reqInfo) internalLogIf(ctx, err) } return "" } defer helmInfoFile.Close() scanner := bufio.NewScanner(helmInfoFile) for scanner.Scan() {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 18.7K bytes - Viewed (0) -
cmd/admin-heal-ops.go
func newHealSequence(ctx context.Context, bucket, objPrefix, clientAddr string, hs madmin.HealOpts, forceStart bool, ) *healSequence { reqInfo := &logger.ReqInfo{RemoteHost: clientAddr, API: "Heal", BucketName: bucket} reqInfo.AppendTags("prefix", objPrefix) ctx, cancel := context.WithCancel(logger.SetReqInfo(ctx, reqInfo)) clientToken := mustGetUUID() return &healSequence{ bucket: bucket, object: objPrefix,
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 25.6K bytes - Viewed (0) -
cmd/api-response.go
errBody string, reqURL *url.URL, ) { reqInfo := logger.GetReqInfo(ctx) errorResponse := APIErrorResponse{ Code: err.Code, Message: errBody, Resource: reqURL.Path, BucketName: reqInfo.BucketName, Key: reqInfo.ObjectName, RequestID: w.Header().Get(xhttp.AmzRequestID), HostID: globalDeploymentID(), }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Oct 25 02:13:19 UTC 2024 - 33.6K bytes - Viewed (0) -
cmd/http-tracer.go
Time: reqStartTime, Duration: reqEndTime.Sub(respRecorder.StartTime), Path: reqPath, Bytes: int64(inputBytes + respRecorder.Size()), HTTP: &madmin.TraceHTTPStats{ ReqInfo: madmin.TraceRequestInfo{ Time: reqStartTime, Proto: r.Proto, Method: r.Method, RawQuery: redactLDAPPwd(r.URL.RawQuery), Client: handlers.GetSourceIP(r),
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Sep 24 17:13:00 UTC 2024 - 6K bytes - Viewed (0) -
cmd/encryption-v1.go
if err != nil { // This cannot happen since AWS S3 allows parts to be 5GB at most // sio max. size is 256 TB reqInfo := (&logger.ReqInfo{}).AppendTags("size", strconv.FormatUint(size, 10)) ctx := logger.SetReqInfo(GlobalContext, reqInfo) logger.CriticalIf(ctx, err) } return int64(size) } // DecryptObjectInfo tries to decrypt the provided object if it is encrypted.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Oct 13 13:06:08 UTC 2024 - 37.2K bytes - Viewed (0) -
cmd/admin-router.go
// Use bitwise-AND and check if the result is non-zero. return h&flag != 0 } // adminMiddleware performs some common admin handler functionality for all // handlers: // // - updates request context with `logger.ReqInfo` and api name based on the // name of the function handler passed (this handler must be a method of // `adminAPIHandlers`). // // - sets up call to send AuditLog //
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Sep 21 11:35:40 UTC 2024 - 26.2K bytes - Viewed (0) -
internal/logger/logger.go
logKind := madmin.LogKindError if len(errKind) > 0 { if ek, ok := errKind[0].(madmin.LogKind); ok { logKind = ek } } req := GetReqInfo(ctx) if req == nil { req = &ReqInfo{ API: "SYSTEM", RequestID: fmt.Sprintf("%X", time.Now().UTC().UnixNano()), } } req.RLock() defer req.RUnlock() API := "SYSTEM" switch { case req.API != "":
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 22 09:43:48 UTC 2024 - 12.4K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
}, finished: nil, }) return err } func (z *erasureServerPools) decommissionPool(ctx context.Context, idx int, pool *erasureSets, bi decomBucketInfo) error { ctx = logger.SetReqInfo(ctx, &logger.ReqInfo{}) const envDecomWorkers = "_MINIO_DECOMMISSION_WORKERS" workerSize, err := env.GetInt(envDecomWorkers, len(pool.sets)) if err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 13:20:19 UTC 2024 - 42.2K bytes - Viewed (1) -
cmd/erasure-server-pool.go
// can be used to query scenarios if health may be lost // if this node is taken down by an external orchestrator. func (z *erasureServerPools) Health(ctx context.Context, opts HealthOptions) HealthResult { reqInfo := (&logger.ReqInfo{}).AppendTags("maintenance", strconv.FormatBool(opts.Maintenance)) type setInfo struct { online int healing int } var drivesHealing int
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 89.8K bytes - Viewed (0)