Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 68 for WatchEvent (0.26 sec)

  2. github.com/kubernetes/kubernetes

    api/openapi-spec/v3/apis__admissionregistration.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
    - 235.4K bytes
    - Viewed (0)
  3. github.com/kubernetes/kubernetes

    api/openapi-spec/v3/apis__admissionregistration.k8s.io__v1beta1_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
    - 235.7K bytes
    - Viewed (0)
  4. github.com/kubernetes/kubernetes

    staging/src/k8s.io/apiextensions-apiserver/test/integration/registration_test.go 

    		}
	}

	addEvents := 0
	for addEvents < len(instances) {
		select {
		case watchEvent := <-noxuNamespacedWatch.ResultChan():
			if e, a := watch.Added, watchEvent.Type; e != a {
				t.Fatalf("expected %v, got %v", e, a)
			}
			name, err := meta.NewAccessor().Name(watchEvent.Object)
			if err != nil {
				t.Fatalf("unable to retrieve object name:%v", err)
			}
			if instances[name].Added {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 14 11:58:05 UTC 2022
    - 15.4K bytes
    - Viewed (0)
  5. github.com/kubernetes/kubernetes

    api/openapi-spec/v3/apis__networking.k8s.io__v1_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
    - 324.8K bytes
    - Viewed (0)
  6. github.com/kubernetes/kubernetes

    pkg/kubelet/config/file_linux.go 

    	case (e.Op & fsnotify.Rename) > 0:
		eventType = podDelete
	default:
		// Ignore rest events
		return nil
	}

	s.watchEvents <- &watchEvent{e.Name, eventType}
	return nil
}

func (s *sourceFile) consumeWatchEvent(e *watchEvent) error {
	switch e.eventType {
	case podAdd, podModify:
		pod, err := s.extractFromFile(e.fileName)
		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 02 17:27:26 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  7. github.com/kubernetes/kubernetes

    pkg/kubelet/server/stats/volume_stat_calculator_test.go 

    	statsCalculator.calcAndStoreStats()

	event, err := WatchEvent(eventStore)
	assert.Nil(t, err)
	assert.Equal(t, fmt.Sprintf("Warning VolumeConditionAbnormal Volume %s: The target path of the volume doesn't exist", "vol0"), event)
}

func WatchEvent(eventChan <-chan string) (string, error) {
	select {
	case event := <-eventChan:
		return event, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  8. github.com/kubernetes/kubernetes

    api/openapi-spec/v3/apis__storage.k8s.io__v1_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
    - 481.9K bytes
    - Viewed (0)
  9. github.com/kubernetes/kubernetes

    api/openapi-spec/v3/apis__resource.k8s.io__v1alpha2_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: Mon Apr 22 12:18:45 UTC 2024
    - 656.6K bytes
    - Viewed (0)
  10. github.com/kubernetes/kubernetes

    api/openapi-spec/v3/apis__admissionregistration.k8s.io__v1_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
    - 388.1K bytes
    - Viewed (0)
  11. github.com/kubernetes/kubernetes

    pkg/kubelet/config/file_unsupported.go 

    import (
	"fmt"

	"k8s.io/klog/v2"
)

func (s *sourceFile) startWatch() {
	klog.ErrorS(nil, "Watching source file is unsupported in this build")
}

func (s *sourceFile) consumeWatchEvent(e *watchEvent) error {
	return fmt.Errorf("consuming watch event is unsupported in this build")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 908 bytes
    - Viewed (0)
Back to top