Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 73 for WatchEvent (0.43 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. staging/src/k8s.io/cli-runtime/pkg/printers/name.go

    // and print "resource/name" pair. If the object is a List, print all items in it.
    func (p *NamePrinter) PrintObj(obj runtime.Object, w io.Writer) error {
    	switch castObj := obj.(type) {
    	case *metav1.WatchEvent:
    		obj = castObj.Object.Object
    	}
    
    	// we use reflect.Indirect here in order to obtain the actual value from a pointer.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 28 23:24:54 UTC 2019
    - 3.9K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher.go

    	}
    
    	return nil
    }
    
    // NOTE: sendWatchCacheEvent is assumed to not modify <event> !!!
    func (c *cacheWatcher) sendWatchCacheEvent(event *watchCacheEvent) {
    	watchEvent := c.convertToWatchEvent(event)
    	if watchEvent == nil {
    		// Watcher is not interested in that object.
    		return
    	}
    
    	// We need to ensure that if we put event X to the c.result, all
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 12:22:41 UTC 2023
    - 18.7K bytes
    - Viewed (0)
  7. staging/src/k8s.io/cli-runtime/artifacts/openapi/swagger-with-shared-parameters.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: Tue Feb 20 15:45:02 UTC 2024
    - 2.3M bytes
    - Viewed (0)
  8. api/openapi-spec/swagger.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: Wed Jun 05 18:37:07 UTC 2024
    - 3.1M bytes
    - Viewed (0)
  9. staging/src/k8s.io/apimachinery/pkg/api/apitesting/roundtrip/roundtrip.go

    var globalNonRoundTrippableTypes = sets.NewString(
    	"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: Wed Apr 12 15:48:03 UTC 2023
    - 16.8K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/apiserver.go

    	// if you modify this, make sure you update the crEncoder
    	unversionedVersion = schema.GroupVersion{Group: "", Version: "v1"}
    	unversionedTypes   = []runtime.Object{
    		&metav1.Status{},
    		&metav1.WatchEvent{},
    		&metav1.APIVersions{},
    		&metav1.APIGroupList{},
    		&metav1.APIGroup{},
    		&metav1.APIResourceList{},
    	}
    )
    
    func init() {
    	install.Install(Scheme)
    
    	// we need to add the options to empty v1
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 19 14:31:43 UTC 2023
    - 11.5K bytes
    - Viewed (0)
Back to top