Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for GetAuditIDTruncated (0.38 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/filters/wrap.go

    			return
    		}
    		http.Error(w, "This request caused apiserver to panic. Look in the logs for details.", http.StatusInternalServerError)
    		klog.ErrorS(nil, "apiserver panic'd", "method", req.Method, "URI", req.RequestURI, "auditID", audit.GetAuditIDTruncated(req.Context()))
    	})
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 16:28:45 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/audit/context.go

    		return ac.Event.AuditID, true
    	}
    	return "", false
    }
    
    // GetAuditIDTruncated returns the audit ID (truncated) from the request context.
    // If the length of the Audit-ID value exceeds the limit, we truncate it to keep
    // the first N (maxAuditIDLength) characters.
    // This is intended to be used in logging only.
    func GetAuditIDTruncated(ctx context.Context) string {
    	auditID, ok := AuditIDFrom(ctx)
    	if !ok {
    		return ""
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 16:16:51 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/helpers.go

    // the audit ID associated with the request.
    type lazyAuditID struct {
    	req *http.Request
    }
    
    func (lazy *lazyAuditID) String() string {
    	if lazy.req != nil {
    		return audit.GetAuditIDTruncated(lazy.req.Context())
    	}
    
    	return "unknown"
    }
    
    // lazyVerb implements String() string and it will
    // lazily get normalized Verb
    type lazyVerb struct {
    	req *http.Request
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Sep 03 15:25:35 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/endpoints/filters/request_deadline.go

    func handleError(w http.ResponseWriter, r *http.Request, code int, innerErr error, msg string) {
    	http.Error(w, msg, code)
    	klog.ErrorSDepth(1, innerErr, msg, "method", r.Method, "URI", r.RequestURI, "auditID", audit.GetAuditIDTruncated(r.Context()))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 05 21:12:12 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/server/httplog/httplog.go

    		rl.StacktraceWhen(pred)
    	}
    }
    
    // Log is intended to be called once at the end of your request handler, via defer
    func (rl *respLogger) Log() {
    	latency := time.Since(rl.startTime)
    	auditID := audit.GetAuditIDTruncated(rl.req.Context())
    	verb := metrics.NormalizedVerb(rl.req)
    
    	keysAndValues := []interface{}{
    		"verb", verb,
    		"URI", rl.req.RequestURI,
    		"latency", latency,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 07 10:10:35 UTC 2023
    - 9.7K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go

    	preparedKey, err := s.prepareKey(key)
    	if err != nil {
    		return err
    	}
    	ctx, span := tracing.Start(ctx, "Create etcd3",
    		attribute.String("audit-id", audit.GetAuditIDTruncated(ctx)),
    		attribute.String("key", key),
    		attribute.String("type", getTypeName(obj)),
    		attribute.String("resource", s.groupResourceString),
    	)
    	defer span.End(500 * time.Millisecond)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 11:56:42 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/responsewriters/writers.go

    	ctx := req.Context()
    	ctx, span := tracing.Start(ctx, "SerializeObject",
    		attribute.String("audit-id", audit.GetAuditIDTruncated(ctx)),
    		attribute.String("method", req.Method),
    		attribute.String("url", req.URL.Path),
    		attribute.String("protocol", req.Proto),
    		attribute.String("mediaType", mediaType),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 07 18:21:43 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    		if err != nil {
    			return err
    		}
    	}
    
    	ctx, span := tracing.Start(ctx, "cacher list",
    		attribute.String("audit-id", audit.GetAuditIDTruncated(ctx)),
    		attribute.Stringer("type", c.groupResource))
    	defer span.End(500 * time.Millisecond)
    
    	if utilfeature.DefaultFeatureGate.Enabled(features.ResilientWatchCacheInitialization) {
    		if !c.ready.check() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
Back to top