Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 17 of 17 for AddEvent (0.13 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_test.go

    	addEvent("key2", 30, later)
    	addEvent("key3", 40, later)
    
    	// Force cache resize.
    	addEvent("key4", 50, later.Add(time.Second))
    
    	_, err := store.getAllEventsSince(15, storage.ListOptions{})
    	if err == nil || !strings.Contains(err.Error(), "too old resource version") {
    		t.Errorf("unexpected error: %v", err)
    	}
    }
    
    func TestSuggestedWatchChannelSize(t *testing.T) {
    	testCases := []struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  2. pkg/controller/garbagecollector/graph_builder.go

    )
    
    type eventType int
    
    func (e eventType) String() string {
    	switch e {
    	case addEvent:
    		return "add"
    	case updateEvent:
    		return "update"
    	case deleteEvent:
    		return "delete"
    	default:
    		return fmt.Sprintf("unknown(%d)", int(e))
    	}
    }
    
    const (
    	addEvent eventType = iota
    	updateEvent
    	deleteEvent
    )
    
    type event struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  3. 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)
  4. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/dispatcher.go

    		} else {
    			status = apierrors.NewBadRequest("error calling webhook")
    		}
    		return &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, false, response)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 23 20:24:12 UTC 2023
    - 13K bytes
    - Viewed (0)
  5. src/cmd/compile/internal/noder/noder.go

    	for _, p := range noders {
    		for e := range p.err {
    			base.ErrorfAt(m.makeXPos(e.Pos), 0, "%s", e.Msg)
    		}
    		if p.file == nil {
    			base.ErrorExit()
    		}
    		lines += p.file.EOF.Line()
    	}
    	base.Timer.AddEvent(int64(lines), "lines")
    
    	unified(m, noders)
    }
    
    // trimFilename returns the "trimmed" filename of b, which is the
    // absolute filename after applying -trimpath processing. This
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Oct 11 20:40:57 UTC 2023
    - 12.5K bytes
    - Viewed (0)
  6. 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)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/conversion/webhook_converter.go

    		Metrics.ObserveConversionWebhookFailure(ctx, time.Since(t), ConversionWebhookCallFailure)
    		return nil, fmt.Errorf("conversion webhook for %v failed: %v", in.GetObjectKind().GroupVersionKind(), err)
    	}
    	span.AddEvent("Request completed")
    
    	convertedObjects, err := getConvertedObjectsFromResponse(requestUID, response)
    	if err != nil {
    		Metrics.ObserveConversionWebhookFailure(ctx, time.Since(t), ConversionWebhookMalformedResponseFailure)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 07 19:37:55 UTC 2023
    - 20.6K bytes
    - Viewed (0)
Back to top