mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-29 22:46:12 +00:00
Merge pull request #2928 from rajdeepd/master
Added test cases for Event Create and Event List
This commit is contained in:
commit
26e5c1d0eb
@ -23,6 +23,7 @@ import (
|
|||||||
|
|
||||||
"github.com/GoogleCloudPlatform/kubernetes/pkg/api"
|
"github.com/GoogleCloudPlatform/kubernetes/pkg/api"
|
||||||
"github.com/GoogleCloudPlatform/kubernetes/pkg/api/testapi"
|
"github.com/GoogleCloudPlatform/kubernetes/pkg/api/testapi"
|
||||||
|
"github.com/GoogleCloudPlatform/kubernetes/pkg/labels"
|
||||||
"github.com/GoogleCloudPlatform/kubernetes/pkg/util"
|
"github.com/GoogleCloudPlatform/kubernetes/pkg/util"
|
||||||
)
|
)
|
||||||
|
|
||||||
@ -61,7 +62,6 @@ func TestEventCreate(t *testing.T) {
|
|||||||
}
|
}
|
||||||
timeStamp := util.Now()
|
timeStamp := util.Now()
|
||||||
event := &api.Event{
|
event := &api.Event{
|
||||||
//namespace: namespace{"default"},
|
|
||||||
Status: "running",
|
Status: "running",
|
||||||
InvolvedObject: *objReference,
|
InvolvedObject: *objReference,
|
||||||
Timestamp: timeStamp,
|
Timestamp: timeStamp,
|
||||||
@ -85,3 +85,84 @@ func TestEventCreate(t *testing.T) {
|
|||||||
t.Errorf("%#v != %#v.", e, a)
|
t.Errorf("%#v != %#v.", e, a)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestEventGet(t *testing.T) {
|
||||||
|
objReference := &api.ObjectReference{
|
||||||
|
Kind: "foo",
|
||||||
|
Namespace: "nm",
|
||||||
|
Name: "objref1",
|
||||||
|
UID: "uid",
|
||||||
|
APIVersion: "apiv1",
|
||||||
|
ResourceVersion: "1",
|
||||||
|
}
|
||||||
|
timeStamp := util.Now()
|
||||||
|
event := &api.Event{
|
||||||
|
Status: "running",
|
||||||
|
InvolvedObject: *objReference,
|
||||||
|
Timestamp: timeStamp,
|
||||||
|
}
|
||||||
|
c := &testClient{
|
||||||
|
Request: testRequest{
|
||||||
|
Method: "GET",
|
||||||
|
Path: "/events/1",
|
||||||
|
Body: nil,
|
||||||
|
},
|
||||||
|
Response: Response{StatusCode: 200, Body: event},
|
||||||
|
}
|
||||||
|
|
||||||
|
response, err := c.Setup().Events("").Get("1")
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
t.Errorf("%#v should be nil.", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
if e, r := event.InvolvedObject, response.InvolvedObject; !reflect.DeepEqual(e, r) {
|
||||||
|
t.Errorf("%#v != %#v.", e, r)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestEventList(t *testing.T) {
|
||||||
|
ns := api.NamespaceDefault
|
||||||
|
objReference := &api.ObjectReference{
|
||||||
|
Kind: "foo",
|
||||||
|
Namespace: ns,
|
||||||
|
Name: "objref1",
|
||||||
|
UID: "uid",
|
||||||
|
APIVersion: "apiv1",
|
||||||
|
ResourceVersion: "1",
|
||||||
|
}
|
||||||
|
timeStamp := util.Now()
|
||||||
|
eventList := &api.EventList{
|
||||||
|
Items: []api.Event{
|
||||||
|
{
|
||||||
|
Status: "running",
|
||||||
|
InvolvedObject: *objReference,
|
||||||
|
Timestamp: timeStamp,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
}
|
||||||
|
c := &testClient{
|
||||||
|
Request: testRequest{
|
||||||
|
Method: "GET",
|
||||||
|
Path: "/events",
|
||||||
|
Body: nil,
|
||||||
|
},
|
||||||
|
Response: Response{StatusCode: 200, Body: eventList},
|
||||||
|
}
|
||||||
|
response, err := c.Setup().Events(ns).List(labels.Everything(),
|
||||||
|
labels.Everything())
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
t.Errorf("%#v should be nil.", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
if len(response.Items) != 1 {
|
||||||
|
t.Errorf("%#v response.Items should have len 1.", response.Items)
|
||||||
|
}
|
||||||
|
|
||||||
|
responseEvent := response.Items[0]
|
||||||
|
if e, r := eventList.Items[0].InvolvedObject,
|
||||||
|
responseEvent.InvolvedObject; !reflect.DeepEqual(e, r) {
|
||||||
|
t.Errorf("%#v != %#v.", e, r)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user