Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for WatchEvent (0.18 sec)

  2. github.com/kubernetes/kubernetes

    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)
  3. github.com/kubernetes/kubernetes

    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)
  4. github.com/kubernetes/kubernetes

    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)
  5. github.com/kubernetes/kubernetes

    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)
  6. github.com/kubernetes/kubernetes

    staging/src/k8s.io/api/testdata/v1.29.0/core.v1.WatchEvent.pb 

    SataQiu <******@****.***> 1702613527 +0800
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 04:12:07 UTC 2023
    - 129 bytes
    - Viewed (0)
  7. github.com/kubernetes/kubernetes

    staging/src/k8s.io/api/testdata/v1.29.0/core.v1.WatchEvent.json 

    SataQiu <******@****.***> 1702613527 +0800
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 04:12:07 UTC 2023
    - 190 bytes
    - Viewed (0)
  8. 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)
  9. github.com/kubernetes/kubernetes

    staging/src/k8s.io/apiserver/pkg/endpoints/handlers/response_test.go 

    			}
		})
	}
}

func TestWatchEncoderIdentifier(t *testing.T) {
	eventFields := reflect.VisibleFields(reflect.TypeOf(metav1.WatchEvent{}))
	if len(eventFields) != 2 {
		t.Error("New field was added to metav1.WatchEvent.")
		t.Error("  Ensure that the following places are updated accordingly:")
		t.Error("  - watchEncoder::doEncode method when creating outEvent")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 18 09:07:03 UTC 2023
    - 6.4K bytes
    - Viewed (0)
Back to top