- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 68 for WatchEvent (0.32 sec)
-
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) -
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/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) -
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) -
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) -
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) -
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) -
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)