- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 73 for WatchEvent (0.32 sec)
-
cmd/kubelet/app/server_bootstrap_test.go
if s.csr == nil { t.Fatalf("no csr") } csr := s.csr.DeepCopy() data := mustMarshal(&metav1.WatchEvent{ Type: "ADDED", Object: runtime.RawExtension{ Raw: mustMarshal(csr), }, }) w.Header().Set("Content-Type", "application/json") w.Write(data) default:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 01 05:59:41 UTC 2022 - 10.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/generated.pb.go
var xxx_messageInfo_Verbs proto.InternalMessageInfo func (m *WatchEvent) Reset() { *m = WatchEvent{} } func (*WatchEvent) ProtoMessage() {} func (*WatchEvent) Descriptor() ([]byte, []int) { return fileDescriptor_a8431b6e0aeeb761, []int{43} } func (m *WatchEvent) XXX_Unmarshal(b []byte) error { return m.Unmarshal(b) } func (m *WatchEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { b = b[:cap(b)]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:37 UTC 2024 - 281.4K bytes - Viewed (0) -
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) -
staging/src/k8s.io/cli-runtime/pkg/printers/tableprinter.go
if _, found := output.(*tabwriter.Writer); !found { w := GetNewTabWriter(output) output = w defer w.Flush() } var eventType string if event, isEvent := obj.(*metav1.WatchEvent); isEvent { eventType = event.Type obj = event.Object.Object } // Parameter "obj" is a table from server; print it. // display tables following the rules of options
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Oct 30 15:08:43 UTC 2022 - 16.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/apitesting/roundtrip/compatibility.go
var coreKinds = sets.NewString( "CreateOptions", "UpdateOptions", "PatchOptions", "DeleteOptions", "GetOptions", "ListOptions", "ExportOptions", "WatchEvent", ) func (c *CompatibilityTestOptions) Complete(t *testing.T) *CompatibilityTestOptions { t.Helper() // Verify scheme if c.Scheme == nil { t.Fatal("scheme is required") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 16:38:32 UTC 2023 - 17.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/response.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 18 09:07:03 UTC 2023 - 16.5K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/artifacts/openapi/swagger.json
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 20 15:45:02 UTC 2024 - 4.5M bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/apiserver_test.go
t.Fatal(err) } t.Logf("Body:\n%s", string(body)) d := watcher(resp.Header.Get("Content-Type"), ioutil.NopCloser(bytes.NewReader(body))) var actual []*metav1.WatchEvent for { var event metav1.WatchEvent _, _, err := d.Decode(nil, &event) if err == io.EOF { break } if err != nil { t.Fatal(err) } actual = append(actual, &event) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 20:15:22 UTC 2023 - 158.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/installer.go
return nil, nil, err } } isGetter = true } var versionedWatchEvent interface{} if isWatcher { versionedWatchEventPtr, err := a.group.Creater.New(a.group.GroupVersion.WithKind("WatchEvent")) if err != nil { return nil, nil, err } versionedWatchEvent = indirectArbitraryPointer(versionedWatchEventPtr) } var ( connectOptions runtime.Object
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 51.5K bytes - Viewed (0) -
common-protos/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto
} // Event represents a single event to a watched resource. // // +protobuf=true // +k8s:deepcopy-gen=true // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object message WatchEvent { optional string type = 1; // Object is: // * If Type is Added or Modified: the new state of the object. // * If Type is Deleted: the state of the object immediately before deletion.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 53.3K bytes - Viewed (0)