From 703d2a87bf9b0e279c04730d2c8e31988a7eaca0 Mon Sep 17 00:00:00 2001 From: derekwaynecarr Date: Thu, 12 Mar 2015 16:47:18 -0400 Subject: [PATCH] Client support to delete events --- pkg/client/events.go | 11 +++++++++++ pkg/client/events_test.go | 10 ++++++++++ pkg/client/fake_events.go | 5 +++++ 3 files changed, 26 insertions(+) diff --git a/pkg/client/events.go b/pkg/client/events.go index 04c7a5ea03c..8777b3ce5e2 100644 --- a/pkg/client/events.go +++ b/pkg/client/events.go @@ -40,6 +40,7 @@ type EventInterface interface { Watch(label, field labels.Selector, resourceVersion string) (watch.Interface, error) // Search finds events about the specified object Search(objOrRef runtime.Object) (*api.EventList, error) + Delete(name string) error } // events implements Events interface @@ -161,3 +162,13 @@ func (e *events) Search(objOrRef runtime.Object) (*api.EventList, error) { } return e.List(labels.Everything(), fields.AsSelector()) } + +// Delete deletes an existing event. +func (e *events) Delete(name string) error { + return e.client.Delete(). + NamespaceIfScoped(e.namespace, len(e.namespace) > 0). + Resource("events"). + Name(name). + Do(). + Error() +} diff --git a/pkg/client/events_test.go b/pkg/client/events_test.go index 41920a22656..bfc4c78682d 100644 --- a/pkg/client/events_test.go +++ b/pkg/client/events_test.go @@ -175,3 +175,13 @@ func TestEventList(t *testing.T) { t.Errorf("%#v != %#v.", e, r) } } + +func TestEventDelete(t *testing.T) { + ns := api.NamespaceDefault + c := &testClient{ + Request: testRequest{Method: "DELETE", Path: "/events/foo"}, + Response: Response{StatusCode: 200}, + } + err := c.Setup().Events(ns).Delete("foo") + c.Validate(t, nil, err) +} diff --git a/pkg/client/fake_events.go b/pkg/client/fake_events.go index d796e910f08..40c9430992a 100644 --- a/pkg/client/fake_events.go +++ b/pkg/client/fake_events.go @@ -64,3 +64,8 @@ func (c *FakeEvents) Search(objOrRef runtime.Object) (*api.EventList, error) { c.Fake.Actions = append(c.Fake.Actions, FakeAction{Action: "search-events"}) return &c.Fake.EventsList, nil } + +func (c *FakeEvents) Delete(name string) error { + c.Fake.Actions = append(c.Fake.Actions, FakeAction{Action: "delete-event", Value: name}) + return nil +}