Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 53 for watchEvents (0.22 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go

    	expectedInitialEventsInStrictOrder := func(initialPods []*example.Pod, globalResourceVersion string) []watch.Event {
    		watchEvents := []watch.Event{}
    		for _, initialPod := range initialPods {
    			watchEvents = append(watchEvents, watch.Event{Type: watch.Added, Object: initialPod})
    		}
    		watchEvents = append(watchEvents, watch.Event{Type: watch.Bookmark, Object: &example.Pod{
    			ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 63.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/watch.go

    			return
    		case <-done:
    			return
    		case <-timeoutCh:
    			return
    		case event, ok := <-ch:
    			if !ok {
    				// End of results.
    				return
    			}
    			metrics.WatchEvents.WithContext(req.Context()).WithLabelValues(kind.Group, kind.Version, kind.Kind).Inc()
    			isWatchListLatencyRecordingRequired := shouldRecordWatchListLatency(event)
    
    			if err := watchEncoder.Encode(event); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 14 16:37:25 UTC 2023
    - 11.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics.go

    			Name:           "tls_handshake_errors_total",
    			Help:           "Number of requests dropped with 'TLS handshake error from' error",
    			StabilityLevel: compbasemetrics.ALPHA,
    		},
    	)
    	WatchEvents = compbasemetrics.NewCounterVec(
    		&compbasemetrics.CounterOpts{
    			Subsystem:      APIServerComponent,
    			Name:           "watch_events_total",
    			Help:           "Number of events sent in watch clients",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 07:29:19 UTC 2023
    - 35K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/testdata/v1.30.0/core.v1.WatchEvent.pb

    SataQiu <******@****.***> 1713430345 +0800
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:52:25 UTC 2024
    - 129 bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiextensions-apiserver/test/integration/basic_test.go

    					select {
    					case watchEvent := <-noxuWatch.ResultChan():
    						eventMetadata, err := meta.Accessor(watchEvent.Object)
    						if err != nil {
    							t.Fatal(err)
    						}
    
    						if watchEvent.Type == watch.Bookmark {
    							continue
    						}
    
    						if watchEvent.Type != watch.Modified {
    							t.Errorf("expected modified event, got %v", watchEvent.Type)
    							break
    						}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 23 11:35:33 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  6. staging/src/k8s.io/api/testdata/v1.29.0/core.v1.WatchEvent.yaml

    SataQiu <******@****.***> 1702613527 +0800
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 04:12:07 UTC 2023
    - 123 bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/testdata/v1.30.0/core.v1.WatchEvent.json

    SataQiu <******@****.***> 1713430345 +0800
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:52:25 UTC 2024
    - 190 bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/testdata/v1.30.0/core.v1.WatchEvent.yaml

    SataQiu <******@****.***> 1713430345 +0800
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:52:25 UTC 2024
    - 123 bytes
    - Viewed (0)
  9. api/openapi-spec/v3/apis__storage.k8s.io__v1alpha1_openapi.json

                "kind": "WatchEvent",
                "version": "v1beta1"
              },
              {
                "group": "apps",
                "kind": "WatchEvent",
                "version": "v1"
              },
              {
                "group": "apps",
                "kind": "WatchEvent",
                "version": "v1beta1"
              },
              {
                "group": "apps",
                "kind": "WatchEvent",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 117.5K bytes
    - Viewed (0)
  10. api/openapi-spec/v3/apis__internal.apiserver.k8s.io__v1alpha1_openapi.json

                "version": "v1"
              },
              {
                "group": "autoscaling",
                "kind": "WatchEvent",
                "version": "v2"
              },
              {
                "group": "autoscaling",
                "kind": "WatchEvent",
                "version": "v2beta1"
              },
              {
                "group": "autoscaling",
                "kind": "WatchEvent",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 133.2K bytes
    - Viewed (0)
Back to top