Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 418 for requestId (0.05 seconds)

  1. internal/logger/target/console/console.go

    	var deploymentID string
    	if entry.DeploymentID != "" {
    		deploymentID = "\nDeploymentID: " + entry.DeploymentID
    	}
    
    	var requestID string
    	if entry.RequestID != "" {
    		requestID = "\nRequestID: " + entry.RequestID
    	}
    
    	var remoteHost string
    	if entry.RemoteHost != "" {
    		remoteHost = "\nRemoteHost: " + entry.RemoteHost
    	}
    
    	var host string
    	if entry.Host != "" {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  2. src/main/java/jcifs/internal/smb2/rdma/RdmaWorkRequest.java

            this.requestId = requestId;
            this.type = type;
            this.memoryRegion = memoryRegion;
            this.completed = false;
        }
    
        /**
         * Get request ID
         *
         * @return unique request identifier
         */
        public long getRequestId() {
            return requestId;
        }
    
        /**
         * Get request type
         *
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 24 00:12:28 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  3. internal/logger/message/audit/entry.go

    	return audit.Entry{
    		Version:      Version,
    		DeploymentID: deploymentID,
    		Time:         time.Now().UTC(),
    	}
    }
    
    // ToEntry - constructs an audit entry from a http request
    func ToEntry(w http.ResponseWriter, r *http.Request, reqClaims map[string]any, deploymentID string) audit.Entry {
    	entry := NewEntry(deploymentID)
    
    	entry.RemoteHost = handlers.GetSourceIP(r)
    	entry.UserAgent = r.UserAgent()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  4. cmd/sts-handlers.go

    	// use that and validate the authentication request. If not, we assume this
    	// is an STS request for a claim based IDP (if one is present) and set
    	// roleArn = openid.DummyRoleARN.
    	//
    	// Currently, we do not support multiple claim based IDPs, as there is no
    	// defined parameter to disambiguate the intended IDP in this STS request.
    	roleArn := openid.DummyRoleARN
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.6K bytes
    - Click Count (0)
  5. internal/logger/logger.go

    			VersionID:  ov.VersionID,
    		})
    	}
    
    	entry := log.Entry{
    		DeploymentID: deploymentID,
    		Level:        logKind,
    		RemoteHost:   req.RemoteHost,
    		Host:         req.Host,
    		RequestID:    req.RequestID,
    		UserAgent:    req.UserAgent,
    		Time:         time.Now().UTC(),
    		API: &log.API{
    			Name: API,
    			Args: &log.Args{
    				Bucket:    req.BucketName,
    				Object:    req.ObjectName,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  6. cmd/handler-utils.go

    }
    
    // Returns access credentials in the request Authorization header.
    func getReqAccessCred(r *http.Request, region string) (cred auth.Credentials) {
    	cred, _, _ = getReqAccessKeyV4(r, region, serviceS3)
    	if cred.AccessKey == "" {
    		cred, _, _ = getReqAccessKeyV2(r)
    	}
    	return cred
    }
    
    // Extract request params to be sent with event notification.
    func extractReqParams(r *http.Request) map[string]string {
    	if r == nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.4K bytes
    - Click Count (1)
  7. cmd/object-handlers.go

    		setPartsCountHeaders(w, objInfo)
    	}
    
    	// Set any additional requested response headers.
    	setHeadGetRespHeaders(w, r.Form)
    
    	// Successful response.
    	if rs != nil || opts.PartNumber > 0 {
    		w.WriteHeader(http.StatusPartialContent)
    	} else {
    		w.WriteHeader(http.StatusOK)
    	}
    
    	// Notify object accessed via a HEAD request.
    	sendEvent(eventArgs{
    		EventName:    event.ObjectAccessedHead,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 120.6K bytes
    - Click Count (0)
  8. cmd/utils.go

    	var lastReq *http.Request
    	checkRedirect := func(req *http.Request, via []*http.Request) error {
    		// fmt.Printf("CheckRedirect:\n")
    		// fmt.Printf("Upcoming: %s %s\n", req.Method, req.URL.String())
    		// for i, c := range via {
    		// 	fmt.Printf("Sofar %d: %s %s\n", i, c.Method, c.URL.String())
    		// }
    		// Save the last request in a redirect chain.
    		lastReq = req
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
  9. cmd/api-response.go

    	// request to get next set of objects. Server lists objects in alphabetical
    	// order Note: This element is returned only if you have delimiter request parameter
    	// specified. If response does not include the NextMaker and it is truncated,
    	// you can use the value of the last Key in the response as the marker in the
    	// subsequent request to get the next set of object keys.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:19 GMT 2025
    - 35K bytes
    - Click Count (0)
  10. cmd/erasure-healing.go

    	reqInfo := logger.GetReqInfo(ctx)
    	var newReqInfo *logger.ReqInfo
    	if reqInfo != nil {
    		newReqInfo = logger.NewReqInfo(reqInfo.RemoteHost, reqInfo.UserAgent, reqInfo.DeploymentID, reqInfo.RequestID, reqInfo.API, bucket, object)
    	} else {
    		newReqInfo = logger.NewReqInfo("", "", globalDeploymentID(), "", "Heal", bucket, object)
    	}
    	healCtx := logger.SetReqInfo(GlobalContext, newReqInfo)
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
Back to Top