- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for WatchEvent (0.17 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)