Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for WatchEvent (0.21 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. 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)
  3. 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)
  4. 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)
  5. staging/src/k8s.io/apiserver/pkg/endpoints/watch_test.go

    					action, object := item.t, item.obj
    					name := fmt.Sprintf("%s-%s-%d", protocol.name, test.MediaType, i)
    
    					// Send
    					w.Action(action, object)
    					// Test receive
    					var got metav1.WatchEvent
    					_, _, err := d.Decode(nil, &got)
    					if err != nil {
    						t.Fatalf("%s: Unexpected error: %v", name, err)
    					}
    					if got.Type != string(action) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 30 17:27:39 UTC 2023
    - 30K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/response.go

    		return fmt.Errorf("unable to encode watch object %T: %v", obj, err)
    	}
    
    	// ContentType is not required here because we are defaulting to the serializer type.
    	outEvent := &metav1.WatchEvent{
    		Type:   string(event.Type),
    		Object: runtime.RawExtension{Raw: e.buffer.Bytes()},
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 18 09:07:03 UTC 2023
    - 16.5K bytes
    - Viewed (0)
Back to top