Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 68 for WatchEvent (0.32 sec)

  1. 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)
  2. staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/resources.go

    		if err != nil {
    			return false, err
    		}
    		defer noxuWatch.Stop()
    
    		select {
    		case watchEvent := <-noxuWatch.ResultChan():
    			if watch.Error == watchEvent.Type {
    				return false, nil
    			}
    			if watch.Deleted != watchEvent.Type {
    				return false, fmt.Errorf("expected DELETE, but got %#v", watchEvent)
    			}
    		case <-time.After(5 * time.Second):
    			return false, fmt.Errorf("gave up waiting for watch event")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 19 02:01:40 UTC 2021
    - 21.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/zz_generated.deepcopy.go

    func (in *WatchEvent) DeepCopyInto(out *WatchEvent) {
    	*out = *in
    	in.Object.DeepCopyInto(&out.Object)
    	return
    }
    
    // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WatchEvent.
    func (in *WatchEvent) DeepCopy() *WatchEvent {
    	if in == nil {
    		return nil
    	}
    	out := new(WatchEvent)
    	in.DeepCopyInto(out)
    	return out
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 01 10:00:25 UTC 2023
    - 32.2K bytes
    - Viewed (0)
  4. pkg/api/testing/serialization_test.go

    var nonRoundTrippableTypes = sets.New[string](
    	"ExportOptions",
    	"GetOptions",
    	// WatchEvent does not include kind and version and can only be deserialized
    	// implicitly (if the caller expects the specific object). The watch call defines
    	// the schema by content type, rather than via kind/version included in each
    	// object.
    	"WatchEvent",
    	// ListOptions is now part of the meta group
    	"ListOptions",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 25 11:04:08 UTC 2023
    - 19.3K bytes
    - Viewed (0)
  5. staging/src/k8s.io/cli-runtime/pkg/printers/json.go

    	if InternalObjectPreventer.IsForbidden(reflect.Indirect(reflect.ValueOf(obj)).Type().PkgPath()) {
    		return fmt.Errorf(InternalObjectPrinterErr)
    	}
    
    	switch obj := obj.(type) {
    	case *metav1.WatchEvent:
    		if InternalObjectPreventer.IsForbidden(reflect.Indirect(reflect.ValueOf(obj.Object.Object)).Type().PkgPath()) {
    			return fmt.Errorf(InternalObjectPrinterErr)
    		}
    		data, err := json.Marshal(obj)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 10 11:23:25 UTC 2021
    - 2.3K bytes
    - Viewed (0)
  6. api/openapi-spec/v3/apis__batch__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: Wed Jun 05 18:37:07 UTC 2024
    - 485.4K bytes
    - Viewed (0)
  7. staging/src/k8s.io/cli-runtime/pkg/printers/yaml.go

    	}
    
    	count := atomic.AddInt64(&p.printCount, 1)
    	if count > 1 {
    		if _, err := w.Write([]byte("---\n")); err != nil {
    			return err
    		}
    	}
    
    	switch obj := obj.(type) {
    	case *metav1.WatchEvent:
    		if InternalObjectPreventer.IsForbidden(reflect.Indirect(reflect.ValueOf(obj.Object.Object)).Type().PkgPath()) {
    			return fmt.Errorf(InternalObjectPrinterErr)
    		}
    		data, err := yaml.Marshal(obj)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 02 14:15:25 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  8. api/openapi-spec/v3/api__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: Wed May 29 22:40:29 UTC 2024
    - 1.8M bytes
    - Viewed (0)
  9. api/openapi-spec/v3/apis__apps__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: Wed May 29 22:40:29 UTC 2024
    - 810.7K bytes
    - Viewed (0)
  10. staging/src/k8s.io/cli-runtime/pkg/printers/tableprinter_test.go

    		// Create the table from the columns and rows.
    		table := &metav1.Table{
    			ColumnDefinitions: test.columns,
    			Rows:              test.rows,
    		}
    		// Add the table to the WatchEvent.
    		event := &metav1.WatchEvent{
    			Type:   "Added",
    			Object: runtime.RawExtension{Object: table},
    		}
    		// Print the event
    		out := bytes.NewBuffer([]byte{})
    		printer := NewTablePrinter(test.options)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Oct 30 15:08:43 UTC 2022
    - 24.4K bytes
    - Viewed (0)
Back to top