Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for AddAuditAnnotationsMap (0.23 sec)

  1. staging/src/k8s.io/apiserver/pkg/audit/context.go

    	}
    	for i := 0; i < len(keysAndValues); i += 2 {
    		addAuditAnnotationLocked(ac, keysAndValues[i], keysAndValues[i+1])
    	}
    }
    
    // AddAuditAnnotationsMap is a bulk version of AddAuditAnnotation. Refer to AddAuditAnnotation for
    // restrictions on when this can be called.
    func AddAuditAnnotationsMap(ctx context.Context, annotations map[string]string) {
    	ac := AuditContextFrom(ctx)
    	if !ac.Enabled() {
    		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)
  2. staging/src/k8s.io/apiserver/pkg/admission/audit.go

    	case AnnotationsGetter:
    		annotations = a.GetAnnotations(ae.Level)
    	default:
    		// this will never happen, because we have already checked it in ensureAnnotationGetter
    	}
    
    	audit.AddAuditAnnotationsMap(ctx, annotations)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 29 00:03:53 UTC 2022
    - 2.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/endpoints/filters/audit.go

    		// latency tracking is not enabled for this request
    		return
    	}
    
    	// record the total latency for this request, for convenience.
    	layerLatencies["apiserver.latency.k8s.io/total"] = latency.String()
    	audit.AddAuditAnnotationsMap(ctx, layerLatencies)
    }
    
    func processAuditEvent(ctx context.Context, sink audit.Sink, ev *auditinternal.Event, omitStages []auditinternal.Stage) bool {
    	for _, stage := range omitStages {
    		if ev.Stage == stage {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 16:16:51 UTC 2023
    - 8.6K bytes
    - Viewed (0)
Back to top