Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 13 of 13 for AddEvent (0.11 sec)

  1. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/dispatcher.go

    			status = apierrors.NewBadRequest("error calling webhook")
    		}
    		return false, &webhookutil.ErrCallingWebhook{WebhookName: h.Name, Reason: fmt.Errorf("failed to call webhook: %w", err), Status: status}
    	}
    	span.AddEvent("Request completed")
    
    	result, err := webhookrequest.VerifyAdmissionResponse(uid, true, response)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    		listVal.Set(reflect.MakeSlice(listVal.Type(), len(selectedObjects), len(selectedObjects)))
    		span.AddEvent("Resized result")
    		for i, o := range selectedObjects {
    			listVal.Index(i).Set(reflect.ValueOf(o).Elem())
    		}
    	}
    	span.AddEvent("Filtered items", attribute.Int("count", listVal.Len()))
    	if c.versioner != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go

    			// has expired accidentally.
    			<-w.clock.After(blockTimeout)
    			w.cond.Broadcast()
    		}()
    	}
    
    	w.RLock()
    	span := tracing.SpanFromContext(ctx)
    	span.AddEvent("watchCache locked acquired")
    	for w.resourceVersion < resourceVersion {
    		if w.clock.Since(startTime) >= blockTimeout {
    			// Request that the client retry after 'resourceVersionTooHighRetrySeconds' seconds.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 10:20:57 UTC 2024
    - 26.2K bytes
    - Viewed (0)
Back to top