Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for WatchEvent (0.17 sec)

  1. 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)
  2. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/zz_generated.conversion.go

    	}); err != nil {
    		return err
    	}
    	if err := s.AddConversionFunc((*WatchEvent)(nil), (*InternalEvent)(nil), func(a, b interface{}, scope conversion.Scope) error {
    		return Convert_v1_WatchEvent_To_v1_InternalEvent(a.(*WatchEvent), b.(*InternalEvent), scope)
    	}); err != nil {
    		return err
    	}
    	if err := s.AddConversionFunc((*WatchEvent)(nil), (*watch.Event)(nil), func(a, b interface{}, scope conversion.Scope) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 01 10:00:25 UTC 2023
    - 21.6K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  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